c1api

package
v0.8.15 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2026 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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,
	skipFullSync bool,
	externalC1Z string,
	externalResourceEntitlementIdFilter string,
	targetedSyncResources []*v2.Resource,
	syncResourceTypeIDs []string,
	workerCount int,
) (tasks.Manager, error)

func NewListEventFeedsHandler added in v0.7.12 

func NewListEventFeedsHandler(task *v1.Task, helpers listEventFeedsHelpers) *listEventFeedsHandler

func NewListEventsHandler added in v0.7.12 

func NewListEventsHandler(task *v1.Task, helpers listEventsHelpers) *listEventsHandler

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
}

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.