tasks

package
v0.1.35 Latest Latest
Warning

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

Go to latest
Published: May 9, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Is

func Is(task *v1.Task, target TaskType) bool

Types

type Manager

type Manager interface {
	Next(ctx context.Context) (*v1.Task, time.Duration, error)
	Process(ctx context.Context, task *v1.Task, cc types.ConnectorClient) error
}

type TaskHandler

type TaskHandler interface {
	HandleTask(ctx context.Context) error
}

type TaskType

type TaskType uint8
const (
	UnknownType TaskType = iota
	NoneType
	FullSyncType
	GrantType
	RevokeType
	HelloType
	CreateAccountType
	CreateResourceType
	DeleteResourceType
	RotateCredentialsType
	EventFeedType
)

func GetType

func GetType(task *v1.Task) TaskType

func (TaskType) String

func (tt TaskType) String() string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL