Help us shape the future of Go! Take the 2026 Go Developer Survey

apiserver

package
v0.49.1 Latest Latest
Warning

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

Go to latest
Published: Oct 21, 2026 License: Apache-2.0 Imports: 35 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" mapstructure:"targets"`
	Subscriptions       map[string]*types.SubscriptionConfig `json:"subscriptions" mapstructure:"subscriptions"`
	Outputs             map[string]map[string]any            `json:"outputs" mapstructure:"outputs"`
	Inputs              map[string]map[string]any            `json:"inputs" mapstructure:"inputs"`
	Processors          map[string]map[string]any            `json:"processors" mapstructure:"processors"`
	TunnelTargetMatches map[string]*config.TunnelTargetMatch `json:"tunnel-target-matches" mapstructure:"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