clitrigger

Documentation

Index

• type ApUpdate
• type CliTrigger
  • func CreateCliTrigger(config *target.BaseConfig) (CliTrigger, error)
• type TriggerEvent
• type WebsocketCliTrigger
  • func NewWebsocketCliTrigger(config *target.BaseConfig, websocketUrl string) *WebsocketCliTrigger
  • func (s *WebsocketCliTrigger) TriggerChannel(ctx context.Context) <-chan TriggerEvent
  • func (s *WebsocketCliTrigger) Wait()
• type WebsocketClient
  • func NewWebsocketClient(config *target.BaseConfig, websocketUrl string) *WebsocketClient
  • func (s *WebsocketClient) Start(ctx context.Context) (<-chan interface{}, error)
  • func (s *WebsocketClient) Wait()

Types

type ApUpdate

type ApUpdate struct {
	Domain          string   `json:"domain"`
	DataSourceNames []string `json:"dataSourceNames"`
}

type CliTrigger

type CliTrigger interface {
	TriggerChannel(ctx context.Context) <-chan TriggerEvent
	Wait()
}

func CreateCliTrigger

func CreateCliTrigger(config *target.BaseConfig) (CliTrigger, error)

type TriggerEvent

type TriggerEvent struct {
	ApUpdate *ApUpdate `json:"apUpdate,omitempty"`
}

type WebsocketCliTrigger

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

func NewWebsocketCliTrigger

func NewWebsocketCliTrigger(config *target.BaseConfig, websocketUrl string) *WebsocketCliTrigger

func (*WebsocketCliTrigger) TriggerChannel

func (s *WebsocketCliTrigger) TriggerChannel(ctx context.Context) <-chan TriggerEvent

func (*WebsocketCliTrigger) Wait

func (s *WebsocketCliTrigger) Wait()

type WebsocketClient

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

func NewWebsocketClient

func NewWebsocketClient(config *target.BaseConfig, websocketUrl string) *WebsocketClient

func (*WebsocketClient) Start

func (s *WebsocketClient) Start(ctx context.Context) (<-chan interface{}, error)

func (*WebsocketClient) Wait

func (s *WebsocketClient) Wait()