daemon

package

v1.0.0 Latest Latest Go to latest Published: Sep 20, 2025 License: GPL-3.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Client represents a gRPC client for communicating with the Spage daemon

func NewClient(cfg *Config) (*Client, error)

NewClient creates a new gRPC client for daemon communication

func (c *Client) Close() error

Close closes the client and cleans up resources

func (c *Client) CloseStreamsGracefully() error

CloseStreamsGracefully closes the streams gracefully, waiting for any pending data

func (c *Client) Connect() error

Connect establishes a connection to the daemon

func (c *Client) Disconnect() error

Disconnect closes the connection to the daemon

func (c *Client) IsConnected() bool

IsConnected returns whether the client is connected to the daemon

func (c *Client) RegisterPlayCompletion() error

func (c *Client) RegisterPlayError(err error) error

RegisterPlayError registers a play error with the daemon via streaming

func (c *Client) RegisterPlayStart(playbook, inventory string, variables map[string]string, executor string) error

RegisterPlayStart registers the current play with the daemon via streaming

func (c *Client) UpdateTaskResult(taskResult *core.TaskResult) error

UpdateTaskResult sends a task result update to the daemon

func (c *Client) WaitForStreamsToFinish(timeout time.Duration) error

WaitForStreamsToFinish waits for streams to finish processing any pending data

type Config struct {
	Endpoint string
	PlayID   string
	Timeout  time.Duration
}

Config holds the client configuration