clientmanager

package
v0.4.29 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	AuthCertificates      []tls.Certificate
	DefaultTemporalConfig *DefaultTemporalConfig
}

type DB 

type DB interface {
	GetTemporalConfigByAccount(ctx context.Context, db db_queries.DBTX, accountId pgtype.UUID) (*pg_models.TemporalConfig, error)
}

type DefaultTemporalConfig 

type DefaultTemporalConfig struct {
	Url              string
	Namespace        string
	SyncJobQueueName string
}

type MockDB 

type MockDB struct {
	mock.Mock
}

MockDB is an autogenerated mock type for the DB type

func NewMockDB 

func NewMockDB(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDB

NewMockDB creates a new instance of MockDB. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockDB) EXPECT 

func (_m *MockDB) EXPECT() *MockDB_Expecter

func (*MockDB) GetTemporalConfigByAccount 

func (_m *MockDB) GetTemporalConfigByAccount(ctx context.Context, db db_queries.DBTX, accountId pgtype.UUID) (*pg_models.TemporalConfig, error)

GetTemporalConfigByAccount provides a mock function with given fields: ctx, db, accountId

type MockDB_Expecter 

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

func (*MockDB_Expecter) GetTemporalConfigByAccount 

func (_e *MockDB_Expecter) GetTemporalConfigByAccount(ctx interface{}, db interface{}, accountId interface{}) *MockDB_GetTemporalConfigByAccount_Call

GetTemporalConfigByAccount is a helper method to define mock.On call

  • ctx context.Context
  • db db_queries.DBTX
  • accountId pgtype.UUID

type MockDB_GetTemporalConfigByAccount_Call 

type MockDB_GetTemporalConfigByAccount_Call struct {
	*mock.Call
}

MockDB_GetTemporalConfigByAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTemporalConfigByAccount'

func (*MockDB_GetTemporalConfigByAccount_Call) Return 

func (_c *MockDB_GetTemporalConfigByAccount_Call) Return(_a0 *pg_models.TemporalConfig, _a1 error) *MockDB_GetTemporalConfigByAccount_Call

func (*MockDB_GetTemporalConfigByAccount_Call) Run 

func (_c *MockDB_GetTemporalConfigByAccount_Call) Run(run func(ctx context.Context, db db_queries.DBTX, accountId pgtype.UUID)) *MockDB_GetTemporalConfigByAccount_Call

func (*MockDB_GetTemporalConfigByAccount_Call) RunAndReturn 

func (_c *MockDB_GetTemporalConfigByAccount_Call) RunAndReturn(run func(context.Context, db_queries.DBTX, pgtype.UUID) (*pg_models.TemporalConfig, error)) *MockDB_GetTemporalConfigByAccount_Call

type MockNamespaceClient 

type MockNamespaceClient struct {
	mock.Mock
}

MockNamespaceClient is a mock of Namespace Client interface.

func (*MockNamespaceClient) Close 

func (_m *MockNamespaceClient) Close()

func (*MockNamespaceClient) Describe 

func (_m *MockNamespaceClient) Describe(ctx context.Context, name string) (*workflowservice.DescribeNamespaceResponse, error)

func (*MockNamespaceClient) Register 

func (_m *MockNamespaceClient) Register(ctx context.Context, request *workflowservice.RegisterNamespaceRequest) error

func (*MockNamespaceClient) Update 

func (_m *MockNamespaceClient) Update(ctx context.Context, request *workflowservice.UpdateNamespaceRequest) error

type MockScheduleClient 

type MockScheduleClient struct {
	mock.Mock
	Handle temporalclient.ScheduleHandle
}

MockScheduleClient is a mock of Schedule Client interface.

func (*MockScheduleClient) Create 

func (_m *MockScheduleClient) Create(ctx context.Context, options temporalclient.ScheduleOptions) (temporalclient.ScheduleHandle, error)

func (*MockScheduleClient) GetHandle 

func (_m *MockScheduleClient) GetHandle(ctx context.Context, scheduleID string) temporalclient.ScheduleHandle

func (*MockScheduleClient) List 

func (_m *MockScheduleClient) List(ctx context.Context, options temporalclient.ScheduleListOptions) (temporalclient.ScheduleListIterator, error)

type MockScheduleHandle 

type MockScheduleHandle struct {
	mock.Mock
}

MockScheduleHandle is a mock of ScheduleHandle interface.

func (*MockScheduleHandle) Backfill 

