client

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2026 License: Apache-2.0 Imports: 12 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 (w *WorkerClient) Run(ctx context.Context, req *agent.RequestContext) (*agent.RunResult, error)

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.Runner
	LLMConfig          *config.LLMConfig
	ServerAddr         string
	DigitalAssistantID uint
	WorkerID           uint
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.