Documentation
¶
Overview ¶
package fluentd provides a fluentd receiver for use in e2e forwarding tests.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Receiver ¶
type Receiver struct {
Name string
Sources map[string]*Source
Pod *corev1.Pod
ConfigMap *corev1.ConfigMap
// contains filtered or unexported fields
}
Receiver is a service running fluentd, listening on on one or more source ports.
func NewReceiver ¶
NewReceiver returns a receiver with no sources. Use AddSource() before calling Create().
func (*Receiver) ConfigPath ¶
ConfigPath returns a path relative to the configuration dir.
type Source ¶
type Source struct {
// Name for the source in the Receiver's Source map, must be unique per receiver.
Name string
// Type is the Fluentd source @type parameter, normally "forward".
Type string
// Port is the listening port for this source.
Port int
// Cert enables sources as TLS servers.
Cert *certificate.CertKey
// CA enables client verification using this CA.
CA *certificate.CertKey
SharedKey string
// contains filtered or unexported fields
}
Source represents a fluentd listening port and output file.
func (*Source) HasOutput ¶
HasOutput returns true if the source's output file exists and is non empty.
func (*Source) TailReader ¶
TailReader returns a CmdReader that tails the source's log stream. Will fail if called before Receiver.Create() has returned.
It waits for the file to exist, and will tail the output file forever, so it won't normally return io.EOF.
Source Files
Click to show internal directories.
Click to hide internal directories.