c1api

Documentation

Index

• Variables
• func NewC1TaskManager(ctx context.Context, clientID string, clientSecret string, tempDir string) (tasks.Manager, error)
• type BatonServiceClient

Variables

var (
	ErrTaskCancelled       = errors.New("task was cancelled")
	ErrTaskHeartbeatFailed = errors.New("task failed heartbeat")

	ErrTaskNonRetryable = errors.New("task failed and is non-retryable")
)

Functions

func NewC1TaskManager

func NewC1TaskManager(ctx context.Context, clientID string, clientSecret string, tempDir string) (tasks.Manager, error)

Types

type BatonServiceClient

type BatonServiceClient interface {
	GetTask(ctx context.Context, req *v1.BatonServiceGetTaskRequest) (*v1.BatonServiceGetTaskResponse, error)
	Heartbeat(ctx context.Context, req *v1.BatonServiceHeartbeatRequest) (*v1.BatonServiceHeartbeatResponse, error)
	FinishTask(ctx context.Context, req *v1.BatonServiceFinishTaskRequest) (*v1.BatonServiceFinishTaskResponse, error)
	Upload(ctx context.Context, task *v1.Task, r io.ReadSeeker) error
	// contains filtered or unexported methods
}