Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func NewListEventFeedsHandler ¶ added in v0.7.12
func NewListEventsHandler ¶ added in v0.7.12
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
}
type BootstrappingTaskManager ¶ added in v0.9.1
type BootstrappingTaskManager interface {
tasks.Manager
Bootstrap(ctx context.Context, cc types.ConnectorClient) error
}
Bootstrap performs the startup Hello handshake with exponential backoff, retrying transient failures up to maxHelloBackoff and bailing on ctx cancel or known-permanent gRPC codes (auth, malformed, unimplemented, etc.). The runner is expected to call this exactly once after construction and before entering the task loop.
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, ) (BootstrappingTaskManager, error)
Source Files
¶
- actions.go
- bulk_create_tickets.go
- bulk_get_tickets.go
- c1api.go
- create_account.go
- create_resource.go
- create_ticket.go
- debug.go
- delete_resource.go
- full_sync.go
- get_ticket.go
- grant.go
- hello.go
- list_event_feeds.go
- list_events.go
- list_ticket_schemas.go
- manager.go
- revoke.go
- rotate_credentials.go
- service_client.go
- task_helpers.go
Click to show internal directories.
Click to hide internal directories.