service

package
v2.0.13 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2026 License: Apache-2.0 Imports: 58 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RootActionName = "a0"
)

Variables

This section is empty.

Functions

func CoalesceNullString added in v2.0.9 

func CoalesceNullString(s sql.NullString) string

func IsTerminalPhase added in v2.0.9 

func IsTerminalPhase(phase common.ActionPhase) bool

func NewTaskService added in v2.0.1 

func NewTaskService(repo interfaces.Repository) taskconnect.TaskServiceHandler

func NewTriggerService added in v2.0.9 

func NewTriggerService(repo interfaces.Repository) triggerconnect.TriggerServiceHandler

Types

type AbortReconciler added in v2.0.10 

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

AbortReconciler watches for abort requests and drives pod termination to completion with exponential backoff retries.

func NewAbortReconciler added in v2.0.10 

func NewAbortReconciler(repo interfaces.Repository, actionsClient actionsconnect.ActionsServiceClient, cfg AbortReconcilerConfig) *AbortReconciler

NewAbortReconciler creates a new AbortReconciler. Zero-value cfg fields are filled with defaults.

func (*AbortReconciler) Push added in v2.0.10 

func (r *AbortReconciler) Push(ctx context.Context, actionID *common.ActionIdentifier, reason string)

Push enqueues an abort request for the given action. Safe to call concurrently. No-op if the key is already queued (dedup).

func (*AbortReconciler) Run added in v2.0.10 

func (r *AbortReconciler) Run(ctx context.Context) error

Run starts the reconciler. It blocks until ctx is cancelled.

type AbortReconcilerConfig added in v2.0.10 

type AbortReconcilerConfig struct {
	// Workers is the number of concurrent pod-termination goroutines.
	Workers int
	// MaxAttempts is the maximum number of actionsClient.Abort calls per action before giving up.
	MaxAttempts int
	// QueueSize is the buffer size of the internal channel.
	QueueSize int
	// InitialDelay is the backoff duration before the first retry.
	InitialDelay time.Duration
	// MaxDelay caps the exponential backoff.
	MaxDelay time.Duration
}

AbortReconcilerConfig holds tunables for the reconciler.

type AppService added in v2.0.9 

type AppService struct {
	appconnect.UnimplementedAppServiceHandler
}

AppService is a dummy implementation that returns empty responses for all endpoints.

func NewAppService added in v2.0.9 

func NewAppService() *AppService

func (*AppService) Create added in v2.0.9 

func (s *AppService) Create(
	ctx context.Context,
	req *connect.Request[flyteapp.CreateRequest],
) (*connect.Response[flyteapp.CreateResponse], error)

func (*AppService) Delete added in v2.0.9 

func (s *AppService) Delete(
	ctx context.Context,
	req *connect.Request[flyteapp.DeleteRequest],
) (*connect.Response[flyteapp.DeleteResponse], error)

func (*AppService) Get added in v2.0.9 

func (s *AppService) Get(
	ctx context.Context,
	req *connect.Request[flyteapp.GetRequest],
) (*connect.Response[flyteapp.GetResponse], error)

func (*AppService) Lease added in v2.0.9 

func (s *AppService) Lease(
	ctx context.Context,
	req *connect.Request[flyteapp.LeaseRequest],
	stream *connect.ServerStream[flyteapp.LeaseResponse],
) error

func (*AppService) List added in v2.0.9 

func (s *AppService) List(
	ctx context.Context,
	req *connect.Request[flyteapp.ListRequest],
) (*connect.Response[flyteapp.ListResponse], error)

func (*AppService) Update added in v2.0.9 

func (s *AppService) Update(
	ctx context.Context,
	req *connect.Request[flyteapp.UpdateRequest],
) (*connect.Response[flyteapp.UpdateResponse], error)

func (*AppService) UpdateStatus added in v2.0.9 

func (s *AppService) UpdateStatus(
	ctx context.Context,
	req *connect.Request[flyteapp.UpdateStatusRequest],
) (*connect.Response[flyteapp.UpdateStatusResponse], error)

func (*AppService) Watch added in v2.0.9 

func (s *AppService) Watch(
	ctx context.Context,
	req *connect.Request[flyteapp.WatchRequest],
	stream *connect.ServerStream[flyteapp.WatchResponse],
) error

type AuthMetadataService added in v2.0.10 

