Versions in this module Expand all Collapse all v1 v1.0.1 Aug 28, 2026 v1.0.0 Aug 26, 2026 Changes in this version + const MaxFleetEndpoints + var ErrFleetTargetUnavailable = errors.New("managementhttp: fleet target unavailable") + var ErrFleetUnavailable = errors.New("managementhttp: fleet unavailable") + var ErrInvalidConfiguration = errors.New("management HTTP: invalid configuration") + var ErrInvalidFleetConfiguration = errors.New("managementhttp: invalid fleet configuration") + var ErrInvalidFleetEndpoints = errors.New("managementhttp: invalid fleet endpoints") + var ErrInvalidRequest = errors.New("management HTTP: invalid request") + var ErrInvalidResponse = errors.New("management HTTP: invalid response") + var ErrRemoteFailure = errors.New("management HTTP: remote failure") + var ErrResponseTooLarge = errors.New("management HTTP: response too large") + func NewHandler(config HandlerConfig) (http.Handler, error) + type Client struct + func NewClient(config ClientConfig) (*Client, error) + func (c *Client) Execute(ctx context.Context, request management.Command) (management.CommandResult, error) + func (c *Client) Inspect(ctx context.Context, request management.InspectRequest) (management.JobRecord, error) + func (c *Client) ListDeadLetters(ctx context.Context, request management.PageRequest) (management.RecordPage, error) + func (c *Client) ListFailures(ctx context.Context, request management.PageRequest) (management.RecordPage, error) + func (c *Client) ListQueues(ctx context.Context, request management.StatusPageRequest) (management.QueueStatusPage, error) + func (c *Client) ListWorkers(ctx context.Context, request management.StatusPageRequest) (management.WorkerStatusPage, error) + type ClientConfig struct + BaseURL string + HTTPClient *http.Client + MaxResponseBytes int64 + Token string + type Endpoint struct + BaseURL string + ID string + type EndpointResolver interface + ResolveEndpoints func(context.Context) ([]Endpoint, error) + type EndpointResolverFunc func(context.Context) ([]Endpoint, error) + func (resolve EndpointResolverFunc) ResolveEndpoints(ctx context.Context) ([]Endpoint, error) + type FleetClient struct + func NewFleetClient(config FleetClientConfig) (*FleetClient, error) + func (client *FleetClient) Execute(ctx context.Context, command management.Command) (management.CommandResult, error) + func (client *FleetClient) Inspect(ctx context.Context, request management.InspectRequest) (management.JobRecord, error) + func (client *FleetClient) ListDeadLetters(ctx context.Context, request management.PageRequest) (management.RecordPage, error) + func (client *FleetClient) ListFailures(ctx context.Context, request management.PageRequest) (management.RecordPage, error) + func (client *FleetClient) ListQueues(ctx context.Context, request management.StatusPageRequest) (management.QueueStatusPage, error) + func (client *FleetClient) ListWorkers(ctx context.Context, request management.StatusPageRequest) (management.WorkerStatusPage, error) + type FleetClientConfig struct + HTTPClient *http.Client + MaxResponseBytes int64 + Resolver EndpointResolver + Token string + type HandlerConfig struct + Controller management.Controller + Records management.RecordReader + Status management.StatusReader + Token string
Go to main page