system

Documentation

Index

• Constants
• type EventListener
• type Events
  • func (se *Events) AddListener(ns string, el EventListener) error
  • func (se *Events) Capabilities() *events.Capabilities
  • func (se *Events) DeliveryRequest(connID string, sub *fftypes.Subscription, event *fftypes.EventDelivery, ...) error
  • func (se *Events) GetOptionsSchema(ctx context.Context) string
  • func (se *Events) Init(ctx context.Context, prefix config.Prefix, callbacks events.Callbacks) (err error)
  • func (se *Events) InitPrefix(prefix config.Prefix)
  • func (se *Events) Name() string
  • func (se *Events) ValidateOptions(options *fftypes.SubscriptionOptions) error

Constants

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

const (
	SystemEventsTransport = "system"
)

Types

type EventListener

type EventListener func(event *fftypes.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) Capabilities

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

func (*Events) DeliveryRequest

func (se *Events) DeliveryRequest(connID string, sub *fftypes.Subscription, event *fftypes.EventDelivery, data []*fftypes.Data) error

func (*Events) GetOptionsSchema

func (se *Events) GetOptionsSchema(ctx context.Context) string

func (*Events) Init

func (se *Events) Init(ctx context.Context, prefix config.Prefix, callbacks events.Callbacks) (err error)

func (*Events) InitPrefix

func (se *Events) InitPrefix(prefix config.Prefix)

func (*Events) Name

func (se *Events) Name() string

func (*Events) ValidateOptions

func (se *Events) ValidateOptions(options *fftypes.SubscriptionOptions) error