client

package
v0.1.21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 2, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type WSClient

type WSClient struct {
	// contains filtered or unexported fields
}

func NewWSClient

func NewWSClient(serverAddr string, workerID uint, opts ...WSClientOption) *WSClient

func (*WSClient) Close

func (c *WSClient) Close() error

func (*WSClient) Connect

func (c *WSClient) Connect(ctx context.Context) error

func (*WSClient) IsConnected

func (c *WSClient) IsConnected() bool

type WSClientOption

type WSClientOption func(*WSClient)

func WithWorkerID

func WithWorkerID(workerID uint) WSClientOption

type WorkerClient

type WorkerClient struct {
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(ctx context.Context, cfg *WorkerConfig) (*WorkerClient, error)

func (*WorkerClient) GetStartedAt

func (w *WorkerClient) GetStartedAt() time.Time

func (*WorkerClient) GetStatus

func (w *WorkerClient) GetStatus() string

func (*WorkerClient) GetWorkerID

func (w *WorkerClient) GetWorkerID() uint

func (*WorkerClient) Run

func (*WorkerClient) Shutdown

func (w *WorkerClient) Shutdown(ctx context.Context) error

func (*WorkerClient) Start

func (w *WorkerClient) Start(ctx context.Context) error

type WorkerConfig

type WorkerConfig struct {
	Runtime            agent.Runtime
	LLMConfig          *config.LLMConfig
	ServerAddr         string
	DigitalAssistantID uint
	WorkerID           uint
}

Jump to

Keyboard shortcuts

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