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

interfaces.go

Version
v0.4.5 (latest)
Published
Feb 3, 2025
Platform
linux/amd64
Imports
2 packages
Last checked
3 weeks ago

Tools for package owners.