Versions in this module Expand all Collapse all v0 v0.1.1 Jun 17, 2022 Changes in this version + var ModuleName = dep.Name("wk", "task") + func Module() dep.Module + type Api struct + func (a *Api) CancelTask(ctx context.Context, request *CancelTaskRequest) (*CancelTaskResponse, error) + func (a *Api) CreateTask(ctx context.Context, request *CreateTaskRequest) (*CreateTaskResponse, error) + type Bucket struct + func (b *Bucket) HasSlot() bool + func (b *Bucket) Reserve() (bool, SlotReleaser) + type CancelTaskRequest struct + TaskID xid.ID + type CancelTaskResponse struct + type Client struct + func (c *Client) Run(ctx context.Context, name string, args any) (xid.ID, error) + func (c *Client) RunSync(ctx context.Context, name string, args any) (any, error) + type CreateTaskRequest struct + Args interface{} + ContentType string + Name string + type CreateTaskResponse struct + TaskID xid.ID + type SlotReleaser func() v0.1.0 Jun 16, 2022 Changes in this version + type Manifest struct + Name string + Payload []byte + PayloadType string + func MarshallJSON(name string, args any) (*Manifest, error) + func MarshallMsgPack(name string, args any) (*Manifest, error) + func (m *Manifest) Unmarshal(v any) error
Go to main page