From Fedora Project Wiki
mNo edit summary
mNo edit summary
 
(14 intermediate revisions by the same user not shown)
Line 2: Line 2:


=== Configuration ===
=== Configuration ===
Koji message bus integration is implemented via a Koji hub plugin, which registers a callback that is executed when certain events occur on the hub.  To install the plugin, install the <code>koji-hub-plugins</code> package on the Koji hub machine.  To enable the plugin, edit the <code>Plugins =</code> entry of <code>/etc/koji-hub/hub.conf</code> so it contains <code>messagebus</code>.  Make sure the <code>Plugins</code> entry is not commented out.
Koji message bus integration is implemented via a Koji hub plugin, which registers a callback that is executed when certain events occur on the hub.  To install the plugin, install the <code>koji-hub-plugins</code> package on the Koji hub machine.  To enable the plugin, edit the <code>Plugins</code> entry of <code>/etc/koji-hub/hub.conf</code> so it contains <code>messagebus</code>.  Make sure the <code>Plugins</code> entry is not commented out.


Configuration of the message bus plugin itself is handled by editing <code>/etc/koji-hub/plugins/messagebus.conf</code>.  The <code>[broker]</code> section defines how to connect to the AMQP broker you want to use.  <code>auth</code> can be any authentication type supported by the SASL configuration of the broker.  If using <code>auth = PLAIN</code>, you must also provide a <code>username</code> and <code>password</code>, and it is highly recommended to set <code>ssl = true</code>.  Otherwise you'll be sending your username and password over the network in plain text.
Configuration of the message bus plugin itself is handled by editing <code>/etc/koji-hub/plugins/messagebus.conf</code>.  The <code>[broker]</code> section defines how to connect to the AMQP broker you want to use.  <code>auth</code> can be any authentication type supported by the SASL configuration of the broker.  If using <code>auth = PLAIN</code>, you must also provide a <code>username</code> and <code>password</code>, and it is highly recommended to set <code>ssl = true</code>.  Otherwise you'll be sending your username and password over the network in plain text.
Line 8: Line 8:
The <code>[exchange]</code> section determines where the plugin will send messages.  The <code>type</code> option may be <code>topic</code> or <code>headers</code>.  The exchange may already exist, or the plugin will create it, in which case the account being used to connect to the broker must have sufficient privileges to create exchanges.
The <code>[exchange]</code> section determines where the plugin will send messages.  The <code>type</code> option may be <code>topic</code> or <code>headers</code>.  The exchange may already exist, or the plugin will create it, in which case the account being used to connect to the broker must have sufficient privileges to create exchanges.


If using a topic exchange, you can set the prefix of the message routing key with the <code>prefix</code> option in the <code>topic</code> section.
If using a topic exchange, you can set the prefix of the message routing key with the <code>prefix</code> option in the <code>[topic]</code> section.


The body of the messages will be encoded in the format specified by the <code>encoding</code> option in the <code>format</code> section.  Right now the only supported format is <code>json</code>.
Messages are encoded/decoded using qpid's native datatype handling.  Message contents will be provided in the native data structures of the language of the receiving process.


=== Message Formats ===
=== Message Formats ===
The following table lists the events for which messages are sent out, the structure of the routing key (when using a topic exchange), the message headers (when using a headers exchange), and the fields present in the body of the message.  All message bodies are json-encoded key/value maps.
The following table lists the events for which messages are sent out, the structure of the routing key (when using a topic exchange), the message headers (when using a headers exchange), and the fields present in the body of the message.  All message bodies are key/value maps.


{|
{|style="width: 100%; table-layout: fixed"
|-
|-
! Type  !!  Routing Key  !!  Message Headers  !!  Body
!style="width: 12em" |  Type  !!  Routing Key  !!  Message Headers  !!  Body
|-
|-
| '''PackageListChange'''
| '''PackageListChange'''
Line 74: Line 74:
|
|
   type (string): Import
   type (string): Import
   importType (string): build, rpm, or image
   importType (string): build, rpm, archive, or image
|
|
   type (string): build, rpm, or image
   type (string): build, rpm, or image
Line 88: Line 88:
     rpm (map): rpm info
     rpm (map): rpm info
     build (map): build info
     build (map): build info
    filepath (string): path to file being imported
  if type == archive:
    archive (map): archive info
    build (map): build info
    build_type (string): type of build
    filepath (string): path to file being imported
   if type == image:
   if type == image:
     image (map): image info
     image (map): image info
    filepath (string): path to file being imported
|-
|-
| '''Tag''' or '''Untag'''
| '''Tag''' and '''Untag'''
|
|
   [prefix].[Tag or Untag].[tag name].[package name].[user name]
   [prefix].[Tag or Untag].[tag name].[package name].[user name]
Line 104: Line 111:
   tag (map): tag info
   tag (map): tag info
   build (map): build info
   build (map): build info
   user (map): build info
   user (map): user info
   force (bool)
   force (bool)
   if type == Untag:
   if type == Untag:
     strict (bool)
     strict (bool)
|-
| '''RepoInit'''
|
  [prefix].RepoInit.[tag name]
|
  tag (string): tag name
|
  tag (map): tag info
  with_src (bool)
  with_debuginfo (bool)
  event (int): event ID
  repo_id (int)
|-
| '''RepoDone'''
|
  [prefix].RepoDone.[tag name]
|
  tag (string): tag name
|
  repo (map): repo info
  data (map): map of arch -> (uploadpath, [files])
  expire (bool)
|}
|}

