webhooks

Documentation

Index

• type WebHooks
  • func (wh *WebHooks) BatchDeliveryRequest(ctx context.Context, connID string, sub *core.Subscription, ...) error
  • func (wh *WebHooks) Capabilities() *events.Capabilities
  • func (wh *WebHooks) DeliveryRequest(ctx context.Context, connID string, sub *core.Subscription, ...) error
  • func (wh *WebHooks) Init(ctx context.Context, config config.Section) (err error)
  • func (wh *WebHooks) InitConfig(config config.Section)
  • func (wh *WebHooks) Name() string
  • func (wh *WebHooks) NamespaceRestarted(ns string, startTime time.Time)
  • func (wh *WebHooks) SetHandler(namespace string, handler events.Callbacks) error
  • func (wh *WebHooks) ValidateOptions(ctx context.Context, options *core.SubscriptionOptions) error

Types

type WebHooks

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

func (*WebHooks) BatchDeliveryRequest

func (wh *WebHooks) BatchDeliveryRequest(ctx context.Context, connID string, sub *core.Subscription, events []*core.CombinedEventDataDelivery) error

func (*WebHooks) Capabilities

func (wh *WebHooks) Capabilities() *events.Capabilities

func (*WebHooks) DeliveryRequest

func (wh *WebHooks) DeliveryRequest(ctx context.Context, connID string, sub *core.Subscription, event *core.EventDelivery, data core.DataArray) error

func (*WebHooks) Init

func (wh *WebHooks) Init(ctx context.Context, config config.Section) (err error)

func (*WebHooks) InitConfig

func (wh *WebHooks) InitConfig(config config.Section)

func (*WebHooks) Name

func (wh *WebHooks) Name() string

func (*WebHooks) NamespaceRestarted

func (wh *WebHooks) NamespaceRestarted(ns string, startTime time.Time)

func (*WebHooks) SetHandler

func (wh *WebHooks) SetHandler(namespace string, handler events.Callbacks) error

func (*WebHooks) ValidateOptions

func (wh *WebHooks) ValidateOptions(ctx context.Context, options *core.SubscriptionOptions) error