agent

Documentation

Index

• func GetPipelineRunLogReader(workflow, pipeline, runID string, pipelineSpec *v1alpha1.PipelineSpec, ...) (io.Reader, int64, error)
• type Server
  • func NewServer(host string, port uint32, ...) *Server
  • func (s *Server) JoinAPIServer(apiServerAddr, agentName, agentAddr, authToken string) error
  • func (s *Server) RunServer() error
  • func (s *Server) Shutdown()

Functions

func GetPipelineRunLogReader

func GetPipelineRunLogReader(
	workflow, pipeline, runID string,
	pipelineSpec *v1alpha1.PipelineSpec, pipelineStatus *v1alpha1.PipelineRunStatus) (io.Reader, int64, error)

GetPipelineRunLogReader returns a reader to read the logs for a particular pipeline run

Types

type Server

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

Server is the GRPC server for agent running.

func NewServer

func NewServer(host string, port uint32, address, certFile, keyFile, rootCACert,
	jwtSecret string, insecureMode bool) *Server

NewServer returns a new server for agent.

func (*Server) JoinAPIServer

func (s *Server) JoinAPIServer(apiServerAddr, agentName, agentAddr, authToken string) error

JoinAPIServer joins the agent to the pool of servers registered on the API server.

func (*Server) RunServer

func (s *Server) RunServer() error

RunServer starts running the GRPC server for xene agent.

func (*Server) Shutdown

func (s *Server) Shutdown()

Shutdown shuts down the agent GRPC server.