output

Documentation

Index

• func New(o obs.OutputSpec, inputs []string, secrets map[string]*corev1.Secret, ...) []Element
• type Output
  • func NewOutput(spec obs.OutputSpec, secrets map[string]*corev1.Secret, op generator.Options) *Output
  • func (o *Output) AddInputFrom(n nhelpers.InputComponent)
  • func (o *Output) Elements() []generator.Element
  • func (o Output) Inputs() []string
  • func (o Output) VisitAcknowledgements(a common.Acknowledgments) common.Acknowledgments
  • func (o Output) VisitBatch(b common.Batch) common.Batch
  • func (o Output) VisitBuffer(b common.Buffer) common.Buffer
  • func (o Output) VisitRequest(r common.Request) common.Request
  • func (o Output) VisitSink(s common.SinkConfig)

Functions

func New

func New(o obs.OutputSpec, inputs []string, secrets map[string]*corev1.Secret, strategy common.ConfigStrategy, op Options) []Element

Types

type Output

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

Output is an adapter between CLF and Config generation

func NewOutput

func NewOutput(spec obs.OutputSpec, secrets map[string]*corev1.Secret, op generator.Options) *Output

func (*Output) AddInputFrom

func (o *Output) AddInputFrom(n nhelpers.InputComponent)

AddInputFrom adds an input to an output regardless if the "input" originates directly from a log source or pipeline filter

func (*Output) Elements

func (o *Output) Elements() []generator.Element

func (Output) Inputs

func (o Output) Inputs() []string

func (Output) VisitAcknowledgements

func (o Output) VisitAcknowledgements(a common.Acknowledgments) common.Acknowledgments

func (Output) VisitBatch

func (o Output) VisitBatch(b common.Batch) common.Batch

func (Output) VisitBuffer

func (o Output) VisitBuffer(b common.Buffer) common.Buffer

VisitBuffer modifies the buffer behavior depending upon the value of the tuning.Delivery mode

func (Output) VisitRequest

func (o Output) VisitRequest(r common.Request) common.Request

func (Output) VisitSink

func (o Output) VisitSink(s common.SinkConfig)