Versions in this module Expand all Collapse all v1 v1.0.0 Aug 26, 2026 Changes in this version + const APIKeyIDHeader + const APIKeySecretHeader + var ErrInvalidAPIKey = errors.New("control-plane client: invalid API key") + var ErrInvalidConfiguration = errors.New("control-plane client: invalid configuration") + var ErrInvalidRequest = errors.New("control-plane client: invalid request") + var ErrInvalidResponse = errors.New("control-plane client: invalid response") + var ErrInvalidToken = errors.New("control-plane client: invalid bearer token") + var ErrResponseTooLarge = errors.New("control-plane client: response too large") + type APIError struct + Code string + Status int + func (e *APIError) Error() string + type APIKeySource interface + APIKey func(context.Context) (string, string, error) + type AuditQuery struct + After uint64 + Limit uint32 + type Client struct + func New(config Config) (*Client, error) + func (c *Client) DesiredStateReader(tenant string) (queue.DesiredStateReader, error) + func (c *Client) ExecuteCommand(ctx context.Context, tenant string, command apihttp.CommandRequest) (controlplane.CommandResult, error) + func (c *Client) GetCommand(ctx context.Context, tenant string, key string) (controlplane.CommandResult, error) + func (c *Client) GetDesiredState(ctx context.Context, tenant string, target queue.Target) (queue.DesiredRecord, error) + func (c *Client) InspectDeadLetter(ctx context.Context, tenant string, id string, ...) (apihttp.Record, error) + func (c *Client) InspectDeadLetterWithOptions(ctx context.Context, tenant string, id string, options RecordInspectOptions) (apihttp.Record, error) + func (c *Client) InspectFailure(ctx context.Context, tenant string, id string, ...) (apihttp.Record, error) + func (c *Client) InspectFailureWithOptions(ctx context.Context, tenant string, id string, options RecordInspectOptions) (apihttp.Record, error) + func (c *Client) ListAudit(ctx context.Context, tenant string, query AuditQuery) (apihttp.AuditPage, error) + func (c *Client) ListCommands(ctx context.Context, tenant string, query CommandQuery) (apihttp.CommandHistoryPage, error) + func (c *Client) ListDeadLetters(ctx context.Context, tenant string, query RecordQuery) (apihttp.RecordPage, error) + func (c *Client) ListFailures(ctx context.Context, tenant string, query RecordQuery) (apihttp.RecordPage, error) + func (c *Client) ListQueues(ctx context.Context, tenant string, query QueueQuery) (apihttp.QueuePage, error) + func (c *Client) ListWorkers(ctx context.Context, tenant string, query WorkerQuery) (apihttp.WorkerPage, error) + func (c *Client) ListWorkloads(ctx context.Context, tenant string, query WorkloadQuery) (controlkubernetes.Page, error) + type CommandQuery struct + Cursor string + Limit uint32 + type Config struct + APIKeys APIKeySource + BaseURL string + HTTPClient *http.Client + MaxResponseBytes int64 + Tokens TokenSource + type QueueQuery struct + Cursor string + Limit uint32 + type RecordInspectOptions struct + Payload queue.PayloadVisibility + RevealDiagnostics bool + type RecordQuery struct + Cursor string + Direction queue.SortDirection + Limit uint32 + Search string + Sort queue.SortField + type TokenSource interface + Token func(context.Context) (string, error) + type WorkerQuery struct + After string + Limit uint32 + Queue string + State fleet.State + type WorkloadQuery struct + Continue string + Limit int64
Go to main page