Documentation
¶
Overview ¶
Package projection is a generated GoMock package.
Index ¶
- type Controller
- func (c *Controller) HandleEvent(ctx context.Context, e stream.Event) (err error)
- func (c *Controller) MatchEvent(_ context.Context, et stream.EventType) bool
- func (c *Controller) Stream(st stream.Type) *Stream
- func (c *Controller) Subscribe(ctx context.Context, sub eventbus.Subscriber) error
- func (c *Controller) Wrap(m ...eventbus.HandlerMiddleware)
- type Filter
- type Handler
- type HandlerFunc
- type MockHandler
- type MockHandlerMockRecorder
- type Stream
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func New ¶
func New(d eventbus.Duplicator) *Controller
func (*Controller) HandleEvent ¶
func (*Controller) MatchEvent ¶
func (*Controller) Subscribe ¶
func (c *Controller) Subscribe(ctx context.Context, sub eventbus.Subscriber) error
func (*Controller) Wrap ¶
func (c *Controller) Wrap(m ...eventbus.HandlerMiddleware)
type HandlerFunc ¶
type MockHandler ¶
type MockHandler struct {
// contains filtered or unexported fields
}
MockHandler is a mock of Handler interface
func NewMockHandler ¶
func NewMockHandler(ctrl *gomock.Controller) *MockHandler
NewMockHandler creates a new mock instance
func (*MockHandler) EXPECT ¶
func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
type MockHandlerMockRecorder ¶
type MockHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockHandlerMockRecorder is the mock recorder for MockHandler
func (*MockHandlerMockRecorder) Handle ¶
func (mr *MockHandlerMockRecorder) Handle(arg0, arg1 interface{}) *gomock.Call
Handle indicates an expected call of Handle
Source Files
Click to show internal directories.
Click to hide internal directories.