scheduler

type CloudTasksClient interface {
	ListTasks(ctx context.Context, req *taskspb.ListTasksRequest, opts ...gax.CallOption) *cloudtasks.TaskIterator
	CreateTask(ctx context.Context, req *taskspb.CreateTaskRequest, opts ...gax.CallOption) (*taskspb.Task, error)
	DeleteTask(ctx context.Context, req *taskspb.DeleteTaskRequest, opts ...gax.CallOption) error
}

type Iterator struct {
	// contains filtered or unexported fields
}

type OAuthToken struct {
	ServiceAccountEmail string
	Scope               string
}

type OIDCToken struct {
	ServiceAccountEmail string
	Audience            string
}

type Scheduler struct {
	// contains filtered or unexported fields
}

type Task struct {
	QueuePath     string
	Prefix        string
	ID            string
	ScheduledAt   time.Time
	Request       *http.Request
	Authorization isAuthorizationToken
	Version       int
}

type TaskIterator interface {
	Next() (*taskspb.Task, error)
	PageInfo() *iterator.PageInfo
}

type TaskLister interface {
	ListTasks(ctx context.Context, req *taskspb.ListTasksRequest, opts ...gax.CallOption) TaskIterator
}

type TaskListerFunc func(ctx context.Context, req *taskspb.ListTasksRequest, opts ...gax.CallOption) *cloudtasks.TaskIterator