controlclient

package

v0.1.1 Latest Latest Go to latest Published: Oct 21, 2026 License: AGPL-3.0 Imports: 11 Imported by: 0

Details

Package controlclient talks to the coordinator's control service.

This section is empty.

View Source

var ErrUnauthenticated = errors.New("unauthenticated")

ErrUnauthenticated means the coordinator rejected the auth key or token.

This section is empty.

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

Client is a control-plane client.

func New(baseURL string) (*Client, error)

New returns a client for the coordinator at baseURL (http or https).

func (c *Client) Register(ctx context.Context, req *controlv1.RegisterRequest) (*controlv1.RegisterResponse, error)

Register enrolls this node.

func (c *Client) ReportStatus(ctx context.Context, token string, peers []*controlv1.PeerPath) error

ReportStatus reports how this node reaches its peers.

func (c *Client) UpdateEndpoints(ctx context.Context, token string, endpoints []string) error

UpdateEndpoints replaces the endpoints the coordinator advertises for this node.

func (c *Client) Watch(ctx context.Context, token string, msg *controlv1.WatchNetmapRequest, fn func(*controlv1.WatchNetmapResponse) error) error

Watch opens a netmap stream and calls fn for every netmap until the stream ends, ctx is cancelled, or fn returns an error.