controlplane

Documentation

Index

• type ListRequest
• type Repository
• type Service
  • func New(repo Repository) *Service
  • func (s *Service) Inspect(ctx context.Context, req *controlplane.InspectRequest) (*controlplane.InspectResponse, error)
  • func (s *Service) ListAgents(ctx context.Context, _ *controlplane.ListRequest) (*controlplane.ListAgentsResponse, error)
  • func (s *Service) ListRuns(ctx context.Context, r *controlplane.ListRequest) (*controlplane.ListRunsResponse, error)
  • func (s *Service) Start(ctx context.Context, req *controlplane.StartRequest) (*controlplane.StartResponse, error)
  • func (s *Service) Stats(ctx context.Context, req *controlplane.StatsRequest) (*controlplane.StatsResponse, error)

Types

type ListRequest

type ListRequest struct {
	Start  *time.Time
	Finish *time.Time
	Limit  *uint64
}

ListRequest is a request structure with predicates used to retrieve a list of runs

type Repository

type Repository interface {
	Stats(context.Context) (*adagio.Stats, error)
	StartRun(context.Context, *adagio.GraphSpec) (*adagio.Run, error)
	InspectRun(ctx context.Context, id string) (*adagio.Run, error)
	ListRuns(context.Context, ListRequest) ([]*adagio.Run, error)
	ListAgents(context.Context) ([]*adagio.Agent, error)
}

Repository is an implementation of a backing repository which can report on the status of runs, list runs and agents and start new runs given a graph specification

type Service

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

Service is an adagio control plane server implementation which adapts call to a Repository implementation

func New

func New(repo Repository) *Service

New constructs and configures a new Service instance

func (*Service) Inspect

func (s *Service) Inspect(ctx context.Context, req *controlplane.InspectRequest) (*controlplane.InspectResponse, error)

Inspect adapts a control plane inspect request into a repository InspectRun call and returns the result

func (*Service) ListAgents

func (s *Service) ListAgents(ctx context.Context, _ *controlplane.ListRequest) (*controlplane.ListAgentsResponse, error)

ListAgents adapts a control plane ListRequest into a repository ListAgents call and returns the result

func (*Service) ListRuns

func (s *Service) ListRuns(ctx context.Context, r *controlplane.ListRequest) (*controlplane.ListRunsResponse, error)

ListRuns adapts a control plane list request into a ListRuns call and returns the result

func (*Service) Start

func (s *Service) Start(ctx context.Context, req *controlplane.StartRequest) (*controlplane.StartResponse, error)

Start adapts a control plane start request into a repository Start Run call and returns the result

func (*Service) Stats

func (s *Service) Stats(ctx context.Context, req *controlplane.StatsRequest) (*controlplane.StatsResponse, error)

Stats adapts a controle plane stats request into a repository Stats call and returns the result