dataproxy

Documentation

Index

• type Service
  • func NewService(cfg config.DataProxyConfig, nodeExec interfaces.NodeExecutionInterface, ...) (Service, error)
  • func (s Service) CreateDownloadLink(ctx context.Context, req *service.CreateDownloadLinkRequest) (resp *service.CreateDownloadLinkResponse, err error)
  • func (s Service) CreateDownloadLocation(ctx context.Context, req *service.CreateDownloadLocationRequest) (*service.CreateDownloadLocationResponse, error)
  • func (s Service) CreateUploadLocation(ctx context.Context, req *service.CreateUploadLocationRequest) (*service.CreateUploadLocationResponse, error)
  • func (s Service) GetData(ctx context.Context, req *service.GetDataRequest) (*service.GetDataResponse, error)
  • func (s Service) GetTaskExecutionID(ctx context.Context, attempt int, nodeExecID core.NodeExecutionIdentifier) (*core.TaskExecutionIdentifier, error)

Types

type Service

type Service struct {
	service.DataProxyServiceServer
	// contains filtered or unexported fields
}

func NewService

func NewService(cfg config.DataProxyConfig,
	nodeExec interfaces.NodeExecutionInterface,
	dataStore *storage.DataStore,
	taskExec interfaces.TaskExecutionInterface) (Service, error)

func (Service) CreateDownloadLink

func (s Service) CreateDownloadLink(ctx context.Context, req *service.CreateDownloadLinkRequest) (
	resp *service.CreateDownloadLinkResponse, err error)

CreateDownloadLink retrieves the requested artifact type for a given execution (wf, node, task) as a signed url(s).

func (Service) CreateDownloadLocation

func (s Service) CreateDownloadLocation(ctx context.Context, req *service.CreateDownloadLocationRequest) (
	*service.CreateDownloadLocationResponse, error)

CreateDownloadLocation creates a temporary signed url to allow callers to download content.

func (Service) CreateUploadLocation

func (s Service) CreateUploadLocation(ctx context.Context, req *service.CreateUploadLocationRequest) (
	*service.CreateUploadLocationResponse, error)

CreateUploadLocation creates a temporary signed url to allow callers to upload content.

func (Service) GetData

func (s Service) GetData(ctx context.Context, req *service.GetDataRequest) (
	*service.GetDataResponse, error)

func (Service) GetTaskExecutionID

func (s Service) GetTaskExecutionID(ctx context.Context, attempt int, nodeExecID core.NodeExecutionIdentifier) (*core.TaskExecutionIdentifier, error)