eventsmocks

Documentation

Index

• type Callbacks
  • func (_m *Callbacks) ConnectionClosed(connID string)
  • func (_m *Callbacks) DeliveryResponse(connID string, inflight *core.EventDeliveryResponse)
  • func (_m *Callbacks) EphemeralSubscription(connID string, namespace string, filter *core.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 *core.Subscription, event *core.EventDelivery, ...) error
  • func (_m *Plugin) Init(ctx context.Context, _a1 config.Section) error
  • func (_m *Plugin) InitConfig(_a0 config.Section)
  • func (_m *Plugin) Name() string
  • func (_m *Plugin) SetHandler(namespace string, handler events.Callbacks) error
  • func (_m *Plugin) ValidateOptions(options *core.SubscriptionOptions) error

Types

type Callbacks

type Callbacks struct {
	mock.Mock
}

Callbacks is an autogenerated mock type for the Callbacks type

func (*Callbacks) ConnectionClosed

func (_m *Callbacks) ConnectionClosed(connID string)

ConnectionClosed provides a mock function with given fields: connID

func (*Callbacks) DeliveryResponse

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

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

func (*Callbacks) EphemeralSubscription

func (_m *Callbacks) EphemeralSubscription(connID string, namespace string, filter *core.SubscriptionFilter, options *core.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 *core.Subscription, event *core.EventDelivery, data core.DataArray) error

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

func (*Plugin) Init

func (_m *Plugin) Init(ctx context.Context, _a1 config.Section) error

Init provides a mock function with given fields: ctx, _a1

func (*Plugin) InitConfig

func (_m *Plugin) InitConfig(_a0 config.Section)

InitConfig provides a mock function with given fields: _a0

func (*Plugin) Name

func (_m *Plugin) Name() string

Name provides a mock function with given fields:

func (*Plugin) SetHandler

func (_m *Plugin) SetHandler(namespace string, handler events.Callbacks) error

SetHandler provides a mock function with given fields: namespace, handler

func (*Plugin) ValidateOptions

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

ValidateOptions provides a mock function with given fields: options