clitrigger

Documentation

Index

• type ApUpdate
• type ApUpdateTriggerHandler
  • func NewApUpdateTrigger(cliTrigger CliTrigger) *ApUpdateTriggerHandler
  • func NewApUpdateTriggerHandler() *ApUpdateTriggerHandler
  • func (h *ApUpdateTriggerHandler) Close()
  • func (h *ApUpdateTriggerHandler) HandleTriggerEvent(_ context.Context, triggerEvent *TriggerEvent)
  • func (h *ApUpdateTriggerHandler) Pop() *ApUpdate
  • func (h *ApUpdateTriggerHandler) TriggerChannel() <-chan struct{}
• type CliTrigger
  • func CreateCliTrigger(config *types.BaseConfig) (CliTrigger, error)
• type DummyCliTrigger
  • func (d DummyCliTrigger) Reset()
  • func (d DummyCliTrigger) Start(_ context.Context)
  • func (d DummyCliTrigger) Subscribe(_ TriggerHandler)
  • func (d DummyCliTrigger) Wait()
• type TriggerEvent
• type TriggerHandler
• type WebsocketCliTrigger
  • func NewWebsocketCliTrigger(config *types.BaseConfig, websocketUrl string) *WebsocketCliTrigger
  • func (s *WebsocketCliTrigger) Reset()
  • func (s *WebsocketCliTrigger) Start(ctx context.Context)
  • func (s *WebsocketCliTrigger) Subscribe(handler TriggerHandler)
  • func (s *WebsocketCliTrigger) Wait()
• type WebsocketClient
  • func NewWebsocketClient(config *types.BaseConfig, websocketUrl string) *WebsocketClient
  • func (s *WebsocketClient) Start(ctx context.Context) (<-chan interface{}, error)
  • func (s *WebsocketClient) Wait()
• type WebsocketMessageError
  • func (e *WebsocketMessageError) Error() string

Types

type ApUpdate

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

type ApUpdateTriggerHandler

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

func NewApUpdateTrigger

func NewApUpdateTrigger(cliTrigger CliTrigger) *ApUpdateTriggerHandler

func NewApUpdateTriggerHandler

func NewApUpdateTriggerHandler() *ApUpdateTriggerHandler

func (*ApUpdateTriggerHandler) Close

func (h *ApUpdateTriggerHandler) Close()

func (*ApUpdateTriggerHandler) HandleTriggerEvent

func (h *ApUpdateTriggerHandler) HandleTriggerEvent(_ context.Context, triggerEvent *TriggerEvent)

func (*ApUpdateTriggerHandler) Pop

func (h *ApUpdateTriggerHandler) Pop() *ApUpdate

func (*ApUpdateTriggerHandler) TriggerChannel

func (h *ApUpdateTriggerHandler) TriggerChannel() <-chan struct{}

type CliTrigger

type CliTrigger interface {
	Start(ctx context.Context)
	Subscribe(handler TriggerHandler)
	Reset()
	Wait()
}

func CreateCliTrigger

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

type DummyCliTrigger

type DummyCliTrigger struct {
}

func (DummyCliTrigger) Reset

func (d DummyCliTrigger) Reset()

func (DummyCliTrigger) Start

func (d DummyCliTrigger) Start(_ context.Context)

func (DummyCliTrigger) Subscribe

func (d DummyCliTrigger) Subscribe(_ TriggerHandler)

func (DummyCliTrigger) Wait

func (d DummyCliTrigger) Wait()

type TriggerEvent

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

type TriggerHandler

type TriggerHandler interface {
	HandleTriggerEvent(ctx context.Context, triggerEvent *TriggerEvent)
}

type WebsocketCliTrigger

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

func NewWebsocketCliTrigger

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

func (*WebsocketCliTrigger) Reset

func (s *WebsocketCliTrigger) Reset()

func (*WebsocketCliTrigger) Start

func (s *WebsocketCliTrigger) Start(ctx context.Context)

func (*WebsocketCliTrigger) Subscribe

func (s *WebsocketCliTrigger) Subscribe(handler TriggerHandler)

func (*WebsocketCliTrigger) Wait

func (s *WebsocketCliTrigger) Wait()

type WebsocketClient

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

func NewWebsocketClient

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

func (*WebsocketClient) Start

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

func (*WebsocketClient) Wait

func (s *WebsocketClient) Wait()

type WebsocketMessageError

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

func (*WebsocketMessageError) Error

func (e *WebsocketMessageError) Error() string