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

funcNewClient¶

func NewClient(ctxcontext.Context, opts ...Option) (*Client,error)

NewClient creates a new socket client and opens a connection to the socket.If path is not provided via WithPath or is empty, it will auto-discover thedefault socket path.

func (*Client)Close¶

func (c *Client) Close()error

Close closes the socket connection.

func (*Client)Ping¶

func (c *Client) Ping(ctxcontext.Context)error

Ping sends a ping request to the agent.

func (*Client)SyncComplete¶

func (c *Client) SyncComplete(ctxcontext.Context, unitNameunit.ID)error

SyncComplete marks a unit as complete in the dependency graph.

func (*Client)SyncReady¶

func (c *Client) SyncReady(ctxcontext.Context, unitNameunit.ID) (bool,error)

SyncReady requests whether a unit is ready to be started. That is, all dependencies are satisfied.

func (*Client)SyncStart¶

func (c *Client) SyncStart(ctxcontext.Context, unitNameunit.ID)error

SyncStart starts a unit in the dependency graph.

func (*Client)SyncStatus¶

func (c *Client) SyncStatus(ctxcontext.Context, unitNameunit.ID) (SyncStatusResponse,error)

SyncStatus gets the status of a unit and its dependencies.

func (*Client)SyncWant¶

func (c *Client) SyncWant(ctxcontext.Context, unitName, dependsOnunit.ID)error

SyncWant declares a dependency between units.

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

func (*DRPCAgentSocketService)Ping¶

func (*DRPCAgentSocketService) Ping(_context.Context, _ *proto.PingRequest) (*proto.PingResponse,error)

Ping responds to a ping request to check if the service is alive.

func (*DRPCAgentSocketService)SyncComplete¶

func (s *DRPCAgentSocketService) SyncComplete(_context.Context, req *proto.SyncCompleteRequest) (*proto.SyncCompleteResponse,error)

SyncComplete marks a unit as complete in the dependency graph.

func (*DRPCAgentSocketService)SyncReady¶

func (s *DRPCAgentSocketService) SyncReady(_context.Context, req *proto.SyncReadyRequest) (*proto.SyncReadyResponse,error)

SyncReady checks whether a unit is ready to be started. That is, all dependencies are satisfied.

func (*DRPCAgentSocketService)SyncStart¶

func (s *DRPCAgentSocketService) SyncStart(_context.Context, req *proto.SyncStartRequest) (*proto.SyncStartResponse,error)

SyncStart starts a unit in the dependency graph.

func (*DRPCAgentSocketService)SyncStatus¶

func (s *DRPCAgentSocketService) SyncStatus(_context.Context, req *proto.SyncStatusRequest) (*proto.SyncStatusResponse,error)

SyncStatus gets the status of a unit and lists its dependencies.

func (*DRPCAgentSocketService)SyncWant¶

func (s *DRPCAgentSocketService) SyncWant(_context.Context, req *proto.SyncWantRequest) (*proto.SyncWantResponse,error)

SyncWant declares a dependency between units.

type DependencyInfo struct {DependsOnunit.ID     `table:"depends on,default_sort" json:"depends_on"`RequiredStatusunit.Status `table:"required status" json:"required_status"`CurrentStatusunit.Status `table:"current status" json:"current_status"`IsSatisfiedbool        `table:"satisfied" json:"is_satisfied"`}

type Option func(*options)

funcWithPath¶

func WithPath(pathstring)Option

WithPath sets the socket path. If not provided or empty, the client willauto-discover the default socket path.

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

funcNewServer¶

func NewServer(loggerslog.Logger, opts ...Option) (*Server,error)

NewServer creates a new agent socket server.

func (*Server)Close¶

func (s *Server) Close()error

Close stops the server and cleans up resources.

type SyncStatusResponse struct {UnitNameunit.ID          `table:"unit,default_sort" json:"unit_name"`Statusunit.Status      `table:"status" json:"status"`IsReadybool             `table:"ready" json:"is_ready"`Dependencies []DependencyInfo `table:"dependencies" json:"dependencies"`}