stanza_input_operator

package module

v0.0.0-...-7cb0806 Latest Latest Go to latest Published: Apr 3, 2024 License: Apache-2.0 Imports: 15 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubearmor/OTel-receiver

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
- func NewConfig() *Config
- func NewConfigWithID(operatorID string) *Config
- func (cfg Config) Build(logger *zap.SugaredLogger) (operator.Operator, error)
type Feeder
- func NewClient(operator helper.InputOperator, cfg Config) (*Feeder, error)
- func (fd *Feeder) DestroyClient() error
type Input
- func (operator *Input) Start(_ operator.Persister) error
- func (operator *Input) Stop() error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	helper.InputConfig `mapstructure:",squash"`

	Endpoint  string `mapstructure:"endpoint,omitempty"`
	LogFilter string `mapstructure:"logfilter,omitempty"`
}

Config is the configuration of a kubearmor input operator

func NewConfig ¶

func NewConfig() *Config

NewConfig creates a new input config with default values

func NewConfigWithID ¶

func NewConfigWithID(operatorID string) *Config

NewConfigWithID creates a new input config with default values NOTE: The config passed from here gets overwritten by values in the config file. So, override is handled by env variable expansion in collector configuration.

func (Config) Build ¶

func (cfg Config) Build(logger *zap.SugaredLogger) (operator.Operator, error)

Build will build a kubearmor input operator from the supplied configuration

type Feeder ¶

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

Feeder Structure

func NewClient ¶

func NewClient(operator helper.InputOperator, cfg Config) (*Feeder, error)

NewClient Function

func (*Feeder) DestroyClient ¶

func (fd *Feeder) DestroyClient() error

type Input ¶

type Input struct {
	helper.InputOperator
	Config
	// contains filtered or unexported fields
}

Input is an operator that processes kubearmor logs

func (*Input) Start ¶

func (operator *Input) Start(_ operator.Persister) error

Start will start generating log entries.

func (*Input) Stop ¶

func (operator *Input) Stop() error

Stop will stop generating logs.

Source Files ¶

View all Source files

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