Versions in this module Expand all Collapse all v1 v1.0.0 Jun 19, 2026 Changes in this version + const ACLAllow + const ACLForbid + const ACLHide + const DefaultPollInterval + const DefaultRealtimeTokenExpiration + const DefaultTimeout + const Expire1d + const Expire1h + const Expire1y + const Expire30d + const Expire7d + const ExpireImmediate + const ExpireNever + const FormatJPEG + const FormatPNG + const PriorityLow + const PriorityNormal + const Version + var OnEnqueue = option.OnEnqueue + var OnQueueUpdate = option.OnQueueUpdate + var WithClientTimeout = option.WithClientTimeout + var WithDecodeMessage = option.WithDecodeMessage + var WithEncodeMessage = option.WithEncodeMessage + var WithFallbackRepository = option.WithFallbackRepository + var WithHeaders = option.WithHeaders + var WithHint = option.WithHint + var WithInterval = option.WithInterval + var WithJWT = option.WithJWT + var WithLifecycle = option.WithLifecycle + var WithLogs = option.WithLogs + var WithMaxBuffering = option.WithMaxBuffering + var WithPath = option.WithPath + var WithPriority = option.WithPriority + var WithRepository = option.WithRepository + var WithStartTimeout = option.WithStartTimeout + var WithTimeout = option.WithTimeout + var WithTokenExpiration = option.WithTokenExpiration + var WithWebhookURL = option.WithWebhookURL + func As[T any](result any) (T, error) + func Cancel(ctx context.Context, application, requestID string) error + func Encode(data []byte, contentType string) string + func EncodeFile(path string) (string, error) + func EncodeImage(img image.Image, format ImageFormat) (string, error) + func Result(ctx context.Context, application, requestID string) (any, error) + func Run(ctx context.Context, application string, arguments any, opts ...RunOption) (any, error) + func Stream(ctx context.Context, application string, arguments any, opts ...StreamOption) iter.Seq2[map[string]any, error] + func Subscribe(ctx context.Context, application string, arguments any, ...) (any, error) + func Upload(ctx context.Context, data []byte, contentType, fileName string, ...) (string, error) + func UploadFile(ctx context.Context, path string, opts ...UploadOption) (string, error) + func UploadImage(ctx context.Context, img image.Image, format ImageFormat, opts ...UploadOption) (string, error) + func WSConnect(ctx context.Context, application string, opts ...RealtimeOption) (*websocket.Conn, error) + type AppID = appid.AppID + func ParseAppID(endpoint string) (AppID, error) + type Client struct + func Default() *Client + func New(opts ...ClientOption) *Client + func (c *Client) Cancel(ctx context.Context, application, requestID string) error + func (c *Client) GetHandle(application, requestID string) (*RequestHandle, error) + func (c *Client) Realtime(ctx context.Context, application string, opts ...RealtimeOption) (*RealtimeConnection, error) + func (c *Client) Result(ctx context.Context, application, requestID string) (any, error) + func (c *Client) Run(ctx context.Context, application string, arguments any, opts ...RunOption) (any, error) + func (c *Client) Status(ctx context.Context, application, requestID string, withLogs bool) (Status, error) + func (c *Client) Stream(ctx context.Context, application string, arguments any, opts ...StreamOption) iter.Seq2[map[string]any, error] + func (c *Client) Submit(ctx context.Context, application string, arguments any, opts ...SubmitOption) (*RequestHandle, error) + func (c *Client) Subscribe(ctx context.Context, application string, arguments any, ...) (any, error) + func (c *Client) Upload(ctx context.Context, data []byte, contentType, fileName string, ...) (string, error) + func (c *Client) UploadFile(ctx context.Context, path string, opts ...UploadOption) (string, error) + func (c *Client) UploadImage(ctx context.Context, img image.Image, format ImageFormat, opts ...UploadOption) (string, error) + func (c *Client) WSConnect(ctx context.Context, application string, opts ...RealtimeOption) (*websocket.Conn, error) + type ClientOption func(*config) + func WithDefaultTimeout(d time.Duration) ClientOption + func WithHTTPClient(h *http.Client) ClientOption + func WithKey(key string) ClientOption + type Completed = status.Completed + type Error = errs.Error + type HTTPError = errs.HTTPError + type ImageFormat = encode.ImageFormat + type InProgress = status.InProgress + type MissingCredentialsError = errs.MissingCredentialsError + type ObjectExpiration = storage.ObjectExpiration + type Queued = status.Queued + type RealtimeConnection = realtime.Connection + func Realtime(ctx context.Context, application string, opts ...RealtimeOption) (*RealtimeConnection, error) + type RealtimeError = realtime.Error + type RealtimeOption = option.RealtimeOption + type RequestHandle = queue.Handle + func GetHandle(application, requestID string) (*RequestHandle, error) + func Submit(ctx context.Context, application string, arguments any, opts ...SubmitOption) (*RequestHandle, error) + type RunOption = option.RunOption + type Status = status.Status + func StatusOf(ctx context.Context, application, requestID string, withLogs bool) (Status, error) + type StorageACL = storage.ACL + type StorageACLDecision = storage.ACLDecision + type StorageACLRule = storage.ACLRule + type StorageSettings = storage.Settings + type StreamOption = option.StreamOption + type SubmitOption = option.SubmitOption + type SubscribeOption = option.SubscribeOption + type TimeoutError = errs.TimeoutError + type UploadOption = option.UploadOption
Go to main page