gasync

package module

Go to main page

Versions in this module

v0

v0.1.7

Aug 26, 2021

v0.1.6

Aug 18, 2021

Changes in this version

+ type ErrValidate struct

+ Message string

+ Path string

+ func ValidateErr(path, format string, params ...interface{}) ErrValidate

+ func (e ErrValidate) Error() string

type FirestoreEngine

+ func (fs FirestoreEngine) Save(ctx context.Context, wf *DBWorkflow, s *async.WorkflowState, unlock bool) error

type ReflectEvent

+ Role string

v0.1.4

Jul 30, 2021

Changes in this version

+ func SwaggerDoc(host string, wfName string, wf func() async.WorkflowState) (interface{}, error)

v0.1.3

Jul 30, 2021

v0.1.2

Jul 30, 2021

Changes in this version

type Config

+ SignSecret string

type GTasksScheduler

+ Secret string

type ResumeRequest

+ Signature string

+ func (req ResumeRequest) HMAC(secret []byte) string

type Server

+ Scheduler *GTasksScheduler

+ func (s *Server) Timeout(dur time.Duration) *TimeoutHandler

+ type TimeoutReq struct

+ Req async.CallbackRequest

+ Signature string

+ func (req TimeoutReq) HMAC(secret []byte) string

v0.1.1

Jul 29, 2021

Changes in this version

+ func Event(name string, handler interface{}, ss ...async.Stmt) async.Event

+ func SwaggerDocs(workflows map[string]func() async.WorkflowState) (interface{}, error)

+ type Config struct

+ BasePublicURL string

+ CORS bool

+ Collection string

+ GCloudLocationID string

+ GCloudProjectID string

+ GCloudTasksQueueName string

+ type DBWorkflow struct

+ LockTill time.Time

+ Meta async.State

+ Sampling100 bool

+ Sampling10000 bool

+ Sampling1000000 bool

+ State interface{}

+ type DBWorkflowLog struct

+ Callback *async.CallbackRequest

+ ExecDuration time.Duration

+ Input interface{}

+ Meta async.State

+ Output interface{}

+ Sampling100 bool

+ Sampling10000 bool

+ Sampling1000000 bool

+ State interface{}

+ Time time.Time

+ type Empty struct

+ type FirestoreEngine struct

+ Collection string

+ DB *firestore.Client

+ Scheduler *GTasksScheduler

+ Workflows map[string]func() async.WorkflowState

+ 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) HandleCallback(ctx context.Context, id string, cb async.CallbackRequest, input interface{}) (interface{}, error)

+ func (fs FirestoreEngine) HandleEvent(ctx context.Context, id string, name string, input interface{}) (interface{}, error)

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

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

+ func (fs FirestoreEngine) ScheduleAndCreate(ctx context.Context, id, name string, state interface{}) error

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

+ type GTasksScheduler struct

+ C *cloudtasks.Service

+ CallbackURL string

+ Collection string

+ Engine *FirestoreEngine

+ LocationID string

+ ProjectID string

+ QueueName string

+ ResumeURL string

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

+ func (mgr *GTasksScheduler) Schedule(ctx context.Context, id string) error

+ func (mgr *GTasksScheduler) Setup(ctx context.Context, req async.CallbackRequest, del time.Duration) (string, error)

+ func (mgr *GTasksScheduler) Teardown(ctx context.Context, req async.CallbackRequest, handled bool) error

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

+ func (t *GTasksScheduler) Timeout(dur time.Duration) *TimeoutHandler

+ type GTasksSchedulerData struct

+ ID string

+ type GraphCtx struct

+ Break []string

+ Parent string

+ Prev []string

+ type Grapher struct

+ func (g *Grapher) AddEdge(from string, to string)

+ func (g *Grapher) AddEdges(from []string, to string)

+ func (g *Grapher) Dot(s async.Stmt) string

+ func (g *Grapher) Walk(s async.Stmt, ctx GraphCtx) GraphCtx

+ type ReflectEvent struct

+ Handler interface{}

+ func (h *ReflectEvent) Handle(ctx context.Context, req async.CallbackRequest, input interface{}) (interface{}, error)

+ func (h ReflectEvent) InputSchema() ([]byte, error)

+ func (h ReflectEvent) MarshalJSON() ([]byte, error)

+ func (h ReflectEvent) Schemas() (in *jsonschema.Schema, out *jsonschema.Schema, err error)

+ func (t *ReflectEvent) Setup(ctx context.Context, req async.CallbackRequest) (string, error)

+ func (t *ReflectEvent) Teardown(ctx context.Context, req async.CallbackRequest, handled bool) error

+ type ResumeRequest struct

+ ID string

+ type Server struct

+ Engine *FirestoreEngine

+ Router *mux.Router

+ func NewServer(cfg Config, workflows map[string]func() async.WorkflowState) (*Server, error)

+ func (s Server) SimpleEventHandler(w http.ResponseWriter, r *http.Request)

+ type TimeoutHandler struct

+ Duration time.Duration

+ func (s TimeoutHandler) MarshalJSON() ([]byte, error)

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

+ func (t *TimeoutHandler) Setup(ctx context.Context, req async.CallbackRequest) (string, error)

+ func (t *TimeoutHandler) Teardown(ctx context.Context, req async.CallbackRequest, handled bool) error

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