agent

Documentation

Overview

Package agent provides a gRPC client for agent services.

Index

• type Client
  • func NewClient(logger *slog.Logger, cfg Config) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) ReceiveKeyRequests(ctx context.Context, handler KeyRequestHandler) error
  • func (c *Client) StreamFiles(ctx context.Context, rcvr *receiver.Receiver) error
  • func (c *Client) SubmitHealthReports(ctx context.Context, reportChan <-chan health.Report) error
  • func (c *Client) SubmitPublicKeys(ctx context.Context, publicKeys map[string]string) error
• type Config
• type KeyRequestHandler

Types

type Client

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

Client handles authenticated access to the AgentService

func NewClient

func NewClient(logger *slog.Logger, cfg Config) (*Client, error)

NewClient creates a new agent gRPC client wrapper

func (*Client) Close

func (c *Client) Close() error

Close shuts down the underlying gRPC connection

func (*Client) ReceiveKeyRequests

func (c *Client) ReceiveKeyRequests(ctx context.Context, handler KeyRequestHandler) error

ReceiveKeyRequests starts receiving key generation requests from the server

func (*Client) StreamFiles

func (c *Client) StreamFiles(ctx context.Context, rcvr *receiver.Receiver) error

StreamFiles subscribes to server-sent files and writes them using the provided receiver.

func (*Client) SubmitHealthReports

func (c *Client) SubmitHealthReports(ctx context.Context, reportChan <-chan health.Report) error

SubmitHealthReports maintains a persistent stream and sends reports periodically

func (*Client) SubmitPublicKeys

func (c *Client) SubmitPublicKeys(ctx context.Context, publicKeys map[string]string) error

SubmitPublicKeys sends generated public keys to the agent service. Note that Certificates are returned via the StreamFiles RPC.

type Config

type Config struct {
	ServerAddress string
	ServerCACert  x509.Certificate
	ClientCert    *x509.Certificate
	PrivateKey    crypto.PrivateKey
	InstanceID    string
}

Config holds the connection settings for the agent gRPC client

type KeyRequestHandler

type KeyRequestHandler interface {
	HandleKeyRequest(keyNames []string) error
}

KeyRequestHandler is called when the server sends key generation requests