system

Documentation

Index

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

Constants

const (
	// SystemEventsConfReadAhead is the readahead used for system events
	SystemEventsConfReadAhead = "readAhead"
)

const (
	SystemEventsTransport = "system"
)

Types

type EventInterface

type EventInterface interface {
	AddSystemEventListener(ns string, el EventListener) error
}

type EventListener

type EventListener func(event *core.EventDelivery) error

type Events

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

Events the system events listener is used for system components that need access to confirmed events, such as the sync<->async bridge.

func (*Events) AddListener

func (se *Events) AddListener(ns string, el EventListener) error

func (*Events) BatchDeliveryRequest

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

func (*Events) Capabilities

func (se *Events) Capabilities() *events.Capabilities

func (*Events) DeliveryRequest

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

func (*Events) Init

func (se *Events) Init(ctx context.Context, config config.Section) (err error)

func (*Events) InitConfig

func (se *Events) InitConfig(config config.Section)

func (*Events) Name

func (se *Events) Name() string

func (*Events) NamespaceRestarted

func (se *Events) NamespaceRestarted(ns string, startTime time.Time)

func (*Events) SetHandler

func (se *Events) SetHandler(namespace string, handler events.Callbacks) error

func (*Events) ValidateOptions

func (se *Events) ValidateOptions(ctx context.Context, options *core.SubscriptionOptions) error