Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ParseEvent ¶
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()
Click to show internal directories.
Click to hide internal directories.