mocks

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 3, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks provides mock implementations for testing.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockAgentKeyStore 

type MockAgentKeyStore struct {
	// contains filtered or unexported fields
}

MockAgentKeyStore is a mock of AgentKeyStore interface.

func NewMockAgentKeyStore 

func NewMockAgentKeyStore(ctrl *gomock.Controller) *MockAgentKeyStore

NewMockAgentKeyStore creates a new mock instance.

func (*MockAgentKeyStore) EXPECT 

func (m *MockAgentKeyStore) EXPECT() *MockAgentKeyStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAgentKeyStore) LookupAgentKey 

func (m *MockAgentKeyStore) LookupAgentKey(ctx context.Context, machineID string) (*client.AgentKey, error)

LookupAgentKey mocks base method.

type MockAgentKeyStoreMockRecorder 

type MockAgentKeyStoreMockRecorder struct {
	// contains filtered or unexported fields
}

MockAgentKeyStoreMockRecorder is the mock recorder for MockAgentKeyStore.

func (*MockAgentKeyStoreMockRecorder) LookupAgentKey 

func (mr *MockAgentKeyStoreMockRecorder) LookupAgentKey(ctx, machineID any) *gomock.Call

LookupAgentKey indicates an expected call of LookupAgentKey.

type MockJetStream 

type MockJetStream struct {
	// contains filtered or unexported fields
}

MockJetStream is a mock of JetStream interface.

func NewMockJetStream 

func NewMockJetStream(ctrl *gomock.Controller) *MockJetStream

NewMockJetStream creates a new mock instance.

func (*MockJetStream) AccountInfo 

func (m *MockJetStream) AccountInfo(arg0 context.Context) (*jetstream.AccountInfo, error)

AccountInfo mocks base method.

func (*MockJetStream) CleanupPublisher 

func (m *MockJetStream) CleanupPublisher()

CleanupPublisher mocks base method.

func (*MockJetStream) Conn 

func (m *MockJetStream) Conn() *nats.Conn

Conn mocks base method.

func (*MockJetStream) Consumer 

func (m *MockJetStream) Consumer(arg0 context.Context, arg1, arg2 string) (jetstream.Consumer, error)

Consumer mocks base method.

func (*MockJetStream) CreateConsumer 

func (m *MockJetStream) CreateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateConsumer mocks base method.

func (*MockJetStream) CreateKeyValue 

