Documentation ¶
Index ¶
- type Callbacks
- func (_m *Callbacks) ConnectionClosed(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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Callbacks ¶
Callbacks is an autogenerated mock type for the Callbacks type
func (*Callbacks) ConnectionClosed ¶ added in v1.0.0
ConnectionClosed 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 ¶
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.DataArray) error
DeliveryRequest provides a mock function with given fields: connID, sub, event, data
func (*Plugin) GetOptionsSchema ¶
GetOptionsSchema provides a mock function with given fields: _a0
func (*Plugin) InitPrefix ¶
InitPrefix provides a mock function with given fields: prefix
func (*Plugin) ValidateOptions ¶
func (_m *Plugin) ValidateOptions(options *fftypes.SubscriptionOptions) error
ValidateOptions provides a mock function with given fields: options