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 MockMsg struct + func NewMockMsg(ctrl *gomock.Controller) *MockMsg + func (m *MockMsg) Ack() error + func (m *MockMsg) Data() []byte + func (m *MockMsg) DoubleAck(arg0 context.Context) error + func (m *MockMsg) EXPECT() *MockMsgMockRecorder + func (m *MockMsg) Headers() nats.Header + func (m *MockMsg) InProgress() error + func (m *MockMsg) Metadata() (*jetstream.MsgMetadata, error) + func (m *MockMsg) Nak() error + func (m *MockMsg) NakWithDelay(delay time.Duration) error + func (m *MockMsg) Reply() string + func (m *MockMsg) Subject() string + func (m *MockMsg) Term() error + func (m *MockMsg) TermWithReason(reason string) error + type MockMsgMockRecorder struct + func (mr *MockMsgMockRecorder) Ack() *gomock.Call + func (mr *MockMsgMockRecorder) Data() *gomock.Call + func (mr *MockMsgMockRecorder) DoubleAck(arg0 any) *gomock.Call + func (mr *MockMsgMockRecorder) Headers() *gomock.Call + func (mr *MockMsgMockRecorder) InProgress() *gomock.Call + func (mr *MockMsgMockRecorder) Metadata() *gomock.Call + func (mr *MockMsgMockRecorder) Nak() *gomock.Call + func (mr *MockMsgMockRecorder) NakWithDelay(delay any) *gomock.Call + func (mr *MockMsgMockRecorder) Reply() *gomock.Call + func (mr *MockMsgMockRecorder) Subject() *gomock.Call + func (mr *MockMsgMockRecorder) Term() *gomock.Call + func (mr *MockMsgMockRecorder) TermWithReason(reason any) *gomock.Call + type MockNATSPublisher struct + func NewMockNATSPublisher(ctrl *gomock.Controller) *MockNATSPublisher + func (m *MockNATSPublisher) EXPECT() *MockNATSPublisherMockRecorder + func (m *MockNATSPublisher) PublishCore(subject string, data []byte) error + func (m *MockNATSPublisher) Subscribe(subject string, handler nats.MsgHandler) (*nats.Subscription, error) + type MockNATSPublisherMockRecorder struct + func (mr *MockNATSPublisherMockRecorder) PublishCore(subject, data any) *gomock.Call + func (mr *MockNATSPublisherMockRecorder) Subscribe(subject, handler any) *gomock.Call
Go to main page