Versions in this module Expand all Collapse all v0 v0.1.1 Aug 24, 2023 v0.1.0 Aug 9, 2023 Changes in this version + const TimecraftAddress + type Client struct + func NewClient() (*Client, error) + func (c *Client) DiscardTasks(ctx context.Context, taskIDs []TaskID) error + func (c *Client) Kill(ctx context.Context, processID ProcessID) error + func (c *Client) Logger() *log.Logger + func (c *Client) LookupTasks(ctx context.Context, taskIDs []TaskID) ([]TaskResponse, error) + func (c *Client) PollTasks(ctx context.Context, batchSize int, timeout time.Duration) ([]TaskResponse, error) + func (c *Client) ProcessID(ctx context.Context) (ProcessID, error) + func (c *Client) Spawn(ctx context.Context, module ModuleSpec) (ProcessID, netip.Addr, error) + func (c *Client) SubmitTasks(ctx context.Context, requests []TaskRequest) ([]TaskID, error) + func (c *Client) Version(ctx context.Context) (string, error) + type HTTPRequest struct + Body []byte + Headers http.Header + Method string + Path string + Port int + type HTTPResponse struct + Body []byte + Headers http.Header + StatusCode int + type ModuleSpec struct + Args []string + Env []string + Function string + OutboundProxy *ModuleSpec + Path string + type ProcessID string + type TaskID string + type TaskInput interface + type TaskOutput interface + type TaskRequest struct + Input TaskInput + Module ModuleSpec + type TaskResponse struct + Error error + ID TaskID + Output TaskOutput + ProcessID ProcessID + State TaskState + type TaskState int + const Error + const Executing + const Initializing + const Queued + const Success