func (m *MockScheduleHandle) Backfill(ctx context.Context, options temporalclient.ScheduleBackfillOptions) error

func (*MockScheduleHandle) Delete 

func (m *MockScheduleHandle) Delete(ctx context.Context) error

func (*MockScheduleHandle) Describe 

func (m *MockScheduleHandle) Describe(ctx context.Context) (*temporalclient.ScheduleDescription, error)

func (*MockScheduleHandle) GetID 

func (m *MockScheduleHandle) GetID() string

func (*MockScheduleHandle) Pause 

func (m *MockScheduleHandle) Pause(ctx context.Context, options temporalclient.SchedulePauseOptions) error

func (*MockScheduleHandle) Trigger 

func (m *MockScheduleHandle) Trigger(ctx context.Context, options temporalclient.ScheduleTriggerOptions) error

func (*MockScheduleHandle) Unpause 

func (m *MockScheduleHandle) Unpause(ctx context.Context, options temporalclient.ScheduleUnpauseOptions) error

func (*MockScheduleHandle) Update 

func (m *MockScheduleHandle) Update(ctx context.Context, options temporalclient.ScheduleUpdateOptions) error

type MockTemporalClient 

type MockTemporalClient struct {
	mock.Mock
}

MockTemporalClient is a mock of temporal client interface.

func (*MockTemporalClient) CancelWorkflow 

func (m *MockTemporalClient) CancelWorkflow(ctx context.Context, workflowID string, runID string) error

func (*MockTemporalClient) CheckHealth 

func (m *MockTemporalClient) CheckHealth(ctx context.Context, request *temporalclient.CheckHealthRequest) (*temporalclient.CheckHealthResponse, error)

func (*MockTemporalClient) Close 

func (m *MockTemporalClient) Close()

func (*MockTemporalClient) CompleteActivity 

func (m *MockTemporalClient) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error

func (*MockTemporalClient) CompleteActivityByID 

func (m *MockTemporalClient) CompleteActivityByID(ctx context.Context, namespace, workflowID, runID, activityID string, result interface{}, err error) error

func (*MockTemporalClient) CountWorkflow 

func (m *MockTemporalClient) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)

func (*MockTemporalClient) DescribeTaskQueue 

func (m *MockTemporalClient) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)

func (*MockTemporalClient) DescribeWorkflowExecution 

func (m *MockTemporalClient) DescribeWorkflowExecution(ctx context.Context, workflowID, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error)

func (*MockTemporalClient) ExecuteWorkflow 

func (m *MockTemporalClient) ExecuteWorkflow(ctx context.Context, options temporalclient.StartWorkflowOptions, workflow interface{}, args ...interface{}) (temporalclient.WorkflowRun, error)

func (*MockTemporalClient) GetSearchAttributes 

func (m *MockTemporalClient) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)

func (*MockTemporalClient) GetWorkerBuildIdCompatibility 

func (m *MockTemporalClient) GetWorkerBuildIdCompatibility(ctx context.Context, options *temporalclient.GetWorkerBuildIdCompatibilityOptions) (*temporalclient.WorkerBuildIDVersionSets, error)

func (*MockTemporalClient) GetWorkerTaskReachability 

func (m *MockTemporalClient) GetWorkerTaskReachability(ctx context.Context, options *temporalclient.GetWorkerTaskReachabilityOptions) (*temporalclient.WorkerTaskReachability, error)

func (*MockTemporalClient) GetWorkflow 

func (m *MockTemporalClient) GetWorkflow(ctx context.Context, workflowID string, runID string) temporalclient.WorkflowRun

func (*MockTemporalClient) GetWorkflowHistory 

func (m *MockTemporalClient) GetWorkflowHistory(ctx context.Context, workflowID string, runID string, isLongPoll bool, filterType enums.HistoryEventFilterType) temporalclient.HistoryEventIterator

func (*MockTemporalClient) GetWorkflowUpdateHandle 

func (m *MockTemporalClient) GetWorkflowUpdateHandle(ref temporalclient.GetWorkflowUpdateHandleOptions) temporalclient.WorkflowUpdateHandle

func (*MockTemporalClient) ListArchivedWorkflow 

func (m *MockTemporalClient) ListArchivedWorkflow(ctx context.Context, request *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)

func (*MockTemporalClient) ListClosedWorkflow 

func (m *MockTemporalClient) ListClosedWorkflow(ctx context.Context, request *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)

func (*MockTemporalClient) ListOpenWorkflow 

