agent

package
v0.0.0-...-211e212 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 28, 2021 License: GPL-3.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL