agent

Documentation

Index

• type Agent
  • func NewAgent(opts *Options, ml pb.AgentServer, logger logger.Logger) (*Agent, error)
  • func NewLocalAgent(ml pb.AgentServer, logger logger.Logger) (*Agent, error)
  • func (a *Agent) RunJob(ctx context.Context, executorPath string, appID int) (err error)
  • func (a *Agent) SetExecutorLogger(w io.WriteCloser) *Agent
  • func (a *Agent) SetLogger(l logger.Logger)
  • func (a *Agent) SetMetricLogger(ml pb.AgentServer)
  • func (a *Agent) StartSocketServer() error
• type Options

Types

type Agent

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

Agent struct todo: agent needs appID

func NewAgent

func NewAgent(opts *Options, ml pb.AgentServer, logger logger.Logger) (*Agent, error)

func NewLocalAgent

func NewLocalAgent(ml pb.AgentServer, logger logger.Logger) (*Agent, error)

func (*Agent) RunJob

func (a *Agent) RunJob(ctx context.Context, executorPath string, appID int) (err error)

RunJob runs the executor in a shell

func (*Agent) SetExecutorLogger

func (a *Agent) SetExecutorLogger(w io.WriteCloser) *Agent

SetExecutorLogger sets executor log writer property

func (*Agent) SetLogger

func (a *Agent) SetLogger(l logger.Logger)

SetLogger set the logger property

func (*Agent) SetMetricLogger

func (a *Agent) SetMetricLogger(ml pb.AgentServer)

SetMetricLogger sets metric logger property

func (*Agent) StartSocketServer

func (a *Agent) StartSocketServer() error

StartSocketServer setup an rpc server over agent unix socket the function runs the server in a separate routine

type Options

type Options struct {
	Route       string
	ClusterPort int
	Socket      string
}