events

Documentation

Index

• func ParseEvent(message map[string]interface{}, eventChan chan<- SaltEvent, keepRawBody bool)
• type EventData
• type EventListener
  • func NewEventListener(ctx context.Context, eventChan chan SaltEvent) *EventListener
  • func (e *EventListener) Close() error
  • func (e *EventListener) ListenEvents(keepRawBody bool)
  • func (e *EventListener) Open()
  • func (e *EventListener) Reconnect()
• type SaltEvent
  • func (e *SaltEvent) ExtractState() string
  • func (e SaltEvent) RawToJSON(indent bool) ([]byte, error)
  • func (e SaltEvent) RawToYAML() ([]byte, error)

Functions

func ParseEvent

func ParseEvent(message map[string]interface{}, eventChan chan<- SaltEvent, keepRawBody bool)

Types

type EventData

type EventData struct {
	Arg       []interface{} `msgpack:"arg"`
	Cmd       string        `msgpack:"cmd"`
	Fun       string        `msgpack:"fun"`
	FunArgs   []interface{} `msgpack:"fun_args"`
	Id        string        `msgpack:"id"`
	Jid       string        `msgpack:"jid"`
	JidStamp  string        `msgpack:"jid_stamp"`
	Minions   []string      `msgpack:"minions"`
	Missing   []string      `msgpack:"missing"`
	Out       string        `msgpack:"out"`
	Retcode   int           `msgpack:"retcode"`
	Return    interface{}   `msgpack:"return"`
	Tgt       interface{}   `msgpack:"tgt"`
	TgtType   string        `msgpack:"tgt_type"`
	Timestamp string        `msgpack:"_stamp"`
	User      string        `msgpack:"user"`
	Schedule  string        `msgpack:"schedule"`
	Success   bool          `msgpack:"success"`
}

type EventListener

type EventListener struct {
	// contains filtered or unexported fields
}

func NewEventListener

func NewEventListener(ctx context.Context, eventChan chan SaltEvent) *EventListener

func (*EventListener) Close

func (e *EventListener) Close() error

func (*EventListener) ListenEvents

func (e *EventListener) ListenEvents(keepRawBody bool)

func (*EventListener) Open

func (e *EventListener) Open()

func (*EventListener) Reconnect

func (e *EventListener) Reconnect()

type SaltEvent

type SaltEvent struct {
	Tag           string
	Type          string
	TargetNumber  int
	Data          EventData
	IsScheduleJob bool
	RawBody       []byte
}

func (*SaltEvent) ExtractState

func (e *SaltEvent) ExtractState() string

Extract state info from event

func (SaltEvent) RawToJSON

func (e SaltEvent) RawToJSON(indent bool) ([]byte, error)

func (SaltEvent) RawToYAML

func (e SaltEvent) RawToYAML() ([]byte, error)