cloudtasks

Apr 28, 2024

Changes in this version

+ type TaskFn func(ctx context.Context, task *Task) error

Apr 4, 2024

Changes in this version

type Function

+ func (f *Function) TestCall(t *testing.T, payload interface{}) error

Dec 7, 2023

Changes in this version

type ExternalTask

+ func (task *ExternalTask) LogValue() slog.Value

type Queue

+ SendExternal func(ctx context.Context, task *ExternalTask) error

type Task

+ func (task *Task) LogValue() slog.Value

Dec 2, 2023

Changes in this version

+ type ExternalTask struct

+ Payload any

+ URL string

Nov 28, 2023

Changes in this version

+ var ErrCannotSendTask = errors.New("cloudtasks: cannot send task")

+ type Function struct

+ func Func(key string, h Handler) *Function

+ func (f *Function) Call(ctx context.Context, queue Queue, payload interface{}, opts ...TaskOption) error

+ func (f *Function) CallTask(ctx context.Context, queue Queue, payload interface{}, opts ...TaskOption) (*Task, error)

+ func (f *Function) Task(payload interface{}, opts ...TaskOption) (*Task, error)

+ type Handler func(ctx context.Context, task *Task) error

+ type Queue interface

+ Send func(ctx context.Context, task *Task) error

+ func NewQueue(r router, runProjectHash string, name string, opts ...QueueOption) Queue

+ type QueueOption func(*gcloudQueue)

+ func WithRegion(region string) QueueOption

+ type Task struct

+ Retries int64

+ func (task *Task) Name() string

+ func (task *Task) Read(dest interface{}) error

+ type TaskOption func(task *Task)

+ func WithName(name string) TaskOption