daemonclient

Documentation

Overview

Package daemonclient is a wrapper around a grpc client to talk to turbod

Index

• type DaemonClient
  • func New(client *connector.Client) *DaemonClient
  • func (d *DaemonClient) GetChangedOutputs(ctx context.Context, hash string, repoRelativeOutputGlobs []string) ([]string, int, error)
  • func (d *DaemonClient) NotifyOutputsWritten(ctx context.Context, hash string, repoRelativeOutputGlobs hash.TaskOutputs, ...) error
  • func (d *DaemonClient) Status(ctx context.Context) (*Status, error)
• type Status

Types

type DaemonClient

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

DaemonClient provides access to higher-level functionality from the daemon to a turbo run.

func New

func New(client *connector.Client) *DaemonClient

New creates a new instance of a DaemonClient.

func (*DaemonClient) GetChangedOutputs

func (d *DaemonClient) GetChangedOutputs(ctx context.Context, hash string, repoRelativeOutputGlobs []string) ([]string, int, error)

GetChangedOutputs implements runcache.OutputWatcher.GetChangedOutputs

func (*DaemonClient) NotifyOutputsWritten

func (d *DaemonClient) NotifyOutputsWritten(ctx context.Context, hash string, repoRelativeOutputGlobs hash.TaskOutputs, timeSaved int) error

NotifyOutputsWritten implements runcache.OutputWatcher.NotifyOutputsWritten

func (*DaemonClient) Status

func (d *DaemonClient) Status(ctx context.Context) (*Status, error)

Status returns the DaemonStatus from the daemon

type Status

type Status struct {
	UptimeMs uint64                       `json:"uptimeMs"`
	LogFile  turbopath.AbsoluteSystemPath `json:"logFile"`
	PidFile  turbopath.AbsoluteSystemPath `json:"pidFile"`
	SockFile turbopath.AbsoluteSystemPath `json:"sockFile"`
}

Status provides details about the daemon's status