Latest revision as of 22:57, 23 July 2013

Koji can be configured to send notifications of events and state changes to a AMQP (qpid) broker. This page explains how to configure Koji to communicate with a message bus and documents the structure and contents of the messages it sends.

Configuration

Koji message bus integration is implemented via a Koji hub plugin, which registers a callback that is executed when certain events occur on the hub. To install the plugin, install the koji-hub-plugins package on the Koji hub machine. To enable the plugin, edit the Plugins entry of /etc/koji-hub/hub.conf so it contains messagebus. Make sure the Plugins entry is not commented out.

Configuration of the message bus plugin itself is handled by editing /etc/koji-hub/plugins/messagebus.conf. The [broker] section defines how to connect to the AMQP broker you want to use. auth can be any authentication type supported by the SASL configuration of the broker. If using auth = PLAIN, you must also provide a username and password, and it is highly recommended to set ssl = true. Otherwise you'll be sending your username and password over the network in plain text.

The [exchange] section determines where the plugin will send messages. The type option may be topic or headers. The exchange may already exist, or the plugin will create it, in which case the account being used to connect to the broker must have sufficient privileges to create exchanges.

If using a topic exchange, you can set the prefix of the message routing key with the prefix option in the [topic] section.

Messages are encoded/decoded using qpid's native datatype handling. Message contents will be provided in the native data structures of the language of the receiving process.

Message Formats

The following table lists the events for which messages are sent out, the structure of the routing key (when using a topic exchange), the message headers (when using a headers exchange), and the fields present in the body of the message. All message bodies are key/value maps.

Type Routing Key Message Headers Body
PackageListChange
 [prefix].PackageListChange.[tag name].[package name]
 type (string): PackageListChange
 tag (string): tag name
 package (string): package name
 action (string): add, update, block,
                 unblock, or remove
 tag (map): tag info
 package (map): package info
 owner (int): owner ID
 block (bool)
 extra_arches (string)
 force (bool)
 update (bool)
TaskStateChange
 [prefix].TaskStateChange.[task method].[attribute changed]
 type (string): TaskStateChange
 method (string): task method
 attribute (string): attribute changed
 old (variable): previous value of attribute
 new (variable): current value of attribute
 attribute (string): attribute changed
 old (variable): previous value of attribute
 new (variable): current value of attribute
 info (map): task info
BuildStateChange
 [prefix].BuildStateChange.[attribute changed].[package name]
 type (string): BuildStateChange
 name (string): package name
 version (string): build version
 release (string): build release
 attribute (string): attribute changed
 old (variable): previous value of attribute
 new (variable): current value of attribute
 attribute (string): attribute changed
 old (variable): previous value of attribute
 new (variable): current value of attribute
 info (map): build info
Import
 [prefix].Import.[import type]
 type (string): Import
 importType (string): build, rpm, archive, or image
 type (string): build, rpm, or image
 if type == build:
   srpm (string)
   rpms (list)
   brmap (map): map of rpm paths -> buildroot ids
   task_id (int)
   build_id (int)
   build (map): build info
   logs (map): map of task arch -> list of log files
 if type == rpm:
   rpm (map): rpm info
   build (map): build info
   filepath (string): path to file being imported
 if type == archive:
   archive (map): archive info
   build (map): build info
   build_type (string): type of build
   filepath (string): path to file being imported
 if type == image:
   image (map): image info
   filepath (string): path to file being imported
Tag and Untag
 [prefix].[Tag or Untag].[tag name].[package name].[user name]
 type (string): Tag or Untag
 tag (string): tag name
 name (string): package name
 version (string): build version
 release (string): build release
 user (string): user name
 tag (map): tag info
 build (map): build info
 user (map): user info
 force (bool)
 if type == Untag:
   strict (bool)
RepoInit
 [prefix].RepoInit.[tag name]
 tag (string): tag name
 tag (map): tag info
 with_src (bool)
 with_debuginfo (bool)
 event (int): event ID
 repo_id (int)
RepoDone
 [prefix].RepoDone.[tag name]
 tag (string): tag name
 repo (map): repo info
 data (map): map of arch -> (uploadpath, [files])
 expire (bool)