query

Documentation

Overview

Package query answers live, on-demand resource reads from the gateway.

It is the pull counterpart to the state collector: nothing is started, nothing is remembered, and no response is cached. The agent stays stateless so its memory footprint does not grow with how much anyone looks at.

Index

• type Executor
  • func New(opts Options) (*Executor, error)
  • func (e *Executor) Execute(ctx context.Context, q *agentv1.ResourceQuery) *agentv1.ResourceQueryResult
• type Options

Types

type Executor

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

Executor answers one ResourceQuery at a time against the Kubernetes API.

func New

func New(opts Options) (*Executor, error)

New builds an Executor.

func (*Executor) Execute

func (e *Executor) Execute(ctx context.Context, q *agentv1.ResourceQuery) *agentv1.ResourceQueryResult

Execute answers one query. It never returns an error: the wire contract is that the agent always replies, so a failure is reported inside the result.

type Options

type Options struct {
	Clients      k8s.QueryClients
	Policy       *policy.Policy
	Logger       *logger.Logger
	Registerer   prometheus.Registerer
	MaxInFlight  int
	MaxQueued    int
	MaxBytes     int
	DefaultLimit int32
}

Options configures an Executor. Only Clients and Policy are required.