Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GenerateInput ¶
type GenerateInput struct {
helper.InputOperator
// contains filtered or unexported fields
}
GenerateInput is an operator that generates log entries.
func (*GenerateInput) Start ¶
func (g *GenerateInput) Start() error
Start will start generating log entries.
type GenerateInputConfig ¶
type GenerateInputConfig struct {
helper.InputConfig `yaml:",inline"`
Entry entry.Entry `json:"entry" yaml:"entry"`
Count int `json:"count,omitempty" yaml:"count,omitempty"`
Static bool `json:"static" yaml:"static,omitempty"`
}
GenerateInputConfig is the configuration of a generate input operator.
func NewGenerateInputConfig ¶
func NewGenerateInputConfig(operatorID string) *GenerateInputConfig
func (*GenerateInputConfig) Build ¶
func (c *GenerateInputConfig) Build(context operator.BuildContext) (operator.Operator, error)
Build will build a generate input operator.
type JournaldInput ¶
type JournaldInput struct {
helper.InputOperator
// contains filtered or unexported fields
}
JournaldInput is an operator that process logs using journald
func (*JournaldInput) Start ¶
func (operator *JournaldInput) Start() error
Start will start generating log entries.
func (*JournaldInput) Stop ¶
func (operator *JournaldInput) Stop() error
Stop will stop generating logs.
type JournaldInputConfig ¶
type JournaldInputConfig struct {
helper.InputConfig `yaml:",inline"`
Directory *string `json:"directory,omitempty" yaml:"directory,omitempty"`
Files []string `json:"files,omitempty" yaml:"files,omitempty"`
StartAt string `json:"start_at,omitempty" yaml:"start_at,omitempty"`
}
JournaldInputConfig is the configuration of a journald input operator
func NewJournaldInputConfig ¶
func NewJournaldInputConfig(operatorID string) *JournaldInputConfig
func (JournaldInputConfig) Build ¶
func (c JournaldInputConfig) Build(buildContext operator.BuildContext) (operator.Operator, error)
Build will build a journald input operator from the supplied configuration
type K8sEvents ¶
type K8sEvents struct {
helper.InputOperator
// contains filtered or unexported fields
}
K8sEvents is an operator for generating logs from k8s events
type K8sEventsConfig ¶
type K8sEventsConfig struct {
helper.InputConfig `yaml:",inline"`
Namespaces []string
}
K8sEventsConfig is the configuration of K8sEvents operator
func NewK8sEventsConfig ¶
func NewK8sEventsConfig(operatorID string) *K8sEventsConfig
NewK8sEventsConfig creates a default K8sEventsConfig
func (K8sEventsConfig) Build ¶
func (c K8sEventsConfig) Build(context operator.BuildContext) (operator.Operator, error)
Build will build a k8s_event_input operator from the supplied configuration
type TCPInput ¶
type TCPInput struct {
helper.InputOperator
// contains filtered or unexported fields
}
TCPInput is an operator that listens for log entries over tcp.
type TCPInputConfig ¶
type TCPInputConfig struct {
helper.InputConfig `yaml:",inline"`
ListenAddress string `json:"listen_address,omitempty" yaml:"listen_address,omitempty"`
}
TCPInputConfig is the configuration of a tcp input operator.
func NewTCPInputConfig ¶
func NewTCPInputConfig(operatorID string) *TCPInputConfig
func (TCPInputConfig) Build ¶
func (c TCPInputConfig) Build(context operator.BuildContext) (operator.Operator, error)
Build will build a tcp input operator.
type UDPInput ¶
type UDPInput struct {
helper.InputOperator
// contains filtered or unexported fields
}
UDPInput is an operator that listens to a socket for log entries.
type UDPInputConfig ¶
type UDPInputConfig struct {
helper.InputConfig `yaml:",inline"`
ListenAddress string `json:"listen_address,omitempty" yaml:"listen_address,omitempty"`
}
UDPInputConfig is the configuration of a udp input operator.
func NewUDPInputConfig ¶
func NewUDPInputConfig(operatorID string) *UDPInputConfig
func (UDPInputConfig) Build ¶
func (c UDPInputConfig) Build(context operator.BuildContext) (operator.Operator, error)
Build will build a udp input operator.
Source Files
Directories