agent

type Client interface {
	// Deploy instructs the agent to deploy an artifact on the node.
	Deploy(ctx context.Context, nodeID string, req *DeployRequest) error
	// Stop instructs the agent to stop a running deployment.
	Stop(ctx context.Context, nodeID string, deploymentID string) error
	// GetStatus retrieves the current status of a deployment.
	GetStatus(ctx context.Context, nodeID string, deploymentID string) (*DeploymentStatus, error)
	// StreamLogs streams logs from a deployment in real-time.
	StreamLogs(ctx context.Context, nodeID string, deploymentID string) (<-chan *models.LogEntry, error)
	// Close closes all connections.
	Close() error
}

type ClientConfig struct {
	// TLSConfig for secure connections. If nil, insecure connections are used.
	TLSConfig *tls.Config
	// DialTimeout is the timeout for establishing connections.
	DialTimeout time.Duration
	// RequestTimeout is the default timeout for RPC calls.
	RequestTimeout time.Duration
	// MaxRetries is the maximum number of retry attempts.
	MaxRetries int
	// InitialBackoff is the initial backoff duration for retries.
	InitialBackoff time.Duration
	// MaxBackoff is the maximum backoff duration for retries.
	MaxBackoff time.Duration
	// BackoffMultiplier is the multiplier for exponential backoff.
	BackoffMultiplier float64
}

type DeployRequest struct {
	DeploymentID string
	Artifact     string
	BuildType    models.BuildType
	Config       *models.RuntimeConfig
	Secrets      map[string]string
}

type DeploymentStatus struct {
	DeploymentID string
	Status       models.DeploymentStatus
	Message      string
	StartedAt    *time.Time
	UpdatedAt    time.Time
}

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

type NodeResolver interface {
	// GetNodeAddress returns the gRPC address for a node.
	GetNodeAddress(ctx context.Context, nodeID string) (string, error)
}

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