func (m *MockTemporalClient) ListOpenWorkflow(ctx context.Context, request *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)

func (*MockTemporalClient) ListWorkflow 

func (m *MockTemporalClient) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)

func (*MockTemporalClient) OperatorService 

func (m *MockTemporalClient) OperatorService() operatorservice.OperatorServiceClient

func (*MockTemporalClient) QueryWorkflow 

func (m *MockTemporalClient) QueryWorkflow(ctx context.Context, workflowID string, runID string, queryType string, args ...interface{}) (converter.EncodedValue, error)

func (*MockTemporalClient) QueryWorkflowWithOptions 

func (m *MockTemporalClient) QueryWorkflowWithOptions(ctx context.Context, request *temporalclient.QueryWorkflowWithOptionsRequest) (*temporalclient.QueryWorkflowWithOptionsResponse, error)

func (*MockTemporalClient) RecordActivityHeartbeat 

func (m *MockTemporalClient) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error

func (*MockTemporalClient) RecordActivityHeartbeatByID 

func (m *MockTemporalClient) RecordActivityHeartbeatByID(ctx context.Context, namespace, workflowID, runID, activityID string, details ...interface{}) error

func (*MockTemporalClient) ResetWorkflowExecution 

func (m *MockTemporalClient) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)

func (*MockTemporalClient) ScanWorkflow 

func (m *MockTemporalClient) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)

func (*MockTemporalClient) ScheduleClient 

func (m *MockTemporalClient) ScheduleClient() temporalclient.ScheduleClient

func (*MockTemporalClient) SignalWithStartWorkflow 

func (m *MockTemporalClient) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, signalArg interface{}, options temporalclient.StartWorkflowOptions, workflow interface{}, workflowArgs ...interface{}) (temporalclient.WorkflowRun, error)

func (*MockTemporalClient) SignalWorkflow 

func (m *MockTemporalClient) SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, arg interface{}) error

func (*MockTemporalClient) TerminateWorkflow 

func (m *MockTemporalClient) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, details ...interface{}) error

func (*MockTemporalClient) UpdateWorkerBuildIdCompatibility 

func (m *MockTemporalClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *temporalclient.UpdateWorkerBuildIdCompatibilityOptions) error

func (*MockTemporalClient) UpdateWorkflow 

func (m *MockTemporalClient) UpdateWorkflow(ctx context.Context, workflowID string, workflowRunID string, updateName string, args ...interface{}) (temporalclient.WorkflowUpdateHandle, error)

func (*MockTemporalClient) UpdateWorkflowWithOptions 

func (m *MockTemporalClient) UpdateWorkflowWithOptions(ctx context.Context, request *temporalclient.UpdateWorkflowWithOptionsRequest) (temporalclient.WorkflowUpdateHandle, error)

func (*MockTemporalClient) WorkflowService 

func (m *MockTemporalClient) WorkflowService() workflowservice.WorkflowServiceClient

type MockTemporalClientManagerClient 

type MockTemporalClientManagerClient struct {
	mock.Mock
}

MockTemporalClientManagerClient is an autogenerated mock type for the TemporalClientManagerClient type

func NewMockTemporalClientManagerClient 

func NewMockTemporalClientManagerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockTemporalClientManagerClient

NewMockTemporalClientManagerClient creates a new instance of MockTemporalClientManagerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockTemporalClientManagerClient) ClearNamespaceClientByAccount 

func (_m *MockTemporalClientManagerClient) ClearNamespaceClientByAccount(ctx context.Context, accountId string)

ClearNamespaceClientByAccount provides a mock function with given fields: ctx, accountId

func (*MockTemporalClientManagerClient) ClearWorkflowClientByAccount 

func (_m *MockTemporalClientManagerClient) ClearWorkflowClientByAccount(ctx context.Context, accountId string)

ClearWorkflowClientByAccount provides a mock function with given fields: ctx, accountId

func (*MockTemporalClientManagerClient) DoesAccountHaveTemporalWorkspace 

func (_m *MockTemporalClientManagerClient) DoesAccountHaveTemporalWorkspace(ctx context.Context, accountId string, logger *slog.Logger) (bool, error)

DoesAccountHaveTemporalWorkspace provides a mock function with given fields: ctx, accountId, logger

func (*MockTemporalClientManagerClient) EXPECT 

func (_m *MockTemporalClientManagerClient) EXPECT() *MockTemporalClientManagerClient_Expecter

func (*MockTemporalClientManagerClient) GetNamespaceClientByAccount 

