agent

Documentation

Index

• func WithAgentId(agentId string) func(agent *Agent)
• func WithDriver(drv driver.Driver) func(agent *Agent)
• func WithGrpc(grpcUrl string, creds clientcredentials.Config) func(agent *Agent)
• func WithHttpClient(client *http.Client) func(agent *Agent)
• func WithLogger(logger *zap.Logger) func(agent *Agent)
• func WithOrganizationId(organizationId string) func(agent *Agent)
• func WithRunnerImage(runnerImage string, pullPolicy string) func(agent *Agent)
• type Agent
  • func New(options ...func(*Agent)) *Agent
  • func (a *Agent) Run() error
• type AuthInterceptor
  • func NewAuthInterceptor(credentials clientcredentials.Config) *AuthInterceptor
  • func (i *AuthInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc
  • func (i *AuthInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
  • func (i *AuthInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc
• type ChangeSink
  • func (sink ChangeSink) Write(p []byte) (int, error)
• type ChangeSummary
• type ChangeSummaryChange
• type Config
  • func LoadConfig() (*Config, error)
  • func (c *Config) GetAgentId() string
  • func (c *Config) GetImage() string
  • func (c *Config) GetNamespace() string
• type RunnerConfig

Functions

func WithAgentId

func WithAgentId(agentId string) func(agent *Agent)

func WithDriver

func WithDriver(drv driver.Driver) func(agent *Agent)

func WithGrpc

func WithGrpc(grpcUrl string, creds clientcredentials.Config) func(agent *Agent)

TODO: This should be updated to accept clientcredentials.Config to support rotation of expired tokens. For now, we will accept failure

func WithHttpClient

func WithHttpClient(client *http.Client) func(agent *Agent)

func WithLogger

func WithLogger(logger *zap.Logger) func(agent *Agent)

func WithOrganizationId

func WithOrganizationId(organizationId string) func(agent *Agent)

func WithRunnerImage

func WithRunnerImage(runnerImage string, pullPolicy string) func(agent *Agent)

Types

type Agent

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

func New

func New(options ...func(*Agent)) *Agent

func (*Agent) Run

func (a *Agent) Run() error

For now, this just queries the current list of runs, and exits. However, it should query the API (or stream) and emit runners as needed

type AuthInterceptor

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

func NewAuthInterceptor

func NewAuthInterceptor(
	credentials clientcredentials.Config,
) *AuthInterceptor

func (*AuthInterceptor) WrapStreamingClient

func (i *AuthInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

func (*AuthInterceptor) WrapStreamingHandler

func (i *AuthInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

func (*AuthInterceptor) WrapUnary

func (i *AuthInterceptor) WrapUnary(next connect.UnaryFunc) connect.UnaryFunc

type ChangeSink

type ChangeSink struct {
	Sdk   *sdk.Sdk
	RunId string
}

func (ChangeSink) Write

func (sink ChangeSink) Write(p []byte) (int, error)

type ChangeSummary

type ChangeSummary struct {
	Type    string              `json:"type"`
	Changes ChangeSummaryChange `json:"changes"`
}

type ChangeSummaryChange

type ChangeSummaryChange struct {
	Add       int    `json:"add"`
	Change    int    `json:"change"`
	Remove    int    `json:"remove"`
	Import    int    `json:"import"`
	Operation string `json:"operation"`
}

type Config

type Config struct {
	Runner  *RunnerConfig `yaml:"runner,omitempty"`
	AgentId string        `yaml:"agentId"`
}

func LoadConfig

func LoadConfig() (*Config, error)

func (*Config) GetAgentId

func (c *Config) GetAgentId() string

func (*Config) GetImage

func (c *Config) GetImage() string

func (*Config) GetNamespace

func (c *Config) GetNamespace() string

type RunnerConfig

type RunnerConfig struct {
	Image     string `yaml:"image,omitempty"`
	Version   string `yaml:"version,omitempty"`
	Namespace string `yaml:"namespace,omitempty"`
}