func (m *MockJetStream) CreateKeyValue(arg0 context.Context, arg1 jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateKeyValue mocks base method.

func (*MockJetStream) CreateObjectStore 

func (m *MockJetStream) CreateObjectStore(arg0 context.Context, arg1 jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateObjectStore mocks base method.

func (*MockJetStream) CreateOrUpdateConsumer 

func (m *MockJetStream) CreateOrUpdateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

CreateOrUpdateConsumer mocks base method.

func (*MockJetStream) CreateOrUpdateKeyValue 

func (m *MockJetStream) CreateOrUpdateKeyValue(arg0 context.Context, arg1 jetstream.KeyValueConfig) (jetstream.KeyValue, error)

CreateOrUpdateKeyValue mocks base method.

func (*MockJetStream) CreateOrUpdateObjectStore 

func (m *MockJetStream) CreateOrUpdateObjectStore(arg0 context.Context, arg1 jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

CreateOrUpdateObjectStore mocks base method.

func (*MockJetStream) CreateOrUpdateStream 

func (m *MockJetStream) CreateOrUpdateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

CreateOrUpdateStream mocks base method.

func (*MockJetStream) CreateStream 

func (m *MockJetStream) CreateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

CreateStream mocks base method.

func (*MockJetStream) DeleteConsumer 

func (m *MockJetStream) DeleteConsumer(arg0 context.Context, arg1, arg2 string) error

DeleteConsumer mocks base method.

func (*MockJetStream) DeleteKeyValue 

func (m *MockJetStream) DeleteKeyValue(arg0 context.Context, arg1 string) error

DeleteKeyValue mocks base method.

func (*MockJetStream) DeleteObjectStore 

func (m *MockJetStream) DeleteObjectStore(arg0 context.Context, arg1 string) error

DeleteObjectStore mocks base method.

func (*MockJetStream) DeleteStream 

func (m *MockJetStream) DeleteStream(arg0 context.Context, arg1 string) error

DeleteStream mocks base method.

func (*MockJetStream) EXPECT 

func (m *MockJetStream) EXPECT() *MockJetStreamMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockJetStream) KeyValue 

func (m *MockJetStream) KeyValue(arg0 context.Context, arg1 string) (jetstream.KeyValue, error)

KeyValue mocks base method.

func (*MockJetStream) KeyValueStoreNames 

func (m *MockJetStream) KeyValueStoreNames(arg0 context.Context) jetstream.KeyValueNamesLister

KeyValueStoreNames mocks base method.

func (*MockJetStream) KeyValueStores 

func (m *MockJetStream) KeyValueStores(arg0 context.Context) jetstream.KeyValueLister

KeyValueStores mocks base method.

func (*MockJetStream) ListStreams 

func (m *MockJetStream) ListStreams(arg0 context.Context, arg1 ...jetstream.StreamListOpt) jetstream.StreamInfoLister

ListStreams mocks base method.

func (*MockJetStream) ObjectStore 

func (m *MockJetStream) ObjectStore(arg0 context.Context, arg1 string) (jetstream.ObjectStore, error)

ObjectStore mocks base method.

func (*MockJetStream) ObjectStoreNames 

func (m *MockJetStream) ObjectStoreNames(arg0 context.Context) jetstream.ObjectStoreNamesLister

ObjectStoreNames mocks base method.

func (*MockJetStream) ObjectStores 

func (m *MockJetStream) ObjectStores(arg0 context.Context) jetstream.ObjectStoresLister

ObjectStores mocks base method.

func (*MockJetStream) Options 

func (m *MockJetStream) Options() jetstream.JetStreamOptions

Options mocks base method.

func (*MockJetStream) OrderedConsumer 

func (m *MockJetStream) OrderedConsumer(arg0 context.Context, arg1 string, arg2 jetstream.OrderedConsumerConfig) (jetstream.Consumer, error)

OrderedConsumer mocks base method.

func (*MockJetStream) PauseConsumer 

func (m *MockJetStream) PauseConsumer(arg0 context.Context, arg1, arg2 string, arg3 time.Time) (*jetstream.ConsumerPauseResponse, error)

PauseConsumer mocks base method.

func (*MockJetStream) Publish 

func (m *MockJetStream) Publish(arg0 context.Context, arg1 string, arg2 []byte, arg3 ...jetstream.PublishOpt) (*jetstream.PubAck, error)

Publish mocks base method.

func (*MockJetStream) PublishAsync 

func (m *MockJetStream) PublishAsync(arg0 string, arg1 []byte, arg2 ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishAsync mocks base method.

func (*MockJetStream) PublishAsyncComplete 

func (m *MockJetStream) PublishAsyncComplete() <-chan struct{}

PublishAsyncComplete mocks base method.

func (*MockJetStream) PublishAsyncPending 

func (m *MockJetStream) PublishAsyncPending() int

PublishAsyncPending mocks base method.

func (*MockJetStream) PublishMsg 

func (m *MockJetStream) PublishMsg(arg0 context.Context, arg1 *nats.Msg, arg2 ...jetstream.PublishOpt) (*jetstream.PubAck, error)

PublishMsg mocks base method.

func (*MockJetStream) PublishMsgAsync 

func (m *MockJetStream) PublishMsgAsync(arg0 *nats.Msg, arg1 ...jetstream.PublishOpt) (jetstream.PubAckFuture, error)

PublishMsgAsync mocks base method.

func (*MockJetStream) ResumeConsumer 

func (m *MockJetStream) ResumeConsumer(arg0 context.Context, arg1, arg2 string) (*jetstream.ConsumerPauseResponse, error)

ResumeConsumer mocks base method.

func (*MockJetStream) Stream 

func (m *MockJetStream) Stream(arg0 context.Context, arg1 string) (jetstream.Stream, error)

Stream mocks base method.

func (*MockJetStream) StreamNameBySubject 

func (m *MockJetStream) StreamNameBySubject(arg0 context.Context, arg1 string) (string, error)

StreamNameBySubject mocks base method.

func (*MockJetStream) StreamNames 

func (m *MockJetStream) StreamNames(arg0 context.Context, arg1 ...jetstream.StreamListOpt) jetstream.StreamNameLister

StreamNames mocks base method.

func (*MockJetStream) UpdateConsumer 

func (m *MockJetStream) UpdateConsumer(arg0 context.Context, arg1 string, arg2 jetstream.ConsumerConfig) (jetstream.Consumer, error)

UpdateConsumer mocks base method.

func (*MockJetStream) UpdateKeyValue 

func (m *MockJetStream) UpdateKeyValue(arg0 context.Context, arg1 jetstream.KeyValueConfig) (jetstream.KeyValue, error)

UpdateKeyValue mocks base method.

func (*MockJetStream) UpdateObjectStore 

func (m *MockJetStream) UpdateObjectStore(arg0 context.Context, arg1 jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error)

UpdateObjectStore mocks base method.

func (*MockJetStream) UpdateStream 

func (m *MockJetStream) UpdateStream(arg0 context.Context, arg1 jetstream.StreamConfig) (jetstream.Stream, error)

UpdateStream mocks base method.

type MockJetStreamMockRecorder 

type MockJetStreamMockRecorder struct {
	// contains filtered or unexported fields
}

MockJetStreamMockRecorder is the mock recorder for MockJetStream.

func (*MockJetStreamMockRecorder) AccountInfo 

func (mr *MockJetStreamMockRecorder) AccountInfo(arg0 interface{}) *gomock.Call

AccountInfo indicates an expected call of AccountInfo.

func (*MockJetStreamMockRecorder) CleanupPublisher 

func (mr *MockJetStreamMockRecorder) CleanupPublisher() *gomock.Call

CleanupPublisher indicates an expected call of CleanupPublisher.

func (*MockJetStreamMockRecorder) Conn 

func (mr *MockJetStreamMockRecorder) Conn() *gomock.Call

Conn indicates an expected call of Conn.

func (*MockJetStreamMockRecorder) Consumer 

func (mr *MockJetStreamMockRecorder) Consumer(arg0, arg1, arg2 interface{}) *gomock.Call

Consumer indicates an expected call of Consumer.

func (*MockJetStreamMockRecorder) CreateConsumer 

func (mr *MockJetStreamMockRecorder) CreateConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

CreateConsumer indicates an expected call of CreateConsumer.

func (*MockJetStreamMockRecorder) CreateKeyValue 

func (mr *MockJetStreamMockRecorder) CreateKeyValue(arg0, arg1 interface{}) *gomock.Call

CreateKeyValue indicates an expected call of CreateKeyValue.

func (*MockJetStreamMockRecorder) CreateObjectStore 

func (mr *MockJetStreamMockRecorder) CreateObjectStore(arg0, arg1 interface{}) *gomock.Call

CreateObjectStore indicates an expected call of CreateObjectStore.

func (*MockJetStreamMockRecorder) CreateOrUpdateConsumer 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

CreateOrUpdateConsumer indicates an expected call of CreateOrUpdateConsumer.

func (*MockJetStreamMockRecorder) CreateOrUpdateKeyValue 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateKeyValue(arg0, arg1 interface{}) *gomock.Call

CreateOrUpdateKeyValue indicates an expected call of CreateOrUpdateKeyValue.

func (*MockJetStreamMockRecorder) CreateOrUpdateObjectStore 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateObjectStore(arg0, arg1 interface{}) *gomock.Call

CreateOrUpdateObjectStore indicates an expected call of CreateOrUpdateObjectStore.

func (*MockJetStreamMockRecorder) CreateOrUpdateStream 

func (mr *MockJetStreamMockRecorder) CreateOrUpdateStream(arg0, arg1 interface{}) *gomock.Call

CreateOrUpdateStream indicates an expected call of CreateOrUpdateStream.

func (*MockJetStreamMockRecorder) CreateStream 

func (mr *MockJetStreamMockRecorder) CreateStream(arg0, arg1 interface{}) *gomock.Call

CreateStream indicates an expected call of CreateStream.

func (*MockJetStreamMockRecorder) DeleteConsumer 

func (mr *MockJetStreamMockRecorder) DeleteConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

DeleteConsumer indicates an expected call of DeleteConsumer.

func (*MockJetStreamMockRecorder) DeleteKeyValue 

func (mr *MockJetStreamMockRecorder) DeleteKeyValue(arg0, arg1 interface{}) *gomock.Call

DeleteKeyValue indicates an expected call of DeleteKeyValue.

func (*MockJetStreamMockRecorder) DeleteObjectStore 

func (mr *MockJetStreamMockRecorder) DeleteObjectStore(arg0, arg1 interface{}) *gomock.Call

DeleteObjectStore indicates an expected call of DeleteObjectStore.

func (*MockJetStreamMockRecorder) DeleteStream 

func (mr *MockJetStreamMockRecorder) DeleteStream(arg0, arg1 interface{}) *gomock.Call

DeleteStream indicates an expected call of DeleteStream.

func (*MockJetStreamMockRecorder) KeyValue 

func (mr *MockJetStreamMockRecorder) KeyValue(arg0, arg1 interface{}) *gomock.Call

KeyValue indicates an expected call of KeyValue.

func (*MockJetStreamMockRecorder) KeyValueStoreNames 

func (mr *MockJetStreamMockRecorder) KeyValueStoreNames(arg0 interface{}) *gomock.Call

KeyValueStoreNames indicates an expected call of KeyValueStoreNames.

func (*MockJetStreamMockRecorder) KeyValueStores 

func (mr *MockJetStreamMockRecorder) KeyValueStores(arg0 interface{}) *gomock.Call

KeyValueStores indicates an expected call of KeyValueStores.

func (*MockJetStreamMockRecorder) ListStreams 

func (mr *MockJetStreamMockRecorder) ListStreams(arg0 interface{}, arg1 ...interface{}) *gomock.Call

ListStreams indicates an expected call of ListStreams.

func (*MockJetStreamMockRecorder) ObjectStore 

func (mr *MockJetStreamMockRecorder) ObjectStore(arg0, arg1 interface{}) *gomock.Call

ObjectStore indicates an expected call of ObjectStore.

func (*MockJetStreamMockRecorder) ObjectStoreNames 

func (mr *MockJetStreamMockRecorder) ObjectStoreNames(arg0 interface{}) *gomock.Call

ObjectStoreNames indicates an expected call of ObjectStoreNames.

func (*MockJetStreamMockRecorder) ObjectStores 

func (mr *MockJetStreamMockRecorder) ObjectStores(arg0 interface{}) *gomock.Call

ObjectStores indicates an expected call of ObjectStores.

func (*MockJetStreamMockRecorder) Options 

func (mr *MockJetStreamMockRecorder) Options() *gomock.Call

Options indicates an expected call of Options.

func (*MockJetStreamMockRecorder) OrderedConsumer 

func (mr *MockJetStreamMockRecorder) OrderedConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

OrderedConsumer indicates an expected call of OrderedConsumer.

func (*MockJetStreamMockRecorder) PauseConsumer 

func (mr *MockJetStreamMockRecorder) PauseConsumer(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

PauseConsumer indicates an expected call of PauseConsumer.

func (*MockJetStreamMockRecorder) Publish 

func (mr *MockJetStreamMockRecorder) Publish(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockJetStreamMockRecorder) PublishAsync 

func (mr *MockJetStreamMockRecorder) PublishAsync(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PublishAsync indicates an expected call of PublishAsync.

func (*MockJetStreamMockRecorder) PublishAsyncComplete 

func (mr *MockJetStreamMockRecorder) PublishAsyncComplete() *gomock.Call

PublishAsyncComplete indicates an expected call of PublishAsyncComplete.

func (*MockJetStreamMockRecorder) PublishAsyncPending 

func (mr *MockJetStreamMockRecorder) PublishAsyncPending() *gomock.Call

PublishAsyncPending indicates an expected call of PublishAsyncPending.

func (*MockJetStreamMockRecorder) PublishMsg 

func (mr *MockJetStreamMockRecorder) PublishMsg(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PublishMsg indicates an expected call of PublishMsg.

func (*MockJetStreamMockRecorder) PublishMsgAsync 

func (mr *MockJetStreamMockRecorder) PublishMsgAsync(arg0 interface{}, arg1 ...interface{}) *gomock.Call

PublishMsgAsync indicates an expected call of PublishMsgAsync.

func (*MockJetStreamMockRecorder) ResumeConsumer 

func (mr *MockJetStreamMockRecorder) ResumeConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

ResumeConsumer indicates an expected call of ResumeConsumer.

func (*MockJetStreamMockRecorder) Stream 

func (mr *MockJetStreamMockRecorder) Stream(arg0, arg1 interface{}) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockJetStreamMockRecorder) StreamNameBySubject 

func (mr *MockJetStreamMockRecorder) StreamNameBySubject(arg0, arg1 interface{}) *gomock.Call

StreamNameBySubject indicates an expected call of StreamNameBySubject.

func (*MockJetStreamMockRecorder) StreamNames 

func (mr *MockJetStreamMockRecorder) StreamNames(arg0 interface{}, arg1 ...interface{}) *gomock.Call

StreamNames indicates an expected call of StreamNames.

func (*MockJetStreamMockRecorder) UpdateConsumer 

func (mr *MockJetStreamMockRecorder) UpdateConsumer(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateConsumer indicates an expected call of UpdateConsumer.

func (*MockJetStreamMockRecorder) UpdateKeyValue 

func (mr *MockJetStreamMockRecorder) UpdateKeyValue(arg0, arg1 interface{}) *gomock.Call

UpdateKeyValue indicates an expected call of UpdateKeyValue.

func (*MockJetStreamMockRecorder) UpdateObjectStore 

func (mr *MockJetStreamMockRecorder) UpdateObjectStore(arg0, arg1 interface{}) *gomock.Call

UpdateObjectStore indicates an expected call of UpdateObjectStore.

func (*MockJetStreamMockRecorder) UpdateStream 

func (mr *MockJetStreamMockRecorder) UpdateStream(arg0, arg1 interface{}) *gomock.Call

UpdateStream indicates an expected call of UpdateStream.

type MockJobClient 

type MockJobClient struct {
	// contains filtered or unexported fields
}

MockJobClient is a mock of JobClient interface.

func NewMockJobClient 

func NewMockJobClient(ctrl *gomock.Controller) *MockJobClient

NewMockJobClient creates a new mock instance.

func (*MockJobClient) CheckDrainFlag 

func (m *MockJobClient) CheckDrainFlag(ctx context.Context, hostname string) bool

CheckDrainFlag mocks base method.

func (*MockJobClient) ConsumeJobs 

func (m *MockJobClient) ConsumeJobs(ctx context.Context, streamName, consumerName string, handler func(jetstream.Msg) error, opts *client.ConsumeOptions) error

ConsumeJobs mocks base method.

func (*MockJobClient) CreateOrUpdateConsumer 

func (m *MockJobClient) CreateOrUpdateConsumer(ctx context.Context, streamName string, consumerConfig jetstream.ConsumerConfig) error

CreateOrUpdateConsumer mocks base method.

func (*MockJobClient) DeleteDrainFlag 

func (m *MockJobClient) DeleteDrainFlag(ctx context.Context, hostname string) error

DeleteDrainFlag mocks base method.

func (*MockJobClient) DeleteJob 

func (m *MockJobClient) DeleteJob(ctx context.Context, jobID string) error

DeleteJob mocks base method.

func (*MockJobClient) EXPECT 

func (m *MockJobClient) EXPECT() *MockJobClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockJobClient) GetAgent 

func (m *MockJobClient) GetAgent(ctx context.Context, hostname string) (*job.AgentInfo, error)

GetAgent mocks base method.

func (*MockJobClient) GetAgentTimeline 

func (m *MockJobClient) GetAgentTimeline(ctx context.Context, hostname string) ([]job.TimelineEvent, error)

GetAgentTimeline mocks base method.

func (*MockJobClient) GetJobData 

func (m *MockJobClient) GetJobData(ctx context.Context, jobKey string) ([]byte, error)

GetJobData mocks base method.

func (*MockJobClient) GetJobStatus 

func (m *MockJobClient) GetJobStatus(ctx context.Context, jobID string) (*job.QueuedJob, error)

GetJobStatus mocks base method.

func (*MockJobClient) GetQueueSummary 

func (m *MockJobClient) GetQueueSummary(ctx context.Context) (*job.QueueStats, error)

GetQueueSummary mocks base method.

func (*MockJobClient) HasJobResponse 

func (m *MockJobClient) HasJobResponse(ctx context.Context, jobID, hostname string) (bool, error)

HasJobResponse mocks base method.

func (*MockJobClient) ListAgents 

func (m *MockJobClient) ListAgents(ctx context.Context) ([]job.AgentInfo, error)

ListAgents mocks base method.

func (*MockJobClient) ListJobs 

func (m *MockJobClient) ListJobs(ctx context.Context, statusFilter string, limit, offset int) (*client0.ListJobsResult, error)

ListJobs mocks base method.

func (*MockJobClient) Modify 

func (m *MockJobClient) Modify(ctx context.Context, target, category string, operation job.OperationType, data any) (string, *job.Response, error)

Modify mocks base method.

func (*MockJobClient) ModifyBroadcast 

func (m *MockJobClient) ModifyBroadcast(ctx context.Context, target, category string, operation job.OperationType, data any) (string, map[string]*job.Response, error)

ModifyBroadcast mocks base method.

func (*MockJobClient) Query 

func (m *MockJobClient) Query(ctx context.Context, target, category string, operation job.OperationType, data any) (string, *job.Response, error)

Query mocks base method.

func (*MockJobClient) QueryBroadcast 

func (m *MockJobClient) QueryBroadcast(ctx context.Context, target, category string, operation job.OperationType, data any) (string, map[string]*job.Response, error)

QueryBroadcast mocks base method.

func (*MockJobClient) RetryJob 

func (m *MockJobClient) RetryJob(ctx context.Context, jobID, targetHostname string) (*client0.CreateJobResult, error)

RetryJob mocks base method.

func (*MockJobClient) SetAgentKeyStore 

func (m *MockJobClient) SetAgentKeyStore(store client0.AgentKeyStore)

SetAgentKeyStore mocks base method.

func (*MockJobClient) SetDrainFlag 

func (m *MockJobClient) SetDrainFlag(ctx context.Context, hostname string) error

SetDrainFlag mocks base method.

func (*MockJobClient) SetMachineID 

func (m *MockJobClient) SetMachineID(machineID string)

SetMachineID mocks base method.

func (*MockJobClient) SetPKISigner 

func (m *MockJobClient) SetPKISigner(signer client0.PKISigner)

SetPKISigner mocks base method.

func (*MockJobClient) WriteAgentTimelineEvent 

func (m *MockJobClient) WriteAgentTimelineEvent(ctx context.Context, hostname, event, message string) error

WriteAgentTimelineEvent mocks base method.

func (*MockJobClient) WriteJobResponse 

func (m *MockJobClient) WriteJobResponse(ctx context.Context, jobID, hostname string, responseData []byte, status, errorMsg string, changed *bool) error

WriteJobResponse mocks base method.

func (*MockJobClient) WriteStatusEvent 

func (m *MockJobClient) WriteStatusEvent(ctx context.Context, jobID, event, hostname string, data map[string]any) error

WriteStatusEvent mocks base method.

type MockJobClientMockRecorder 

type MockJobClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockJobClientMockRecorder is the mock recorder for MockJobClient.

func (*MockJobClientMockRecorder) CheckDrainFlag 

func (mr *MockJobClientMockRecorder) CheckDrainFlag(ctx, hostname any) *gomock.Call

CheckDrainFlag indicates an expected call of CheckDrainFlag.

func (*MockJobClientMockRecorder) ConsumeJobs 

func (mr *MockJobClientMockRecorder) ConsumeJobs(ctx, streamName, consumerName, handler, opts any) *gomock.Call

ConsumeJobs indicates an expected call of ConsumeJobs.

func (*MockJobClientMockRecorder) CreateOrUpdateConsumer 

func (mr *MockJobClientMockRecorder) CreateOrUpdateConsumer(ctx, streamName, consumerConfig any) *gomock.Call

CreateOrUpdateConsumer indicates an expected call of CreateOrUpdateConsumer.

func (*MockJobClientMockRecorder) DeleteDrainFlag 

func (mr *MockJobClientMockRecorder) DeleteDrainFlag(ctx, hostname any) *gomock.Call

DeleteDrainFlag indicates an expected call of DeleteDrainFlag.

func (*MockJobClientMockRecorder) DeleteJob 

func (mr *MockJobClientMockRecorder) DeleteJob(ctx, jobID any) *gomock.Call

DeleteJob indicates an expected call of DeleteJob.

func (*MockJobClientMockRecorder) GetAgent 

func (mr *MockJobClientMockRecorder) GetAgent(ctx, hostname any) *gomock.Call

GetAgent indicates an expected call of GetAgent.

func (*MockJobClientMockRecorder) GetAgentTimeline 

func (mr *MockJobClientMockRecorder) GetAgentTimeline(ctx, hostname any) *gomock.Call

GetAgentTimeline indicates an expected call of GetAgentTimeline.

func (*MockJobClientMockRecorder) GetJobData 

func (mr *MockJobClientMockRecorder) GetJobData(ctx, jobKey any) *gomock.Call

GetJobData indicates an expected call of GetJobData.

func (*MockJobClientMockRecorder) GetJobStatus 

func (mr *MockJobClientMockRecorder) GetJobStatus(ctx, jobID any) *gomock.Call

GetJobStatus indicates an expected call of GetJobStatus.

func (*MockJobClientMockRecorder) GetQueueSummary 

func (mr *MockJobClientMockRecorder) GetQueueSummary(ctx any) *gomock.Call

GetQueueSummary indicates an expected call of GetQueueSummary.

func (*MockJobClientMockRecorder) HasJobResponse 

func (mr *MockJobClientMockRecorder) HasJobResponse(ctx, jobID, hostname any) *gomock.Call

HasJobResponse indicates an expected call of HasJobResponse.

func (*MockJobClientMockRecorder) ListAgents 

func (mr *MockJobClientMockRecorder) ListAgents(ctx any) *gomock.Call

ListAgents indicates an expected call of ListAgents.

func (*MockJobClientMockRecorder) ListJobs 

func (mr *MockJobClientMockRecorder) ListJobs(ctx, statusFilter, limit, offset any) *gomock.Call

ListJobs indicates an expected call of ListJobs.

func (*MockJobClientMockRecorder) Modify 

func (mr *MockJobClientMockRecorder) Modify(ctx, target, category, operation, data any) *gomock.Call

Modify indicates an expected call of Modify.

func (*MockJobClientMockRecorder) ModifyBroadcast 

func (mr *MockJobClientMockRecorder) ModifyBroadcast(ctx, target, category, operation, data any) *gomock.Call

ModifyBroadcast indicates an expected call of ModifyBroadcast.

func (*MockJobClientMockRecorder) Query 

func (mr *MockJobClientMockRecorder) Query(ctx, target, category, operation, data any) *gomock.Call

Query indicates an expected call of Query.

func (*MockJobClientMockRecorder) QueryBroadcast 

func (mr *MockJobClientMockRecorder) QueryBroadcast(ctx, target, category, operation, data any) *gomock.Call

QueryBroadcast indicates an expected call of QueryBroadcast.

func (*MockJobClientMockRecorder) RetryJob 

func (mr *MockJobClientMockRecorder) RetryJob(ctx, jobID, targetHostname any) *gomock.Call

RetryJob indicates an expected call of RetryJob.

func (*MockJobClientMockRecorder) SetAgentKeyStore 

func (mr *MockJobClientMockRecorder) SetAgentKeyStore(store any) *gomock.Call

SetAgentKeyStore indicates an expected call of SetAgentKeyStore.

func (*MockJobClientMockRecorder) SetDrainFlag 

func (mr *MockJobClientMockRecorder) SetDrainFlag(ctx, hostname any) *gomock.Call

SetDrainFlag indicates an expected call of SetDrainFlag.

func (*MockJobClientMockRecorder) SetMachineID 

func (mr *MockJobClientMockRecorder) SetMachineID(machineID any) *gomock.Call

SetMachineID indicates an expected call of SetMachineID.

func (*MockJobClientMockRecorder) SetPKISigner 

func (mr *MockJobClientMockRecorder) SetPKISigner(signer any) *gomock.Call

SetPKISigner indicates an expected call of SetPKISigner.

func (*MockJobClientMockRecorder) WriteAgentTimelineEvent 

func (mr *MockJobClientMockRecorder) WriteAgentTimelineEvent(ctx, hostname, event, message any) *gomock.Call

WriteAgentTimelineEvent indicates an expected call of WriteAgentTimelineEvent.

func (*MockJobClientMockRecorder) WriteJobResponse 

func (mr *MockJobClientMockRecorder) WriteJobResponse(ctx, jobID, hostname, responseData, status, errorMsg, changed any) *gomock.Call

WriteJobResponse indicates an expected call of WriteJobResponse.

func (*MockJobClientMockRecorder) WriteStatusEvent 

func (mr *MockJobClientMockRecorder) WriteStatusEvent(ctx, jobID, event, hostname, data any) *gomock.Call

WriteStatusEvent indicates an expected call of WriteStatusEvent.

type MockKeyLister 

type MockKeyLister struct {
	// contains filtered or unexported fields
}

MockKeyLister is a mock of KeyLister interface.

func NewMockKeyLister 

func NewMockKeyLister(ctrl *gomock.Controller) *MockKeyLister

NewMockKeyLister creates a new mock instance.

func (*MockKeyLister) EXPECT 

func (m *MockKeyLister) EXPECT() *MockKeyListerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockKeyLister) Keys 

func (m *MockKeyLister) Keys() <-chan string

Keys mocks base method.

func (*MockKeyLister) Stop 

func (m *MockKeyLister) Stop() error

Stop mocks base method.

type MockKeyListerMockRecorder 

type MockKeyListerMockRecorder struct {
	// contains filtered or unexported fields
}

MockKeyListerMockRecorder is the mock recorder for MockKeyLister.

func (*MockKeyListerMockRecorder) Keys 

func (mr *MockKeyListerMockRecorder) Keys() *gomock.Call

Keys indicates an expected call of Keys.

func (*MockKeyListerMockRecorder) Stop 

func (mr *MockKeyListerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

type MockKeyValue 

type MockKeyValue struct {
	// contains filtered or unexported fields
}

MockKeyValue is a mock of KeyValue interface.

func NewMockKeyValue 

func NewMockKeyValue(ctrl *gomock.Controller) *MockKeyValue

NewMockKeyValue creates a new mock instance.

func (*MockKeyValue) Bucket 

func (m *MockKeyValue) Bucket() string

Bucket mocks base method.

func (*MockKeyValue) Create 

func (m *MockKeyValue) Create(ctx context.Context, key string, value []byte, opts ...jetstream.KVCreateOpt) (uint64, error)

Create mocks base method.

func (*MockKeyValue) Delete 

func (m *MockKeyValue) Delete(ctx context.Context, key string, opts ...jetstream.KVDeleteOpt) error

Delete mocks base method.

func (*MockKeyValue) EXPECT 

func (m *MockKeyValue) EXPECT() *MockKeyValueMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockKeyValue) Get 

func (m *MockKeyValue) Get(ctx context.Context, key string) (jetstream.KeyValueEntry, error)

Get mocks base method.

func (*MockKeyValue) GetRevision 

func (m *MockKeyValue) GetRevision(ctx context.Context, key string, revision uint64) (jetstream.KeyValueEntry, error)

GetRevision mocks base method.

func (*MockKeyValue) History 

func (m *MockKeyValue) History(ctx context.Context, key string, opts ...jetstream.WatchOpt) ([]jetstream.KeyValueEntry, error)

History mocks base method.

func (*MockKeyValue) Keys 

func (m *MockKeyValue) Keys(ctx context.Context, opts ...jetstream.WatchOpt) ([]string, error)

Keys mocks base method.

func (*MockKeyValue) ListKeys 

func (m *MockKeyValue) ListKeys(ctx context.Context, opts ...jetstream.WatchOpt) (jetstream.KeyLister, error)

ListKeys mocks base method.

func (*MockKeyValue) ListKeysFiltered 

func (m *MockKeyValue) ListKeysFiltered(ctx context.Context, filters ...string) (jetstream.KeyLister, error)

ListKeysFiltered mocks base method.

func (*MockKeyValue) Purge 

func (m *MockKeyValue) Purge(ctx context.Context, key string, opts ...jetstream.KVDeleteOpt) error

Purge mocks base method.

func (*MockKeyValue) PurgeDeletes 

func (m *MockKeyValue) PurgeDeletes(ctx context.Context, opts ...jetstream.KVPurgeOpt) error

PurgeDeletes mocks base method.

func (*MockKeyValue) Put 

func (m *MockKeyValue) Put(ctx context.Context, key string, value []byte) (uint64, error)

Put mocks base method.

func (*MockKeyValue) PutString 

func (m *MockKeyValue) PutString(ctx context.Context, key, value string) (uint64, error)

PutString mocks base method.

func (*MockKeyValue) Status 

func (m *MockKeyValue) Status(ctx context.Context) (jetstream.KeyValueStatus, error)

Status mocks base method.

func (*MockKeyValue) Update 

func (m *MockKeyValue) Update(ctx context.Context, key string, value []byte, revision uint64) (uint64, error)

Update mocks base method.

func (*MockKeyValue) Watch 

func (m *MockKeyValue) Watch(ctx context.Context, keys string, opts ...jetstream.WatchOpt) (jetstream.KeyWatcher, error)

Watch mocks base method.

func (*MockKeyValue) WatchAll 

func (m *MockKeyValue) WatchAll(ctx context.Context, opts ...jetstream.WatchOpt) (jetstream.KeyWatcher, error)

WatchAll mocks base method.

func (*MockKeyValue) WatchFiltered 

func (m *MockKeyValue) WatchFiltered(ctx context.Context, keys []string, opts ...jetstream.WatchOpt) (jetstream.KeyWatcher, error)

WatchFiltered mocks base method.

type MockKeyValueEntry 

type MockKeyValueEntry struct {
	// contains filtered or unexported fields
}

MockKeyValueEntry is a mock of KeyValueEntry interface.

func NewMockKeyValueEntry 

func NewMockKeyValueEntry(ctrl *gomock.Controller) *MockKeyValueEntry

NewMockKeyValueEntry creates a new mock instance.

func (*MockKeyValueEntry) Bucket 

func (m *MockKeyValueEntry) Bucket() string

Bucket mocks base method.

func (*MockKeyValueEntry) Created 

func (m *MockKeyValueEntry) Created() time.Time

Created mocks base method.

func (*MockKeyValueEntry) Delta 

func (m *MockKeyValueEntry) Delta() uint64

Delta mocks base method.

func (*MockKeyValueEntry) EXPECT 

func (m *MockKeyValueEntry) EXPECT() *MockKeyValueEntryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockKeyValueEntry) Key 

func (m *MockKeyValueEntry) Key() string

Key mocks base method.

func (*MockKeyValueEntry) Operation 

func (m *MockKeyValueEntry) Operation() jetstream.KeyValueOp

Operation mocks base method.

func (*MockKeyValueEntry) Revision 

func (m *MockKeyValueEntry) Revision() uint64

Revision mocks base method.

func (*MockKeyValueEntry) Value 

func (m *MockKeyValueEntry) Value() []byte

Value mocks base method.

type MockKeyValueEntryMockRecorder 

type MockKeyValueEntryMockRecorder struct {
	// contains filtered or unexported fields
}

MockKeyValueEntryMockRecorder is the mock recorder for MockKeyValueEntry.

func (*MockKeyValueEntryMockRecorder) Bucket 

func (mr *MockKeyValueEntryMockRecorder) Bucket() *gomock.Call

Bucket indicates an expected call of Bucket.

func (*MockKeyValueEntryMockRecorder) Created 

func (mr *MockKeyValueEntryMockRecorder) Created() *gomock.Call

Created indicates an expected call of Created.

func (*MockKeyValueEntryMockRecorder) Delta 

func (mr *MockKeyValueEntryMockRecorder) Delta() *gomock.Call

Delta indicates an expected call of Delta.

func (*MockKeyValueEntryMockRecorder) Key 

func (mr *MockKeyValueEntryMockRecorder) Key() *gomock.Call

Key indicates an expected call of Key.

func (*MockKeyValueEntryMockRecorder) Operation 

func (mr *MockKeyValueEntryMockRecorder) Operation() *gomock.Call

Operation indicates an expected call of Operation.

func (*MockKeyValueEntryMockRecorder) Revision 

func (mr *MockKeyValueEntryMockRecorder) Revision() *gomock.Call

Revision indicates an expected call of Revision.

func (*MockKeyValueEntryMockRecorder) Value 

func (mr *MockKeyValueEntryMockRecorder) Value() *gomock.Call

Value indicates an expected call of Value.

type MockKeyValueMockRecorder 

type MockKeyValueMockRecorder struct {
	// contains filtered or unexported fields
}

MockKeyValueMockRecorder is the mock recorder for MockKeyValue.

func (*MockKeyValueMockRecorder) Bucket 

func (mr *MockKeyValueMockRecorder) Bucket() *gomock.Call

Bucket indicates an expected call of Bucket.

func (*MockKeyValueMockRecorder) Create 

func (mr *MockKeyValueMockRecorder) Create(ctx, key, value any, opts ...any) *gomock.Call

Create indicates an expected call of Create.

func (*MockKeyValueMockRecorder) Delete 

func (mr *MockKeyValueMockRecorder) Delete(ctx, key any, opts ...any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockKeyValueMockRecorder) Get 

func (mr *MockKeyValueMockRecorder) Get(ctx, key any) *gomock.Call

Get indicates an expected call of Get.

func (*MockKeyValueMockRecorder) GetRevision 

func (mr *MockKeyValueMockRecorder) GetRevision(ctx, key, revision any) *gomock.Call

GetRevision indicates an expected call of GetRevision.

func (*MockKeyValueMockRecorder) History 

func (mr *MockKeyValueMockRecorder) History(ctx, key any, opts ...any) *gomock.Call

History indicates an expected call of History.

func (*MockKeyValueMockRecorder) Keys 

func (mr *MockKeyValueMockRecorder) Keys(ctx any, opts ...any) *gomock.Call

Keys indicates an expected call of Keys.

func (*MockKeyValueMockRecorder) ListKeys 

func (mr *MockKeyValueMockRecorder) ListKeys(ctx any, opts ...any) *gomock.Call

ListKeys indicates an expected call of ListKeys.

func (*MockKeyValueMockRecorder) ListKeysFiltered 

func (mr *MockKeyValueMockRecorder) ListKeysFiltered(ctx any, filters ...any) *gomock.Call

ListKeysFiltered indicates an expected call of ListKeysFiltered.

func (*MockKeyValueMockRecorder) Purge 

func (mr *MockKeyValueMockRecorder) Purge(ctx, key any, opts ...any) *gomock.Call

Purge indicates an expected call of Purge.

func (*MockKeyValueMockRecorder) PurgeDeletes 

func (mr *MockKeyValueMockRecorder) PurgeDeletes(ctx any, opts ...any) *gomock.Call

PurgeDeletes indicates an expected call of PurgeDeletes.

func (*MockKeyValueMockRecorder) Put 

func (mr *MockKeyValueMockRecorder) Put(ctx, key, value any) *gomock.Call

Put indicates an expected call of Put.

func (*MockKeyValueMockRecorder) PutString 

func (mr *MockKeyValueMockRecorder) PutString(ctx, key, value any) *gomock.Call

PutString indicates an expected call of PutString.

func (*MockKeyValueMockRecorder) Status 

func (mr *MockKeyValueMockRecorder) Status(ctx any) *gomock.Call

Status indicates an expected call of Status.

func (*MockKeyValueMockRecorder) Update 

func (mr *MockKeyValueMockRecorder) Update(ctx, key, value, revision any) *gomock.Call

Update indicates an expected call of Update.

func (*MockKeyValueMockRecorder) Watch 

func (mr *MockKeyValueMockRecorder) Watch(ctx, keys any, opts ...any) *gomock.Call

Watch indicates an expected call of Watch.

func (*MockKeyValueMockRecorder) WatchAll 

func (mr *MockKeyValueMockRecorder) WatchAll(ctx any, opts ...any) *gomock.Call

WatchAll indicates an expected call of WatchAll.

func (*MockKeyValueMockRecorder) WatchFiltered 

func (mr *MockKeyValueMockRecorder) WatchFiltered(ctx, keys any, opts ...any) *gomock.Call

WatchFiltered indicates an expected call of WatchFiltered.

type MockKeyWatcher 

type MockKeyWatcher struct {
	// contains filtered or unexported fields
}

MockKeyWatcher is a mock of KeyWatcher interface.

func NewMockKeyWatcher 

func NewMockKeyWatcher(ctrl *gomock.Controller) *MockKeyWatcher

NewMockKeyWatcher creates a new mock instance.

func (*MockKeyWatcher) EXPECT 

func (m *MockKeyWatcher) EXPECT() *MockKeyWatcherMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockKeyWatcher) Stop 

func (m *MockKeyWatcher) Stop() error

Stop mocks base method.

func (*MockKeyWatcher) Updates 

func (m *MockKeyWatcher) Updates() <-chan jetstream.KeyValueEntry

Updates mocks base method.

type MockKeyWatcherMockRecorder 

type MockKeyWatcherMockRecorder struct {
	// contains filtered or unexported fields
}

MockKeyWatcherMockRecorder is the mock recorder for MockKeyWatcher.

func (*MockKeyWatcherMockRecorder) Stop 

func (mr *MockKeyWatcherMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockKeyWatcherMockRecorder) Updates 

func (mr *MockKeyWatcherMockRecorder) Updates() *gomock.Call

Updates indicates an expected call of Updates.

type MockNATSClient 

type MockNATSClient struct {
	// contains filtered or unexported fields
}

MockNATSClient is a mock of NATSClient interface.

func NewMockNATSClient 

func NewMockNATSClient(ctrl *gomock.Controller) *MockNATSClient

NewMockNATSClient creates a new mock instance.

func (*MockNATSClient) ConsumeMessages 

func (m *MockNATSClient) ConsumeMessages(ctx context.Context, streamName, consumerName string, handler client.JetStreamMessageHandler, opts *client.ConsumeOptions) error

ConsumeMessages mocks base method.

func (*MockNATSClient) CreateOrUpdateConsumerWithConfig 

func (m *MockNATSClient) CreateOrUpdateConsumerWithConfig(ctx context.Context, streamName string, consumerConfig jetstream.ConsumerConfig) error

CreateOrUpdateConsumerWithConfig mocks base method.

func (*MockNATSClient) EXPECT 

func (m *MockNATSClient) EXPECT() *MockNATSClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNATSClient) GetStreamInfo 

func (m *MockNATSClient) GetStreamInfo(ctx context.Context, streamName string) (*jetstream.StreamInfo, error)

GetStreamInfo mocks base method.

func (*MockNATSClient) KVPut 

func (m *MockNATSClient) KVPut(bucket, key string, value []byte) error

KVPut mocks base method.

func (*MockNATSClient) Publish 

func (m *MockNATSClient) Publish(ctx context.Context, subject string, data []byte) error

Publish mocks base method.

type MockNATSClientMockRecorder 

type MockNATSClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockNATSClientMockRecorder is the mock recorder for MockNATSClient.

func (*MockNATSClientMockRecorder) ConsumeMessages 

func (mr *MockNATSClientMockRecorder) ConsumeMessages(ctx, streamName, consumerName, handler, opts any) *gomock.Call

ConsumeMessages indicates an expected call of ConsumeMessages.

func (*MockNATSClientMockRecorder) CreateOrUpdateConsumerWithConfig 

func (mr *MockNATSClientMockRecorder) CreateOrUpdateConsumerWithConfig(ctx, streamName, consumerConfig any) *gomock.Call

CreateOrUpdateConsumerWithConfig indicates an expected call of CreateOrUpdateConsumerWithConfig.

func (*MockNATSClientMockRecorder) GetStreamInfo 

func (mr *MockNATSClientMockRecorder) GetStreamInfo(ctx, streamName any) *gomock.Call

GetStreamInfo indicates an expected call of GetStreamInfo.

func (*MockNATSClientMockRecorder) KVPut 

func (mr *MockNATSClientMockRecorder) KVPut(bucket, key, value any) *gomock.Call

KVPut indicates an expected call of KVPut.

func (*MockNATSClientMockRecorder) Publish 

func (mr *MockNATSClientMockRecorder) Publish(ctx, subject, data any) *gomock.Call

Publish indicates an expected call of Publish.

type MockNATSConnector 

type MockNATSConnector struct {
	// contains filtered or unexported fields
}

MockNATSConnector is a mock of NATSConnector interface.

func NewMockNATSConnector 

func NewMockNATSConnector(ctrl *gomock.Controller) *MockNATSConnector

NewMockNATSConnector creates a new mock instance.

func (*MockNATSConnector) Close 

func (m *MockNATSConnector) Close()

Close mocks base method.

func (*MockNATSConnector) Connect 

func (m *MockNATSConnector) Connect(arg0 string, arg1 ...nats.Option) (*nats.Conn, error)

Connect mocks base method.

func (*MockNATSConnector) ConnectedUrl 

func (m *MockNATSConnector) ConnectedUrl() string

ConnectedUrl mocks base method.

func (*MockNATSConnector) EXPECT 

func (m *MockNATSConnector) EXPECT() *MockNATSConnectorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNATSConnector) JetStream 