func (_m *MockTemporalClientManagerClient) GetNamespaceClientByAccount(ctx context.Context, accountId string, logger *slog.Logger) (client.NamespaceClient, error)

GetNamespaceClientByAccount provides a mock function with given fields: ctx, accountId, logger

func (*MockTemporalClientManagerClient) GetScheduleClientByAccount 

func (_m *MockTemporalClientManagerClient) GetScheduleClientByAccount(ctx context.Context, accountId string, logger *slog.Logger) (client.ScheduleClient, error)

GetScheduleClientByAccount provides a mock function with given fields: ctx, accountId, logger

func (*MockTemporalClientManagerClient) GetScheduleHandleClientByAccount 

func (_m *MockTemporalClientManagerClient) GetScheduleHandleClientByAccount(ctx context.Context, accountId string, scheduleId string, logger *slog.Logger) (client.ScheduleHandle, error)

GetScheduleHandleClientByAccount provides a mock function with given fields: ctx, accountId, scheduleId, logger

func (*MockTemporalClientManagerClient) GetTemporalConfigByAccount 

func (_m *MockTemporalClientManagerClient) GetTemporalConfigByAccount(ctx context.Context, accountId string) (*pg_models.TemporalConfig, error)

GetTemporalConfigByAccount provides a mock function with given fields: ctx, accountId

func (*MockTemporalClientManagerClient) GetWorkflowClientByAccount 

func (_m *MockTemporalClientManagerClient) GetWorkflowClientByAccount(ctx context.Context, accountId string, logger *slog.Logger) (client.Client, error)

GetWorkflowClientByAccount provides a mock function with given fields: ctx, accountId, logger

type MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call 

type MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call struct {
	*mock.Call
}

MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClearNamespaceClientByAccount'

func (*MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call) Return 

func (_c *MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call) Return() *MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call

func (*MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call) Run 

func (_c *MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call) Run(run func(ctx context.Context, accountId string)) *MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call

func (*MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call) RunAndReturn 

func (_c *MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call) RunAndReturn(run func(context.Context, string)) *MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call

type MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call 

type MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call struct {
	*mock.Call
}

MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClearWorkflowClientByAccount'

func (*MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call) Return 

func (_c *MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call) Return() *MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call

func (*MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call) Run 

func (_c *MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call) Run(run func(ctx context.Context, accountId string)) *MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call

func (*MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call) RunAndReturn 

func (_c *MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call) RunAndReturn(run func(context.Context, string)) *MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call

type MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call 

type MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call struct {
	*mock.Call
}

MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DoesAccountHaveTemporalWorkspace'

func (*MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call) Return 

func (_c *MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call) Return(_a0 bool, _a1 error) *MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call

func (*MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call) Run 

func (_c *MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call) Run(run func(ctx context.Context, accountId string, logger *slog.Logger)) *MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call

func (*MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call) RunAndReturn 

func (_c *MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call) RunAndReturn(run func(context.Context, string, *slog.Logger) (bool, error)) *MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call

type MockTemporalClientManagerClient_Expecter 

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

func (*MockTemporalClientManagerClient_Expecter) ClearNamespaceClientByAccount 

func (_e *MockTemporalClientManagerClient_Expecter) ClearNamespaceClientByAccount(ctx interface{}, accountId interface{}) *MockTemporalClientManagerClient_ClearNamespaceClientByAccount_Call

ClearNamespaceClientByAccount is a helper method to define mock.On call

  • ctx context.Context
  • accountId string

func (*MockTemporalClientManagerClient_Expecter) ClearWorkflowClientByAccount 

func (_e *MockTemporalClientManagerClient_Expecter) ClearWorkflowClientByAccount(ctx interface{}, accountId interface{}) *MockTemporalClientManagerClient_ClearWorkflowClientByAccount_Call

ClearWorkflowClientByAccount is a helper method to define mock.On call

  • ctx context.Context
  • accountId string

func (*MockTemporalClientManagerClient_Expecter) DoesAccountHaveTemporalWorkspace 

func (_e *MockTemporalClientManagerClient_Expecter) DoesAccountHaveTemporalWorkspace(ctx interface{}, accountId interface{}, logger interface{}) *MockTemporalClientManagerClient_DoesAccountHaveTemporalWorkspace_Call

DoesAccountHaveTemporalWorkspace is a helper method to define mock.On call

  • ctx context.Context
  • accountId string
  • logger *slog.Logger

