eventsmocks

Documentation

Index

• type Callbacks
  • func (_m *Callbacks) ConnnectionClosed(connID string)
  • func (_m *Callbacks) DeliveryResponse(connID string, inflight *fftypes.EventDeliveryResponse)
  • func (_m *Callbacks) EphemeralSubscription(connID string, namespace string, filter *fftypes.SubscriptionFilter, ...) error
  • func (_m *Callbacks) RegisterConnection(connID string, matcher events.SubscriptionMatcher) error
• type Plugin
  • func (_m *Plugin) Capabilities() *events.Capabilities
  • func (_m *Plugin) DeliveryRequest(connID string, sub *fftypes.Subscription, event *fftypes.EventDelivery, ...) error
  • func (_m *Plugin) GetOptionsSchema(_a0 context.Context) string
  • func (_m *Plugin) Init(ctx context.Context, prefix config.Prefix, callbacks events.Callbacks) error
  • func (_m *Plugin) InitPrefix(prefix config.Prefix)
  • func (_m *Plugin) Name() string
  • func (_m *Plugin) ValidateOptions(options *fftypes.SubscriptionOptions) error
• type PluginAll
  • func (_m *PluginAll) Capabilities() *events.Capabilities
  • func (_m *PluginAll) ChangeEvent(connID string, ce *fftypes.ChangeEvent)
  • func (_m *PluginAll) DeliveryRequest(connID string, sub *fftypes.Subscription, event *fftypes.EventDelivery, ...) error
  • func (_m *PluginAll) GetOptionsSchema(_a0 context.Context) string
  • func (_m *PluginAll) Init(ctx context.Context, prefix config.Prefix, callbacks events.Callbacks) error
  • func (_m *PluginAll) InitPrefix(prefix config.Prefix)
  • func (_m *PluginAll) Name() string
  • func (_m *PluginAll) ValidateOptions(options *fftypes.SubscriptionOptions) error

Types

type Callbacks

type Callbacks struct {
	mock.Mock
}

Callbacks is an autogenerated mock type for the Callbacks type

func (*Callbacks) ConnnectionClosed

func (_m *Callbacks) ConnnectionClosed(connID string)

ConnnectionClosed provides a mock function with given fields: connID

func (*Callbacks) DeliveryResponse

func (_m *Callbacks) DeliveryResponse(connID string, inflight *fftypes.EventDeliveryResponse)

DeliveryResponse provides a mock function with given fields: connID, inflight

func (*Callbacks) EphemeralSubscription

func (_m *Callbacks) EphemeralSubscription(connID string, namespace string, filter *fftypes.SubscriptionFilter, options *fftypes.SubscriptionOptions) error

EphemeralSubscription provides a mock function with given fields: connID, namespace, filter, options

func (*Callbacks) RegisterConnection

func (_m *Callbacks) RegisterConnection(connID string, matcher events.SubscriptionMatcher) error

RegisterConnection provides a mock function with given fields: connID, matcher

type Plugin

type Plugin struct {
	mock.Mock
}

Plugin is an autogenerated mock type for the Plugin type

func (*Plugin) Capabilities

func (_m *Plugin) Capabilities() *events.Capabilities

Capabilities provides a mock function with given fields:

func (*Plugin) DeliveryRequest

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

DeliveryRequest provides a mock function with given fields: connID, sub, event, data

func (*Plugin) GetOptionsSchema

func (_m *Plugin) GetOptionsSchema(_a0 context.Context) string

GetOptionsSchema provides a mock function with given fields: _a0

func (*Plugin) Init

func (_m *Plugin) Init(ctx context.Context, prefix config.Prefix, callbacks events.Callbacks) error

Init provides a mock function with given fields: ctx, prefix, callbacks

func (*Plugin) InitPrefix

func (_m *Plugin) InitPrefix(prefix config.Prefix)

InitPrefix provides a mock function with given fields: prefix

func (*Plugin) Name

func (_m *Plugin) Name() string

Name provides a mock function with given fields:

func (*Plugin) ValidateOptions

func (_m *Plugin) ValidateOptions(options *fftypes.SubscriptionOptions) error

ValidateOptions provides a mock function with given fields: options

type PluginAll

type PluginAll struct {
	mock.Mock
}

PluginAll is an autogenerated mock type for the PluginAll type

func (*PluginAll) Capabilities

func (_m *PluginAll) Capabilities() *events.Capabilities

Capabilities provides a mock function with given fields:

func (*PluginAll) ChangeEvent

func (_m *PluginAll) ChangeEvent(connID string, ce *fftypes.ChangeEvent)

ChangeEvent provides a mock function with given fields: connID, ce

func (*PluginAll) DeliveryRequest

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

DeliveryRequest provides a mock function with given fields: connID, sub, event, data

func (*PluginAll) GetOptionsSchema

func (_m *PluginAll) GetOptionsSchema(_a0 context.Context) string

GetOptionsSchema provides a mock function with given fields: _a0

func (*PluginAll) Init

func (_m *PluginAll) Init(ctx context.Context, prefix config.Prefix, callbacks events.Callbacks) error

Init provides a mock function with given fields: ctx, prefix, callbacks

func (*PluginAll) InitPrefix

func (_m *PluginAll) InitPrefix(prefix config.Prefix)

InitPrefix provides a mock function with given fields: prefix

func (*PluginAll) Name

func (_m *PluginAll) Name() string

Name provides a mock function with given fields:

func (*PluginAll) ValidateOptions

func (_m *PluginAll) ValidateOptions(options *fftypes.SubscriptionOptions) error

ValidateOptions provides a mock function with given fields: options