agent

Documentation

Index

• func ServeAgent(ctx context.Context, cfg *config.Agent, api *client.Client) error
• type Agent
  • func New(api *client.Client, dclient *docker.Docker, name string) (*Agent, error)
  • func (a *Agent) GetJobs(ctx context.Context, agnt *agent.Agent) error
  • func (a *Agent) HandleJob(ctx context.Context, job *agent.Job) error
  • func (a *Agent) HandleScan(ctx context.Context, sess *scan.Session) error
  • func (a *Agent) Register(ctx context.Context, agnt *agent.Agent) error
  • func (a *Agent) Retrieve(ctx context.Context, agnt *agent.Agent) error
  • func (a *Agent) Serve(ctx context.Context) error
• type RemoteServer
  • func NewRemoteServer(transp transport.Transport, api *client.Client, sess *scan.Session) (*RemoteServer, error)
  • func (s *RemoteServer) Connect(ctx context.Context) error
  • func (s *RemoteServer) DownloadFile(ctx context.Context, fileId string) ([]byte, error)
  • func (s *RemoteServer) GetConfig(ctx context.Context) (*plan.Conf, error)
  • func (s *RemoteServer) GetPluginVersions(ctx context.Context, name string) ([]string, error)
  • func (s *RemoteServer) Handle(ctx context.Context, msg transport.Extractor) (interface{}, error)
  • func (s *RemoteServer) RunPlugin(ctx context.Context, step *plan.WorkflowStep) (*report.Report, error)
  • func (s *RemoteServer) SendReport(ctx context.Context, rep *report.Report) error

Functions

func ServeAgent

func ServeAgent(ctx context.Context, cfg *config.Agent, api *client.Client) error

Types

type Agent

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

func New

func New(api *client.Client, dclient *docker.Docker, name string) (*Agent, error)

func (*Agent) GetJobs

func (a *Agent) GetJobs(ctx context.Context, agnt *agent.Agent) error

func (*Agent) HandleJob

func (a *Agent) HandleJob(ctx context.Context, job *agent.Job) error

func (*Agent) HandleScan

func (a *Agent) HandleScan(ctx context.Context, sess *scan.Session) error

func (*Agent) Register

func (a *Agent) Register(ctx context.Context, agnt *agent.Agent) error

func (*Agent) Retrieve

func (a *Agent) Retrieve(ctx context.Context, agnt *agent.Agent) error

func (*Agent) Serve

func (a *Agent) Serve(ctx context.Context) error

type RemoteServer

type RemoteServer struct {
	Rep *report.Report
	// contains filtered or unexported fields
}

func NewRemoteServer

func NewRemoteServer(transp transport.Transport, api *client.Client, sess *scan.Session) (*RemoteServer, error)

Server connects agent with plugin script

func (*RemoteServer) Connect

func (s *RemoteServer) Connect(ctx context.Context) error

func (*RemoteServer) DownloadFile

func (s *RemoteServer) DownloadFile(ctx context.Context, fileId string) ([]byte, error)

func (*RemoteServer) GetConfig

func (s *RemoteServer) GetConfig(ctx context.Context) (*plan.Conf, error)

func (*RemoteServer) GetPluginVersions

func (s *RemoteServer) GetPluginVersions(ctx context.Context, name string) ([]string, error)

func (*RemoteServer) Handle

func (s *RemoteServer) Handle(ctx context.Context, msg transport.Extractor) (interface{}, error)

func (*RemoteServer) RunPlugin

func (s *RemoteServer) RunPlugin(ctx context.Context, step *plan.WorkflowStep) (*report.Report, error)

func (*RemoteServer) SendReport

func (s *RemoteServer) SendReport(ctx context.Context, rep *report.Report) error