func (*MockTemporalClientManagerClient_Expecter) GetNamespaceClientByAccount 

func (_e *MockTemporalClientManagerClient_Expecter) GetNamespaceClientByAccount(ctx interface{}, accountId interface{}, logger interface{}) *MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call

GetNamespaceClientByAccount is a helper method to define mock.On call

  • ctx context.Context
  • accountId string
  • logger *slog.Logger

func (*MockTemporalClientManagerClient_Expecter) GetScheduleClientByAccount 

func (_e *MockTemporalClientManagerClient_Expecter) GetScheduleClientByAccount(ctx interface{}, accountId interface{}, logger interface{}) *MockTemporalClientManagerClient_GetScheduleClientByAccount_Call

GetScheduleClientByAccount is a helper method to define mock.On call

  • ctx context.Context
  • accountId string
  • logger *slog.Logger

func (*MockTemporalClientManagerClient_Expecter) GetScheduleHandleClientByAccount 

func (_e *MockTemporalClientManagerClient_Expecter) GetScheduleHandleClientByAccount(ctx interface{}, accountId interface{}, scheduleId interface{}, logger interface{}) *MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call

GetScheduleHandleClientByAccount is a helper method to define mock.On call

  • ctx context.Context
  • accountId string
  • scheduleId string
  • logger *slog.Logger

func (*MockTemporalClientManagerClient_Expecter) GetTemporalConfigByAccount 

func (_e *MockTemporalClientManagerClient_Expecter) GetTemporalConfigByAccount(ctx interface{}, accountId interface{}) *MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call

GetTemporalConfigByAccount is a helper method to define mock.On call

  • ctx context.Context
  • accountId string

func (*MockTemporalClientManagerClient_Expecter) GetWorkflowClientByAccount 

func (_e *MockTemporalClientManagerClient_Expecter) GetWorkflowClientByAccount(ctx interface{}, accountId interface{}, logger interface{}) *MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call

GetWorkflowClientByAccount is a helper method to define mock.On call

  • ctx context.Context
  • accountId string
  • logger *slog.Logger

type MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call 

type MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call struct {
	*mock.Call
}

MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetNamespaceClientByAccount'

func (*MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call) Return 

func (_c *MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call) Return(_a0 client.NamespaceClient, _a1 error) *MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call

func (*MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call) Run 

func (_c *MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call) Run(run func(ctx context.Context, accountId string, logger *slog.Logger)) *MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call

func (*MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call) RunAndReturn 

func (_c *MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call) RunAndReturn(run func(context.Context, string, *slog.Logger) (client.NamespaceClient, error)) *MockTemporalClientManagerClient_GetNamespaceClientByAccount_Call

type MockTemporalClientManagerClient_GetScheduleClientByAccount_Call 

type MockTemporalClientManagerClient_GetScheduleClientByAccount_Call struct {
	*mock.Call
}

MockTemporalClientManagerClient_GetScheduleClientByAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetScheduleClientByAccount'

func (*MockTemporalClientManagerClient_GetScheduleClientByAccount_Call) Return 

func (_c *MockTemporalClientManagerClient_GetScheduleClientByAccount_Call) Return(_a0 client.ScheduleClient, _a1 error) *MockTemporalClientManagerClient_GetScheduleClientByAccount_Call

func (*MockTemporalClientManagerClient_GetScheduleClientByAccount_Call) Run 

func (_c *MockTemporalClientManagerClient_GetScheduleClientByAccount_Call) Run(run func(ctx context.Context, accountId string, logger *slog.Logger)) *MockTemporalClientManagerClient_GetScheduleClientByAccount_Call

func (*MockTemporalClientManagerClient_GetScheduleClientByAccount_Call) RunAndReturn 

func (_c *MockTemporalClientManagerClient_GetScheduleClientByAccount_Call) RunAndReturn(run func(context.Context, string, *slog.Logger) (client.ScheduleClient, error)) *MockTemporalClientManagerClient_GetScheduleClientByAccount_Call

type MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call 

type MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call struct {
	*mock.Call
}

MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetScheduleHandleClientByAccount'

func (*MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call) Return 

func (_c *MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call) Return(_a0 client.ScheduleHandle, _a1 error) *MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call

func (*MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call) Run 

func (_c *MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call) Run(run func(ctx context.Context, accountId string, scheduleId string, logger *slog.Logger)) *MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call

func (*MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call) RunAndReturn 

