eventing

Documentation

Index

• Constants
• Variables
• func SendErrorResponse(from string, status int32)
• func SendMessage(msg Message) error
• func SendResponse(msg Message)
• type Message
  • func CreateMessage(to, from, event string, status int32, content any) Message
• type MessageHandler

Constants

const (
	StartupEvent   = "event:startup"
	ShutdownEvent  = "event:shutdown"
	StartupPause   = "event:pause"
	ShutdownResume = "event:resume"
	ErrorEvent     = "event:error"
	RestartEvent   = "event:restart"
	FailoverEvent  = "event:failover"
	FailbackEvent  = "event:failback"
	PingEvent      = "event:ping"
	ProfileEvent   = "event:profile"
	VirtualHost    = "vhost"

	StatusInProgress  = -100
	StatusNotProvided = -101
)

Variables

var Directory *syncMap

Functions

func SendErrorResponse

func SendErrorResponse(from string, status int32)

func SendMessage

func SendMessage(msg Message) error

func SendResponse

func SendResponse(msg Message)

Types

type Message

type Message struct {
	To       string
	From     string
	Event    string
	Content  any
	Status   int32
	CreateTS time.Time
}

func CreateMessage

func CreateMessage(to, from, event string, status int32, content any) Message

type MessageHandler

type MessageHandler func(msg Message)