func (m *MockNATSConnector) JetStream(arg0 ...nats.JSOpt) (nats.JetStreamContext, error)

JetStream mocks base method.

func (*MockNATSConnector) QueueSubscribe 

func (m *MockNATSConnector) QueueSubscribe(arg0, arg1 string, arg2 nats.MsgHandler) (*nats.Subscription, error)

QueueSubscribe mocks base method.

func (*MockNATSConnector) Subscribe 

func (m *MockNATSConnector) Subscribe(arg0 string, arg1 nats.MsgHandler) (*nats.Subscription, error)

Subscribe mocks base method.

type MockNATSConnectorMockRecorder 

type MockNATSConnectorMockRecorder struct {
	// contains filtered or unexported fields
}

MockNATSConnectorMockRecorder is the mock recorder for MockNATSConnector.

func (*MockNATSConnectorMockRecorder) Close 

func (mr *MockNATSConnectorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockNATSConnectorMockRecorder) Connect 

func (mr *MockNATSConnectorMockRecorder) Connect(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Connect indicates an expected call of Connect.

func (*MockNATSConnectorMockRecorder) ConnectedUrl 

func (mr *MockNATSConnectorMockRecorder) ConnectedUrl() *gomock.Call

ConnectedUrl indicates an expected call of ConnectedUrl.

func (*MockNATSConnectorMockRecorder) JetStream 

func (mr *MockNATSConnectorMockRecorder) JetStream(arg0 ...interface{}) *gomock.Call

JetStream indicates an expected call of JetStream.

func (*MockNATSConnectorMockRecorder) QueueSubscribe 

func (mr *MockNATSConnectorMockRecorder) QueueSubscribe(arg0, arg1, arg2 interface{}) *gomock.Call

QueueSubscribe indicates an expected call of QueueSubscribe.

func (*MockNATSConnectorMockRecorder) Subscribe 

func (mr *MockNATSConnectorMockRecorder) Subscribe(arg0, arg1 interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

type MockPKISigner 

type MockPKISigner struct {
	// contains filtered or unexported fields
}

MockPKISigner is a mock of PKISigner interface.

func NewMockPKISigner 

func NewMockPKISigner(ctrl *gomock.Controller) *MockPKISigner

NewMockPKISigner creates a new mock instance.

func (*MockPKISigner) ControllerPublicKey 

func (m *MockPKISigner) ControllerPublicKey() ed25519.PublicKey

ControllerPublicKey mocks base method.

func (*MockPKISigner) EXPECT 

func (m *MockPKISigner) EXPECT() *MockPKISignerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPKISigner) Fingerprint 

func (m *MockPKISigner) Fingerprint() string

Fingerprint mocks base method.

func (*MockPKISigner) Sign 

func (m *MockPKISigner) Sign(data []byte) []byte

Sign mocks base method.

type MockPKISignerMockRecorder 

type MockPKISignerMockRecorder struct {
	// contains filtered or unexported fields
}

MockPKISignerMockRecorder is the mock recorder for MockPKISigner.

func (*MockPKISignerMockRecorder) ControllerPublicKey 

func (mr *MockPKISignerMockRecorder) ControllerPublicKey() *gomock.Call

ControllerPublicKey indicates an expected call of ControllerPublicKey.

func (*MockPKISignerMockRecorder) Fingerprint 

func (mr *MockPKISignerMockRecorder) Fingerprint() *gomock.Call

Fingerprint indicates an expected call of Fingerprint.

func (*MockPKISignerMockRecorder) Sign 

func (mr *MockPKISignerMockRecorder) Sign(data any) *gomock.Call

Sign indicates an expected call of Sign.

Source Files

View all Source files

Directories

Path Synopsis
Package hostname provides mock implementations for HostnameProvider testing.
 Package hostname provides mock implementations for HostnameProvider testing.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.