agent

Documentation

Index

• func AddAPIKeyMeta(ctx context.Context, apiKey string) context.Context
• func NewGRPCConnection(ctx context.Context, isInsecure bool, server string, logger *zap.SugaredLogger) (*grpc.ClientConn, error)
• type Agent
  • func NewAgent(logger *zap.SugaredLogger, handler fasthttp.RequestHandler, apiKey string, ...) (*Agent, error)
  • func (ag *Agent) Events() []testkube.EventType
  • func (ag *Agent) Kind() string
  • func (ag *Agent) Load() (listeners common.Listeners, err error)
  • func (ag *Agent) Metadata() map[string]string
  • func (ag *Agent) Name() string
  • func (ag *Agent) Notify(event testkube.Event) (result testkube.EventResult)
  • func (ag *Agent) Run(ctx context.Context) error
  • func (ag *Agent) Selector() string

Functions

func AddAPIKeyMeta

func AddAPIKeyMeta(ctx context.Context, apiKey string) context.Context

func NewGRPCConnection

func NewGRPCConnection(ctx context.Context, isInsecure bool, server string, logger *zap.SugaredLogger) (*grpc.ClientConn, error)

Types

type Agent

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

func NewAgent

func NewAgent(logger *zap.SugaredLogger,
	handler fasthttp.RequestHandler,
	apiKey string,
	client cloud.TestKubeCloudAPIClient,
	workerCount int,
	logStreamWorkerCount int,
	logStreamFunc func(ctx context.Context, executionID string) (chan output.Output, error),
	clusterID string,
	clusterName string,
	envs map[string]string,
) (*Agent, error)

func (*Agent) Events

func (ag *Agent) Events() []testkube.EventType

func (*Agent) Kind

func (ag *Agent) Kind() string

func (*Agent) Load

func (ag *Agent) Load() (listeners common.Listeners, err error)

func (*Agent) Metadata

func (ag *Agent) Metadata() map[string]string

func (*Agent) Name

func (ag *Agent) Name() string

func (*Agent) Notify

func (ag *Agent) Notify(event testkube.Event) (result testkube.EventResult)

func (*Agent) Run

func (ag *Agent) Run(ctx context.Context) error

func (*Agent) Selector

func (ag *Agent) Selector() string