gcloud

README

gtasks-scheduler

External scheduler using Google Cloud Tasks

Documentation

Index

• Variables
• type DBWorkflow
• type Engine
• type FirestoreEngine
  • func (fs FirestoreEngine) Checkpoint(ctx context.Context, wf DBWorkflow, s async.WorkflowState) func(bool) error
  • func (fs FirestoreEngine) Get(ctx context.Context, id string) (*DBWorkflow, error)
  • func (fs FirestoreEngine) Lock(ctx context.Context, id string) (DBWorkflow, error)
  • func (fs FirestoreEngine) OnCallback(ctx context.Context, req async.CallbackRequest, input interface{}) (interface{}, error)
  • func (fs FirestoreEngine) OnResume(ctx context.Context, id string) error
  • func (fs FirestoreEngine) ScheduleAndCreate(ctx context.Context, id string, s *async.State) error
  • func (fs FirestoreEngine) Unlock(ctx context.Context, id string) error
• type GTasksScheduler
  • func (s *GTasksScheduler) ResumeHandler(w http.ResponseWriter, r *http.Request)
  • func (mgr *GTasksScheduler) Schedule(id string) error
• type Request
• type Scheduler
• type TimeoutHandler
  • func Timeout(dur time.Duration) TimeoutHandler
  • func (t *TimeoutHandler) Handle(req async.CallbackRequest, input interface{}) (interface{}, error)
  • func (t *TimeoutHandler) Type() string
• type TimeoutMgr
  • func (mgr *TimeoutMgr) Setup(req async.CallbackRequest) error
  • func (t *TimeoutMgr) Teardown(req async.CallbackRequest) error
  • func (mgr *TimeoutMgr) TimeoutHandler(w http.ResponseWriter, r *http.Request)

Variables

var TimeoutTypeName = "gsched-timeout"

Types

type DBWorkflow

type DBWorkflow struct {
	Meta     async.State
	State    interface{} // json body of workflow state
	LockTill time.Time   // optimistic locking
}

type Engine

type Engine interface {
	OnResume(ctx context.Context, id string) error
	OnCallback(ctx context.Context, cb async.CallbackRequest, input interface{}) (interface{}, error)
}

type FirestoreEngine

type FirestoreEngine struct {
	DB         *firestore.Client
	Collection string
	Workflows  map[string]func() async.WorkflowState
	// contains filtered or unexported fields
}

func (FirestoreEngine) Checkpoint

func (fs FirestoreEngine) Checkpoint(ctx context.Context, wf DBWorkflow, s async.WorkflowState) func(bool) error

func (FirestoreEngine) Get

func (fs FirestoreEngine) Get(ctx context.Context, id string) (*DBWorkflow, error)

func (FirestoreEngine) Lock

func (fs FirestoreEngine) Lock(ctx context.Context, id string) (DBWorkflow, error)

func (FirestoreEngine) OnCallback

func (fs FirestoreEngine) OnCallback(ctx context.Context, req async.CallbackRequest, input interface{}) (interface{}, error)

func (FirestoreEngine) OnResume

func (fs FirestoreEngine) OnResume(ctx context.Context, id string) error

func (FirestoreEngine) ScheduleAndCreate

func (fs FirestoreEngine) ScheduleAndCreate(ctx context.Context, id string, s *async.State) error

func (FirestoreEngine) Unlock

func (fs FirestoreEngine) Unlock(ctx context.Context, id string) error

type GTasksScheduler

type GTasksScheduler struct {
	C          *cloudtasks.Service
	Collection string
	ProjectID  string
	LocationID string
	QueueName  string
	ResumeURL  string
	// contains filtered or unexported fields
}

func (*GTasksScheduler) ResumeHandler

func (s *GTasksScheduler) ResumeHandler(w http.ResponseWriter, r *http.Request)

func (*GTasksScheduler) Schedule

func (mgr *GTasksScheduler) Schedule(id string) error

type Request

type Request struct {
	ID  string
	Req *async.CallbackRequest
}

type Scheduler

type Scheduler interface {
	Schedule(ctx context.Context, id string) error
	OnCallback(ctx context.Context, cb async.CallbackRequest, input interface{}) (interface{}, error)
}

type TimeoutHandler

type TimeoutHandler struct {
	Delay time.Duration
}

func Timeout

func Timeout(dur time.Duration) TimeoutHandler

func (*TimeoutHandler) Handle

func (t *TimeoutHandler) Handle(req async.CallbackRequest, input interface{}) (interface{}, error)

func (*TimeoutHandler) Type

func (t *TimeoutHandler) Type() string

type TimeoutMgr

type TimeoutMgr struct {
	C           *cloudtasks.Service
	Collection  string
	ProjectID   string
	LocationID  string
	QueueName   string
	CallbackURL string
	// contains filtered or unexported fields
}

func (*TimeoutMgr) Setup

func (mgr *TimeoutMgr) Setup(req async.CallbackRequest) error

func (*TimeoutMgr) Teardown

func (t *TimeoutMgr) Teardown(req async.CallbackRequest) error

func (*TimeoutMgr) TimeoutHandler

func (mgr *TimeoutMgr) TimeoutHandler(w http.ResponseWriter, r *http.Request)