Documentation
¶
Overview ¶
Package messagebus logic to send message and get reply over IPC
Index ¶
Constants ¶
View Source
const (
DefaultCreateChannelRetryIntervalSeconds = 5
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IMessageBus ¶
type IMessageBus interface {
Start() error
SendSurveyMessage(survey *message.Message) ([]*message.Message, error)
Stop()
}
IMessageBus is the interface for sending out survey message and receiving the result
type MessageBus ¶
type MessageBus struct {
// contains filtered or unexported fields
}
MessageBus contains the ipc channel to communicate to core agent.
func NewMessageBus ¶
func NewMessageBus(context context.ICoreAgentContext) *MessageBus
NewMessageBus creates a new instance of message bus
func (*MessageBus) SendSurveyMessage ¶
SendSurveyMessage sends the health or termination survey message
func (*MessageBus) Start ¶
func (bus *MessageBus) Start() error
Start starts the health and terminate worker message channel
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.