Versions in this module Expand all Collapse all v0 v0.2.0 Oct 3, 2026 v0.1.0 Oct 1, 2026 Changes in this version + type MockLifecycle struct + func NewMockLifecycle(ctrl *gomock.Controller) *MockLifecycle + func (m *MockLifecycle) EXPECT() *MockLifecycleMockRecorder + func (m *MockLifecycle) Start() + func (m *MockLifecycle) Stop(ctx context.Context) + type MockLifecycleMockRecorder struct + func (mr *MockLifecycleMockRecorder) Start() *gomock.Call + func (mr *MockLifecycleMockRecorder) Stop(ctx any) *gomock.Call + type MockNATSConnector struct + func NewMockNATSConnector(ctrl *gomock.Controller) *MockNATSConnector + func (m *MockNATSConnector) Close() + func (m *MockNATSConnector) Connect(url string, opts ...nats.Option) (*nats.Conn, error) + func (m *MockNATSConnector) ConnectedUrl() string + func (m *MockNATSConnector) EXPECT() *MockNATSConnectorMockRecorder + func (m *MockNATSConnector) JetStream(opts ...nats.JSOpt) (nats.JetStreamContext, error) + func (m *MockNATSConnector) Publish(subject string, data []byte) error + func (m *MockNATSConnector) QueueSubscribe(subject, queue string, handler nats.MsgHandler) (*nats.Subscription, error) + func (m *MockNATSConnector) Subscribe(subject string, handler nats.MsgHandler) (*nats.Subscription, error) + type MockNATSConnectorMockRecorder struct + func (mr *MockNATSConnectorMockRecorder) Close() *gomock.Call + func (mr *MockNATSConnectorMockRecorder) Connect(url any, opts ...any) *gomock.Call + func (mr *MockNATSConnectorMockRecorder) ConnectedUrl() *gomock.Call + func (mr *MockNATSConnectorMockRecorder) JetStream(opts ...any) *gomock.Call + func (mr *MockNATSConnectorMockRecorder) Publish(subject, data any) *gomock.Call + func (mr *MockNATSConnectorMockRecorder) QueueSubscribe(subject, queue, handler any) *gomock.Call + func (mr *MockNATSConnectorMockRecorder) Subscribe(subject, handler any) *gomock.Call
Go to main page