v1alpha1_jobservice

package
v0.4.22 Latest Latest
Warning

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

 Go to latest Published: May 22, 2024 License: MIT Imports: 42 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 {
	IsAuthEnabled bool

	RunLogConfig *RunLogConfig
}

type Destination 

type Destination struct {
	ConnectionId pgtype.UUID
	Options      *pg_models.JobDestinationOptions
}

type KubePodRunLogConfig 

type KubePodRunLogConfig struct {
	Namespace     string
	WorkerAppName string
}

type LogLine 

type LogLine struct {
	WorkflowID string     `json:"WorkflowID"`
	Time       *time.Time `json:"time,omitempty"`
	Level      string     `json:"level"`
}

type LokiRunLogConfig 

type LokiRunLogConfig struct {
	BaseUrl string

	LabelsQuery string // Labels to filter loki by, without the curly braces
	// labels to keep after the json filtering. Keeps ordering. Not sure if it will always need to equal the labels query keys, so separating this
	KeepLabels []string
}

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 RunLogConfig 

type RunLogConfig struct {
	IsEnabled        bool
	RunLogType       *RunLogType
	RunLogPodConfig  *KubePodRunLogConfig // required if RunLogType is k8s-pods
	LokiRunLogConfig *LokiRunLogConfig    // required if RunLogType is loki
}

type RunLogType 

type RunLogType string
const (
	KubePodRunLogType RunLogType = "k8s-pods"
	LokiRunLogType    RunLogType = "loki"
)

type Service 

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

func New 

func New(
	cfg *Config,
	db *nucleusdb.NucleusDb,
	temporalWfManager clientmanager.TemporalClientManagerClient,
	connectionService mgmtv1alpha1connect.ConnectionServiceClient,
	useraccountService mgmtv1alpha1connect.UserAccountServiceClient,
) *Service

func (*Service) CancelJobRun 

func (s *Service) CancelJobRun(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.CancelJobRunRequest],
) (*connect.Response[mgmtv1alpha1.CancelJobRunResponse], error)

func (*Service) CreateJob 

func (s *Service) CreateJob(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.CreateJobRequest],
) (*connect.Response[mgmtv1alpha1.CreateJobResponse], error)

func (*Service) CreateJobDestinationConnections 

func (s *Service) CreateJobDestinationConnections(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.CreateJobDestinationConnectionsRequest],
) (*connect.Response[mgmtv1alpha1.CreateJobDestinationConnectionsResponse], error)

func (*Service) CreateJobRun 

func (s *Service) CreateJobRun(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.CreateJobRunRequest],
) (*connect.Response[mgmtv1alpha1.CreateJobRunResponse], error)

func (*Service) DeleteJob 

func (s *Service) DeleteJob(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.DeleteJobRequest],
) (*connect.Response[mgmtv1alpha1.DeleteJobResponse], error)

func (*Service) DeleteJobDestinationConnection 

func (s *Service) DeleteJobDestinationConnection(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.DeleteJobDestinationConnectionRequest],
) (*connect.Response[mgmtv1alpha1.DeleteJobDestinationConnectionResponse], error)

func (*Service) DeleteJobRun 

func (s *Service) DeleteJobRun(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.DeleteJobRunRequest],
) (*connect.Response[mgmtv1alpha1.DeleteJobRunResponse], error)

func (*Service) GetJob 

func (s *Service) GetJob(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobRequest],
) (*connect.Response[mgmtv1alpha1.GetJobResponse], error)

func (*Service) GetJobNextRuns 

func (s *Service) GetJobNextRuns(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobNextRunsRequest],
) (*connect.Response[mgmtv1alpha1.GetJobNextRunsResponse], error)

func (*Service) GetJobRecentRuns 

func (s *Service) GetJobRecentRuns(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobRecentRunsRequest],
) (*connect.Response[mgmtv1alpha1.GetJobRecentRunsResponse], error)

func (*Service) GetJobRun 

func (s *Service) GetJobRun(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobRunRequest],
) (*connect.Response[mgmtv1alpha1.GetJobRunResponse], error)

func (*Service) GetJobRunEvents 

func (s *Service) GetJobRunEvents(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobRunEventsRequest],
) (*connect.Response[mgmtv1alpha1.GetJobRunEventsResponse], error)

func (*Service) GetJobRunLogsStream 

func (s *Service) GetJobRunLogsStream(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobRunLogsStreamRequest],
	stream *connect.ServerStream[mgmtv1alpha1.GetJobRunLogsStreamResponse],
) error

func (*Service) GetJobRuns 

func (s *Service) GetJobRuns(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobRunsRequest],
) (*connect.Response[mgmtv1alpha1.GetJobRunsResponse], error)

func (*Service) GetJobStatus 

func (s *Service) GetJobStatus(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobStatusRequest],
) (*connect.Response[mgmtv1alpha1.GetJobStatusResponse], error)

func (*Service) GetJobStatuses 

func (s *Service) GetJobStatuses(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobStatusesRequest],
) (*connect.Response[mgmtv1alpha1.GetJobStatusesResponse], error)

func (*Service) GetJobs 

func (s *Service) GetJobs(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetJobsRequest],
) (*connect.Response[mgmtv1alpha1.GetJobsResponse], error)

func (*Service) IsJobNameAvailable 

func (s *Service) IsJobNameAvailable(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.IsJobNameAvailableRequest],
) (*connect.Response[mgmtv1alpha1.IsJobNameAvailableResponse], error)

func (*Service) PauseJob 

func (s *Service) PauseJob(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.PauseJobRequest],
) (*connect.Response[mgmtv1alpha1.PauseJobResponse], error)

func (*Service) SetJobSourceSqlConnectionSubsets 

func (s *Service) SetJobSourceSqlConnectionSubsets(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsRequest],
) (*connect.Response[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)

func (*Service) SetJobSyncOptions 

func (s *Service) SetJobSyncOptions(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.SetJobSyncOptionsRequest],
) (*connect.Response[mgmtv1alpha1.SetJobSyncOptionsResponse], error)

func (*Service) SetJobWorkflowOptions 

func (s *Service) SetJobWorkflowOptions(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.SetJobWorkflowOptionsRequest],
) (*connect.Response[mgmtv1alpha1.SetJobWorkflowOptionsResponse], error)

func (*Service) TerminateJobRun 

func (s *Service) TerminateJobRun(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.TerminateJobRunRequest],
) (*connect.Response[mgmtv1alpha1.TerminateJobRunResponse], error)

func (*Service) UpdateJobDestinationConnection 

func (s *Service) UpdateJobDestinationConnection(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.UpdateJobDestinationConnectionRequest],
) (*connect.Response[mgmtv1alpha1.UpdateJobDestinationConnectionResponse], error)

func (*Service) UpdateJobSchedule 

func (s *Service) UpdateJobSchedule(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.UpdateJobScheduleRequest],
) (*connect.Response[mgmtv1alpha1.UpdateJobScheduleResponse], error)

func (*Service) UpdateJobSourceConnection 

func (s *Service) UpdateJobSourceConnection(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.UpdateJobSourceConnectionRequest],
) (*connect.Response[mgmtv1alpha1.UpdateJobSourceConnectionResponse], 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.