apiserver

package
v0.44.1 Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type APIErrors

type APIErrors struct {
	Errors []string `json:"errors,omitempty"`
}

type ConfigApplyRequest

type ConfigApplyRequest struct {
	Targets             map[string]*types.TargetConfig       `json:"targets"`
	Subscriptions       map[string]*types.SubscriptionConfig `json:"subscriptions"`
	Outputs             map[string]map[string]any            `json:"outputs"`
	Inputs              map[string]map[string]any            `json:"inputs"`
	Processors          map[string]map[string]any            `json:"processors"`
	TunnelTargetMatches map[string]*config.TunnelTargetMatch `json:"tunnel-target-matches"`
}

Apply request is a request to apply the configuration to the collector. Any object that is not provided in the request is deleted.

type ProcessorConfigRequest

type ProcessorConfigRequest struct {
	Name   string `json:"name"`
	Type   string `json:"type"`
	Config any    `json:"config"`
}

type ProcessorConfigResponse

type ProcessorConfigResponse struct {
	Name   string `json:"name"`
	Type   string `json:"type"`
	Config any    `json:"config"`
}

type Server

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

func NewServer

func NewServer(
	store *collstore.Store,
	targetManager *targets_manager.TargetsManager,
	outputsManager *outputs_manager.OutputsManager,
	inputsManager *inputs_manager.InputsManager,
	clusterManager *cluster_manager.ClusterManager,
	reg *prometheus.Registry,
) *Server

func (*Server) Start

func (s *Server) Start(locker lockers.Locker, wg *sync.WaitGroup) error

func (*Server) Stop

func (s *Server) Stop()

type SubscriptionResponse

type SubscriptionResponse struct {
	Name    string                      `json:"name"`
	Config  *types.SubscriptionConfig   `json:"config"`
	Targets map[string]*TargetStateInfo `json:"targets"`
}

SubscriptionResponse represents a subscription with its targets and states

type TargetResponse

type TargetResponse struct {
	Name   string                 `json:"name"`
	Config *types.TargetConfig    `json:"config"`
	State  *collstore.TargetState `json:"state,omitempty"`
}

type TargetStateInfo

type TargetStateInfo struct {
	Name  string `json:"name"`
	State string `json:"state"`
}

TargetStateInfo represents target information for a subscription

Jump to

Keyboard shortcuts

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