worker_client

package

v1.0.0-helm Latest Latest Go to latest Published: Nov 25, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Package worker_client is a generated GoMock package.

This section is empty.

This section is empty.

func QueuePublisher(ctx context.Context, queuesProvider queues.Provider) (queues.QueueProducer, error)

type EventWithOrgId struct {
	OrgId uuid.UUID `json:"orgId"`
	Event api.Event `json:"event"`
}

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

MockWorkerClient is a mock of WorkerClient interface.

func NewMockWorkerClient(ctrl *gomock.Controller) *MockWorkerClient

NewMockWorkerClient creates a new mock instance.

func (m *MockWorkerClient) EXPECT() *MockWorkerClientMockRecorder

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

func (m *MockWorkerClient) EmitEvent(ctx context.Context, orgId uuid.UUID, event *v1beta1.Event)

EmitEvent mocks base method.

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

MockWorkerClientMockRecorder is the mock recorder for MockWorkerClient.

func (mr *MockWorkerClientMockRecorder) EmitEvent(ctx, orgId, event any) *gomock.Call

EmitEvent indicates an expected call of EmitEvent.

type WorkerClient interface {
	EmitEvent(ctx context.Context, orgId uuid.UUID, event *api.Event)
}

func NewWorkerClient(publisher queues.QueueProducer, log logrus.FieldLogger) WorkerClient