v1alpha1_jobservice

package
v0.4.67 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2024 License: MIT Imports: 45 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
	IsNeosyncCloud 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 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,
	sqlmanager sql_manager.SqlManagerClient,
) *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) GetRunContext added in v0.4.54 

func (s *Service) GetRunContext(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetRunContextRequest],
) (*connect.Response[mgmtv1alpha1.GetRunContextResponse], 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) SetRunContext added in v0.4.54 

func (s *Service) SetRunContext(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.SetRunContextRequest],
) (*connect.Response[mgmtv1alpha1.SetRunContextResponse], error)

func (*Service) SetRunContexts added in v0.4.54 

func (s *Service) SetRunContexts(
	ctx context.Context,
	stream *connect.ClientStream[mgmtv1alpha1.SetRunContextsRequest],
) (*connect.Response[mgmtv1alpha1.SetRunContextsResponse], 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)

func (*Service) ValidateJobMappings added in v0.4.24 

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