Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + type Service struct + 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) GetCompleteTaskExecutionID(ctx context.Context, taskExecID core.TaskExecutionIdentifier) (*core.TaskExecutionIdentifier, error) + func (s Service) GetData(ctx context.Context, req *service.GetDataRequest) (*service.GetDataResponse, error) + func (s Service) GetDataFromNodeExecution(ctx context.Context, nodeExecID core.NodeExecutionIdentifier, ...) (*service.GetDataResponse, error) + func (s Service) GetDataFromTaskExecution(ctx context.Context, taskExecID core.TaskExecutionIdentifier, ...) (*service.GetDataResponse, error) + func (s Service) GetTaskExecutionID(ctx context.Context, attempt int, nodeExecID core.NodeExecutionIdentifier) (*core.TaskExecutionIdentifier, error)