flywheel

Aug 25, 2020

Changes in this version

type Manager

+ func (m *Manager) Handler() http.Handler

Aug 19, 2020

Changes in this version

+ const STATUS_COMPLETED

+ const STATUS_CREATED

+ const STATUS_FAILED

+ const STATUS_RUNNING

+ func NewID() string

+ type Manager struct

+ func NewManager(namespace string, opts ...ManagerOption) (*Manager, error)

+ func (m *Manager) CheckIn(ctx context.Context, id string) error

+ func (m *Manager) Complete(ctx context.Context, id string) error

+ func (m *Manager) Fail(ctx context.Context, id, message string) error

+ func (m *Manager) GetTask(ctx context.Context, id string) (*Task, error)

+ func (m *Manager) Log(ctx context.Context, id, message string) error

+ func (m *Manager) Start(ctx context.Context, t *Task) error

+ type ManagerOption func(*Manager)

+ func WithRedis(client *redis.Client) ManagerOption

+ func WithRedisAddress(address string) ManagerOption

+ func WithRedisDatabase(db int) ManagerOption

+ func WithRedisPassword(password string) ManagerOption

+ func WithRedisUsername(username string) ManagerOption

+ func WithTTL(ttl time.Duration) ManagerOption

+ func WithoutRedisPing() ManagerOption

+ type Task struct

+ CheckinAt string

+ CompletedAt string

+ CreatedAt string

+ Events []string

+ FailedAt string

+ Failure string

+ ID string

+ Status string

+ func NewTask() *Task