agent

Documentation

Index

• type Service
  • func NewService(s storage.Storage) *Service
  • func (s Service) Actions(ctx context.Context, cmd *pb.ReadActions) (*pb.ActionsRead, error)
  • func (s Service) Ready() error
  • func (s Service) Results(ctx context.Context, cmd *pb.ReturnResult) (*pb.ResultReturned, error)
  • func (s Service) Run(ctx context.Context, cmd *pb.Action) (*pb.Result, error)

Types

type Service

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

Service is the implementation for twirp to use

func NewService

func NewService(s storage.Storage) *Service

NewService creates the new service with dependencies

func (Service) Actions

func (s Service) Actions(ctx context.Context, cmd *pb.ReadActions) (*pb.ActionsRead, error)

Actions gets the next action for the agent or an empty list if there's nothing to do

func (Service) Ready

func (s Service) Ready() error

Ready implements the ReadyService method so this service can be part of a health check routine

func (Service) Results

func (s Service) Results(ctx context.Context, cmd *pb.ReturnResult) (*pb.ResultReturned, error)

Results returns a result for this agent

func (Service) Run

func (s Service) Run(ctx context.Context, cmd *pb.Action) (*pb.Result, error)

Run runs an action and returns a result from a particular agent