package ipc
import "github.com/redhatinsights/yggdrasil/ipc"
Index ¶
Variables ¶
var InterfaceDispatcher string
var InterfaceWorker string
Types ¶
type DispatcherEvent ¶
type DispatcherEvent uint
DispatcherEvent is an event emitted by the com.redhat.Yggdrasil1.Dispatcher1.Event signal.
const ( // DispatcherEventReceivedDisconnect is emitted when the dispatcher receives // the "disconnect" command. DispatcherEventReceivedDisconnect DispatcherEvent = 1 // DispatcherEventUnexpectedDisconnect is emitted when the transport unexpected // disconnects from the network. DispatcherEventUnexpectedDisconnect DispatcherEvent = 2 // DispatcherEventConnectionRestored is emitted when the transport reconnects // to the network. DispatcherEventConnectionRestored DispatcherEvent = 3 )
type WorkerEvent ¶
type WorkerEvent struct { Worker string Name WorkerEventName MessageID string ResponseTo string Data map[string]string }
type WorkerEventName ¶
type WorkerEventName uint
const ( // WorkerEventNameBegin is emitted when the worker "accepts" // a dispatched message and begins "working". WorkerEventNameBegin WorkerEventName = 1 // WorkerEventNameEnd is emitted when the worker finishes "working". WorkerEventNameEnd WorkerEventName = 2 // WorkerEventNameWorking is emitted when the worker wishes // to continue to announce it is working. WorkerEventNameWorking WorkerEventName = 3 // WorkerEventNameStarted is emitted when worker finished starting // process, and it can start process received messages. WorkerEventNameStarted WorkerEventName = 4 // WorkerEventNameStopped is emitted when worker is stopped, // and it cannot process any message. WorkerEventNameStopped WorkerEventName = 5 )
func (WorkerEventName) String ¶
func (e WorkerEventName) String() string
Source Files ¶
- Version
- v0.4.5 (latest)
- Published
- Feb 3, 2025
- Platform
- linux/amd64
- Imports
- 2 packages
- Last checked
- 3 weeks ago –
Tools for package owners.