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: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterService added in v2.0.12 

type ClusterService struct {
	clusterconnect.UnimplementedClusterServiceHandler
}

func NewClusterService added in v2.0.12 

func NewClusterService() *ClusterService

func (*ClusterService) SelectCluster added in v2.0.12 

func (s *ClusterService) SelectCluster(
	ctx context.Context,
	req *connect.Request[cluster.SelectClusterRequest],
) (*connect.Response[cluster.SelectClusterResponse], error)

type Service 

type Service struct {
	dataproxyconnect.UnimplementedDataProxyServiceHandler
	// contains filtered or unexported fields
}

func NewService 

func NewService(cfg config.DataProxyConfig, dataStore *storage.DataStore, taskClient taskconnect.TaskServiceClient, triggerClient triggerconnect.TriggerServiceClient, runClient workflowconnect.RunServiceClient, logStreamer logs.LogStreamer) *Service

NewService creates a new DataProxyService instance. 

func (s *Service) CreateDownloadLink(
	ctx context.Context,
	req *connect.Request[dataproxy.CreateDownloadLinkRequest],
) (*connect.Response[dataproxy.CreateDownloadLinkResponse], error)

CreateDownloadLink generates signed URL(s) for downloading an artifact associated with a run action.

func (*Service) CreateUploadLocation 

func (s *Service) CreateUploadLocation(
	ctx context.Context,
	req *connect.Request[dataproxy.CreateUploadLocationRequest],
) (*connect.Response[dataproxy.CreateUploadLocationResponse], error)

CreateUploadLocation generates a signed URL for uploading data to the configured storage backend.

func (*Service) GetActionData added in v2.0.12 

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

GetActionData gets input and output data for an action by calling RunService for URIs and reading the data from storage.

func (*Service) TailLogs added in v2.0.12 

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

TailLogs streams logs for an action attempt.

func (*Service) UploadInputs added in v2.0.10 

func (s *Service) UploadInputs(
	ctx context.Context,
	req *connect.Request[dataproxy.UploadInputsRequest],
) (*connect.Response[dataproxy.UploadInputsResponse], error)

UploadInputs persists the given inputs to storage and returns a URI and hash that can be passed to CreateRun via OffloadedInputData.

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.