func (_c *MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call) RunAndReturn(run func(context.Context, string, string, *slog.Logger) (client.ScheduleHandle, error)) *MockTemporalClientManagerClient_GetScheduleHandleClientByAccount_Call

type MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call 

type MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call struct {
	*mock.Call
}

MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTemporalConfigByAccount'

func (*MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call) Return 

func (_c *MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call) Return(_a0 *pg_models.TemporalConfig, _a1 error) *MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call

func (*MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call) Run 

func (_c *MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call) Run(run func(ctx context.Context, accountId string)) *MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call

func (*MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call) RunAndReturn 

func (_c *MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call) RunAndReturn(run func(context.Context, string) (*pg_models.TemporalConfig, error)) *MockTemporalClientManagerClient_GetTemporalConfigByAccount_Call

type MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call 

type MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call struct {
	*mock.Call
}

MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflowClientByAccount'

func (*MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call) Return 

func (_c *MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call) Return(_a0 client.Client, _a1 error) *MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call

func (*MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call) Run 

func (_c *MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call) Run(run func(ctx context.Context, accountId string, logger *slog.Logger)) *MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call

func (*MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call) RunAndReturn 

func (_c *MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call) RunAndReturn(run func(context.Context, string, *slog.Logger) (client.Client, error)) *MockTemporalClientManagerClient_GetWorkflowClientByAccount_Call

type TemporalClientManager 

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

func New 

func New(
	config *Config,
	db DB,
	dbtx db_queries.DBTX,
) *TemporalClientManager

func (*TemporalClientManager) ClearNamespaceClientByAccount 

func (t *TemporalClientManager) ClearNamespaceClientByAccount(
	ctx context.Context,
	accountId string,
)

func (*TemporalClientManager) ClearWorkflowClientByAccount 

func (t *TemporalClientManager) ClearWorkflowClientByAccount(
	ctx context.Context,
	accountId string,
)

func (*TemporalClientManager) DoesAccountHaveTemporalWorkspace 

func (t *TemporalClientManager) DoesAccountHaveTemporalWorkspace(
	ctx context.Context,
	accountId string,
	logger *slog.Logger,
) (bool, error)

func (*TemporalClientManager) GetNamespaceClientByAccount 

func (t *TemporalClientManager) GetNamespaceClientByAccount(
	ctx context.Context,
	accountId string,
	logger *slog.Logger,
) (temporalclient.NamespaceClient, error)

func (*TemporalClientManager) GetScheduleClientByAccount 

func (t *TemporalClientManager) GetScheduleClientByAccount(
	ctx context.Context,
	accountId string,
	logger *slog.Logger,
) (temporalclient.ScheduleClient, error)

func (*TemporalClientManager) GetScheduleHandleClientByAccount 

func (t *TemporalClientManager) GetScheduleHandleClientByAccount(
	ctx context.Context,
	accountId string,
	scheduleId string,
	logger *slog.Logger,
) (temporalclient.ScheduleHandle, error)

func (*TemporalClientManager) GetTemporalConfigByAccount 

func (t *TemporalClientManager) GetTemporalConfigByAccount(
	ctx context.Context,
	accountId string,
) (*pg_models.TemporalConfig, error)

func (*TemporalClientManager) GetWorkflowClientByAccount 

func (t *TemporalClientManager) GetWorkflowClientByAccount(
	ctx context.Context,
	accountId string,
	logger *slog.Logger,
) (temporalclient.Client, error)

type TemporalClientManagerClient 

type TemporalClientManagerClient interface {
	ClearNamespaceClientByAccount(ctx context.Context, accountId string)
	ClearWorkflowClientByAccount(ctx context.Context, accountId string)
	GetNamespaceClientByAccount(ctx context.Context, accountId string, logger *slog.Logger) (temporalclient.NamespaceClient, error)
	GetWorkflowClientByAccount(ctx context.Context, accountId string, logger *slog.Logger) (temporalclient.Client, error)
	GetScheduleClientByAccount(ctx context.Context, accountId string, logger *slog.Logger) (temporalclient.ScheduleClient, error)
	GetScheduleHandleClientByAccount(ctx context.Context, accountId string, scheduleId string, logger *slog.Logger) (temporalclient.ScheduleHandle, error)
	GetTemporalConfigByAccount(ctx context.Context, accountId string) (*pg_models.TemporalConfig, error)
	DoesAccountHaveTemporalWorkspace(
		ctx context.Context,
		accountId string,
		logger *slog.Logger,
	) (bool, error)
}

Source Files

View all Source files

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.