type AuthMetadataService struct {
	authconnect.UnimplementedAuthMetadataServiceHandler
	// contains filtered or unexported fields
}

AuthMetadataService implements the AuthMetadataServiceHandler interface.

func NewAuthMetadataService added in v2.0.10 

func NewAuthMetadataService(dataplaneDomain string) *AuthMetadataService

NewAuthMetadataService creates a new AuthMetadataService instance.

func (*AuthMetadataService) GetPublicClientConfig added in v2.0.10 

func (s *AuthMetadataService) GetPublicClientConfig(
	ctx context.Context,
	req *connect.Request[auth.GetPublicClientConfigRequest],
) (*connect.Response[auth.GetPublicClientConfigResponse], error)

type IdentityService added in v2.0.8 

type IdentityService struct{}

IdentityService implements the IdentityServiceHandler interface.

func NewIdentityService added in v2.0.8 

func NewIdentityService() *IdentityService

NewIdentityService creates a new IdentityService instance.

func (*IdentityService) UserInfo added in v2.0.8 

func (s *IdentityService) UserInfo(
	ctx context.Context,
	req *connect.Request[auth.UserInfoRequest],
) (*connect.Response[auth.UserInfoResponse], error)

UserInfo returns information about the currently logged in user. TODO: Wire with real auth to populate user info from the authenticated context.

type K8sLogStreamer added in v2.0.9 

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

K8sLogStreamer streams logs directly from Kubernetes pods.

func NewK8sLogStreamer added in v2.0.9 

func NewK8sLogStreamer(k8sConfig *rest.Config) (*K8sLogStreamer, error)

NewK8sLogStreamer creates a K8sLogStreamer from a Kubernetes REST config. It clears the timeout so that long-lived log streams are not interrupted.

func (*K8sLogStreamer) TailLogs added in v2.0.9 

func (s *K8sLogStreamer) TailLogs(ctx context.Context, logContext *core.LogContext, stream *connect.ServerStream[workflow.TailLogsResponse]) error

TailLogs streams log lines for the given LogContext from a Kubernetes pod.

type LogStreamer added in v2.0.9 

type LogStreamer interface {
	TailLogs(ctx context.Context, logContext *core.LogContext, stream *connect.ServerStream[workflow.TailLogsResponse]) error
}

LogStreamer abstracts log fetching from different backends.

type ProjectService added in v2.0.8 

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

func NewProjectService added in v2.0.8 

func NewProjectService(projectRepo interfaces.ProjectRepo, domains []*project.Domain) *ProjectService

func (*ProjectService) CreateProject added in v2.0.8 

func (s *ProjectService) CreateProject(
	ctx context.Context,
	req *connect.Request[project.CreateProjectRequest],
) (*connect.Response[project.CreateProjectResponse], error)

func (*ProjectService) GetProject added in v2.0.8 

func (s *ProjectService) GetProject(
	ctx context.Context,
	req *connect.Request[project.GetProjectRequest],
) (*connect.Response[project.GetProjectResponse], error)

func (*ProjectService) ListProjects added in v2.0.8 

func (s *ProjectService) ListProjects(
	ctx context.Context,
	req *connect.Request[project.ListProjectsRequest],
) (*connect.Response[project.ListProjectsResponse], error)

func (*ProjectService) UpdateProject added in v2.0.8 

func (s *ProjectService) UpdateProject(
	ctx context.Context,
	req *connect.Request[project.UpdateProjectRequest],
) (*connect.Response[project.UpdateProjectResponse], error)

type RunLogsService added in v2.0.9 

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

RunLogsService implements the RunLogsServiceHandler interface.

func NewRunLogsService added in v2.0.9 

func NewRunLogsService(repo interfaces.Repository, streamer LogStreamer) *RunLogsService

NewRunLogsService creates a new RunLogsService.

func (*RunLogsService) TailLogs added in v2.0.9 

func (s *RunLogsService) TailLogs(ctx context.Context, req *connect.Request[workflow.TailLogsRequest], stream *connect.ServerStream[workflow.TailLogsResponse]) error

TailLogs streams pod logs for an action attempt.

type RunService 

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

RunService implements the RunServiceHandler interface

func NewRunService 

func NewRunService(repo interfaces.Repository, actionsClient actionsconnect.ActionsServiceClient, storagePrefix string, dataStore *storage.DataStore, reconciler *AbortReconciler) *RunService

NewRunService creates a new RunService instance

