client

package

v0.1.11 Latest Latest Go to latest Published: Nov 7, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type NodeClient struct {
	Node   *models.Node
	Conn   *grpc.ClientConn
	Client pb.DaemonServiceClient
}

NodeClient wraps a gRPC connection to a daemon

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

Pool manages gRPC connections to multiple daemons

func NewPool(timeout time.Duration) *Pool

NewPool creates a new client pool

func (p *Pool) CheckHealth(ctx context.Context) (map[string]*pb.DaemonStatus, error)

CheckHealth checks the health of all connected nodes

func (p *Pool) Close() error

Close closes all connections

func (p *Pool) Connect(ctx context.Context, node *models.Node) error

Connect establishes a connection to a node

func (p *Pool) ConnectAll(ctx context.Context, nodes []*models.Node) error

ConnectAll establishes connections to all nodes

func (p *Pool) Count() int

Count returns the number of connected clients

func (p *Pool) GetAllClients() []*NodeClient

GetAllClients returns all connected clients

func (p *Pool) GetClient(nodeID string) (*NodeClient, error)

GetClient returns the client for a node

func (p *Pool) Initialize(ctx context.Context, config *pb.InitializeRequest) error

Initialize initializes all connected daemons

func (p *Pool) IsConnected(nodeID string) bool

IsConnected checks if a node is connected

func (p *Pool) StopAll(ctx context.Context) error

StopAll stops all processes on all nodes