agent

Documentation

Index

• type AgentServer
  • func NewAgentServer(ctx context.Context, opts ...AgentServerOption) *AgentServer
  • func (s *AgentServer) HandleStream(stream grpc.ClientStream) error
  • func (s *AgentServer) StartMetricsProvider()
  • func (s *AgentServer) Target() string
  • func (s *AgentServer) TryConnect() (grpc.ClientStream, error)
• type AgentServerOption
  • func WithMonitorClient(client types.MonitorClient) AgentServerOption
  • func WithSchedulerClient(client types.SchedulerClient) AgentServerOption
  • func WithToolchainFinders(args ...toolchains.FinderWithOptions) AgentServerOption
  • func WithToolchainRunners(args ...run.StoreAddFunc) AgentServerOption
  • func WithUsageLimits(usageLimits *metrics.UsageLimits) AgentServerOption
• type AgentServerOptions
  • func (o *AgentServerOptions) Apply(opts ...AgentServerOption)

Types

type AgentServer

type AgentServer struct {
	metrics.StatusController
	// contains filtered or unexported fields
}

func NewAgentServer

func NewAgentServer(
	ctx context.Context,
	opts ...AgentServerOption,
) *AgentServer

func (*AgentServer) HandleStream

func (s *AgentServer) HandleStream(stream grpc.ClientStream) error

func (*AgentServer) StartMetricsProvider

func (s *AgentServer) StartMetricsProvider()

func (*AgentServer) Target

func (s *AgentServer) Target() string

func (*AgentServer) TryConnect

func (s *AgentServer) TryConnect() (grpc.ClientStream, error)

type AgentServerOption

type AgentServerOption func(*AgentServerOptions)

func WithMonitorClient

func WithMonitorClient(client types.MonitorClient) AgentServerOption

func WithSchedulerClient

func WithSchedulerClient(client types.SchedulerClient) AgentServerOption

func WithToolchainFinders

func WithToolchainFinders(args ...toolchains.FinderWithOptions) AgentServerOption

func WithToolchainRunners

func WithToolchainRunners(args ...run.StoreAddFunc) AgentServerOption

func WithUsageLimits

func WithUsageLimits(usageLimits *metrics.UsageLimits) AgentServerOption

type AgentServerOptions

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

func (*AgentServerOptions) Apply

func (o *AgentServerOptions) Apply(opts ...AgentServerOption)