ws

Jun 7, 2026

Changes in this version

type Client

+ func (c *Client) SetOnConnected(f func())

type Handler

+ func (h *Handler) SetDisableAutoUpdate(disabled bool)

Apr 24, 2026

Changes in this version

+ const DefaultMaxReconnectAttempts

type Client

+ func (c *Client) EnvironmentID() string

Mar 23, 2026

Changes in this version

+ type Client struct

+ func NewClient(token, apiURL, workspaceRoot string, handler MessageHandler, version string) *Client

+ func (c *Client) Close() error

+ func (c *Client) Connect(ctx context.Context) error

+ func (c *Client) Labels() []string

+ func (c *Client) Name() string

+ func (c *Client) Run(ctx context.Context) error

+ func (c *Client) RunWithReconnect(ctx context.Context) error

+ func (c *Client) Send(msg *protocol.Message) error

+ func (c *Client) SendPayload(msgType protocol.MessageType, payload any) error

+ func (c *Client) WorknodeID() string

+ type Handler struct

+ func NewHandler(ws *workspace.Workspace) *Handler

+ func (h *Handler) CancelAllTasks()

+ func (h *Handler) Handle(ctx context.Context, msg *protocol.Message) error

+ func (h *Handler) RunningTaskCount() int

+ func (h *Handler) SetClient(client *Client)

+ func (h *Handler) WaitForTasks(timeout time.Duration) bool

+ type MessageHandler func(ctx context.Context, msg *protocol.Message) error