func (*RunService) AbortAction 

func (s *RunService) AbortAction(
	ctx context.Context,
	req *connect.Request[workflow.AbortActionRequest],
) (*connect.Response[workflow.AbortActionResponse], error)

AbortAction aborts a specific action

func (*RunService) AbortRun 

func (s *RunService) AbortRun(
	ctx context.Context,
	req *connect.Request[workflow.AbortRunRequest],
) (*connect.Response[workflow.AbortRunResponse], error)

AbortRun aborts a run

func (*RunService) CreateRun 

func (s *RunService) CreateRun(
	ctx context.Context,
	req *connect.Request[workflow.CreateRunRequest],
) (*connect.Response[workflow.CreateRunResponse], error)

CreateRun creates a new run

func (*RunService) GetActionData 

func (s *RunService) GetActionData(
	ctx context.Context,
	req *connect.Request[workflow.GetActionDataRequest],
) (*connect.Response[workflow.GetActionDataResponse], error)

GetActionData gets input and output data for an action by reading from storage.

func (*RunService) GetActionDataURIs added in v2.0.12 

func (s *RunService) GetActionDataURIs(
	ctx context.Context,
	req *connect.Request[workflow.GetActionDataURIsRequest],
) (*connect.Response[workflow.GetActionDataURIsResponse], error)

func (*RunService) GetActionDetails 

func (s *RunService) GetActionDetails(
	ctx context.Context,
	req *connect.Request[workflow.GetActionDetailsRequest],
) (*connect.Response[workflow.GetActionDetailsResponse], error)

GetActionDetails gets detailed information about an action from the DB.

func (*RunService) GetActionLogContext added in v2.0.12 

func (s *RunService) GetActionLogContext(
	ctx context.Context,
	req *connect.Request[workflow.GetActionLogContextRequest],
) (*connect.Response[workflow.GetActionLogContextResponse], error)

func (*RunService) GetRunDetails 

func (s *RunService) GetRunDetails(
	ctx context.Context,
	req *connect.Request[workflow.GetRunDetailsRequest],
) (*connect.Response[workflow.GetRunDetailsResponse], error)

GetRunDetails gets detailed information about a run from the DB.

func (*RunService) ListActions 

func (s *RunService) ListActions(
	ctx context.Context,
	req *connect.Request[workflow.ListActionsRequest],
) (*connect.Response[workflow.ListActionsResponse], error)

ListActions lists actions for a run

func (*RunService) ListRuns 

func (s *RunService) ListRuns(
	ctx context.Context,
	req *connect.Request[workflow.ListRunsRequest],
) (*connect.Response[workflow.ListRunsResponse], error)

ListRuns lists runs based on filter criteria

func (*RunService) RecordAction added in v2.0.8 

func (s *RunService) RecordAction(
	ctx context.Context,
	req *connect.Request[workflow.RecordActionRequest],
) (*connect.Response[workflow.RecordActionResponse], error)

RecordAction records a new action in the database.

func (*RunService) RecordActionEventStream added in v2.0.8 

func (s *RunService) RecordActionEventStream(
	ctx context.Context,
	stream *connect.BidiStream[workflow.RecordActionEventStreamRequest, workflow.RecordActionEventStreamResponse],
) error

RecordActionEventStream is the bidirectional streaming variant of RecordActionEvents.

func (*RunService) RecordActionEvents added in v2.0.8 

func (s *RunService) RecordActionEvents(
	ctx context.Context,
	req *connect.Request[workflow.RecordActionEventsRequest],
) (*connect.Response[workflow.RecordActionEventsResponse], error)

RecordActionEvents records a batch of action events.

func (*RunService) RecordActionStream added in v2.0.8 

func (s *RunService) RecordActionStream(
	ctx context.Context,
	stream *connect.BidiStream[workflow.RecordActionStreamRequest, workflow.RecordActionStreamResponse],
) error

RecordActionStream is the bidirectional streaming variant of RecordAction.

func (*RunService) UpdateActionStatus added in v2.0.8 

func (s *RunService) UpdateActionStatus(
	ctx context.Context,
	req *connect.Request[workflow.UpdateActionStatusRequest],
) (*connect.Response[workflow.UpdateActionStatusResponse], error)

UpdateActionStatus updates the phase of an action.

func (*RunService) UpdateActionStatusStream added in v2.0.8 

func (s *RunService) UpdateActionStatusStream(
	ctx context.Context,
	stream *connect.BidiStream[workflow.UpdateActionStatusStreamRequest, workflow.UpdateActionStatusStreamResponse],
) error

UpdateActionStatusStream is the bidirectional streaming variant of UpdateActionStatus.

func (*RunService) WatchActionDetails 

func (s *RunService) WatchActionDetails(
	ctx context.Context,
	req *connect.Request[workflow.WatchActionDetailsRequest],
	stream *connect.ServerStream[workflow.WatchActionDetailsResponse],
) error

WatchActionDetails streams action details updates from the DB.

func (*RunService) WatchActions 

func (s *RunService) WatchActions(
	ctx context.Context,
	req *connect.Request[workflow.WatchActionsRequest],
	stream *connect.ServerStream[workflow.WatchActionsResponse],
) error

WatchActions streams action updates for a run from the DB.

func (*RunService) WatchClusterEvents 

func (s *RunService) WatchClusterEvents(
	ctx context.Context,
	req *connect.Request[workflow.WatchClusterEventsRequest],
	stream *connect.ServerStream[workflow.WatchClusterEventsResponse],
) error

WatchClusterEvents streams Kubernetes cluster events recorded in action_events.

func (*RunService) WatchGroups 

func (s *RunService) WatchGroups(ctx context.Context, req *connect.Request[workflow.WatchGroupsRequest], stream *connect.ServerStream[workflow.WatchGroupsResponse]) error

WatchGroups streams task groups (runs grouped by task) from the database.

func (*RunService) WatchRunDetails 

func (s *RunService) WatchRunDetails(
	ctx context.Context,
	req *connect.Request[workflow.WatchRunDetailsRequest],
	stream *connect.ServerStream[workflow.WatchRunDetailsResponse],
) error

WatchRunDetails streams run details updates from the DB.

func (*RunService) WatchRuns 

func (s *RunService) WatchRuns(
	ctx context.Context,
	req *connect.Request[workflow.WatchRunsRequest],
	stream *connect.ServerStream[workflow.WatchRunsResponse],
) error

WatchRuns streams run updates based on filter criteria

type TranslatorService added in v2.0.7 

type TranslatorService struct {
	workflowconnect.UnimplementedTranslatorServiceHandler
}

TranslatorService implements the TranslatorServiceHandler interface for translating between Flyte literals and JSON representations.

func NewTranslatorService added in v2.0.7 

func NewTranslatorService() *TranslatorService

NewTranslatorService creates a new TranslatorService instance.

func (*TranslatorService) JsonValuesToLiterals added in v2.0.7 

func (s *TranslatorService) JsonValuesToLiterals(
	ctx context.Context,
	req *connect.Request[workflow.JsonValuesToLiteralsRequest],
) (*connect.Response[workflow.JsonValuesToLiteralsResponse], error)

JsonValuesToLiterals converts raw JSON values and type definitions (VariableMap) into NamedLiterals.

func (*TranslatorService) LaunchFormJsonToLiterals added in v2.0.7 

func (s *TranslatorService) LaunchFormJsonToLiterals(
	ctx context.Context,
	req *connect.Request[workflow.LaunchFormJsonToLiteralsRequest],
) (*connect.Response[workflow.LaunchFormJsonToLiteralsResponse], error)

LaunchFormJsonToLiterals converts an RSJF JSON schema to a list of NamedLiterals.

func (*TranslatorService) LiteralsToLaunchFormJson added in v2.0.7 

func (s *TranslatorService) LiteralsToLaunchFormJson(
	ctx context.Context,
	req *connect.Request[workflow.LiteralsToLaunchFormJsonRequest],
) (*connect.Response[workflow.LiteralsToLaunchFormJsonResponse], error)

LiteralsToLaunchFormJson converts a list of NamedLiterals to an RSJF-compliant JSON schema.

func (*TranslatorService) TaskSpecToLaunchFormJson added in v2.0.7 

func (s *TranslatorService) TaskSpecToLaunchFormJson(
	ctx context.Context,
	req *connect.Request[workflow.TaskSpecToLaunchFormJsonRequest],
) (*connect.Response[workflow.TaskSpecToLaunchFormJsonResponse], error)

TaskSpecToLaunchFormJson converts a TaskSpec to an RSJF-compliant JSON schema.

Source Files

View all Source files

Directories

Path Synopsis

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.