out_forward

Documentation

Index

• func Factory() plugin.Plugin
• type AutoConnectWriter
  • func NewAutoConnectWriter(f ConnectFunc, seq sequencer, ackTimeout time.Duration) *AutoConnectWriter
  • func (w *AutoConnectWriter) Close()
  • func (w *AutoConnectWriter) Write(b []byte) (n int, err error)
• type CompatibleMode
  • func (m *CompatibleMode) UnmarshalText(b []byte) (err error)
• type Config
• type ConnectFunc
• type ForwardOutput
  • func (o *ForwardOutput) Close() error
  • func (o *ForwardOutput) Encode(ev *message.Event) (buffer.Sizer, error)
  • func (o *ForwardOutput) Init(env *plugin.Env) (err error)
  • func (o *ForwardOutput) Start() (err error)
  • func (o *ForwardOutput) Write(l []buffer.Sizer) (int, error)
• type RoundRobinWriter
  • func NewRoundRobinWriter(minWeight int) *RoundRobinWriter
  • func (w *RoundRobinWriter) Add(writer io.Writer, weight int)
  • func (w *RoundRobinWriter) Write(b []byte) (n int, err error)

Functions

func Factory

func Factory() plugin.Plugin

Types

type AutoConnectWriter

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

func NewAutoConnectWriter

func NewAutoConnectWriter(f ConnectFunc, seq sequencer, ackTimeout time.Duration) *AutoConnectWriter

func (*AutoConnectWriter) Close

func (w *AutoConnectWriter) Close()

func (*AutoConnectWriter) Write

func (w *AutoConnectWriter) Write(b []byte) (n int, err error)

type CompatibleMode

type CompatibleMode int

const (
	CompatibleDisable CompatibleMode = iota
	CompatibleLegacy
	CompatibleExtend
)

func (*CompatibleMode) UnmarshalText

func (m *CompatibleMode) UnmarshalText(b []byte) (err error)

type Config

type Config struct {
	MinWeight  int             `toml:"min_weight"`
	Compatible CompatibleMode  `toml:"compatible"`
	AckTimeout buffer.Duration `toml:"ack_timeout"`
	Servers    []struct {
		Server string `toml:"server"`
		Weight int    `toml:"weight"`
	} `toml:"servers"`
}

type ConnectFunc

type ConnectFunc func() (net.Conn, error)

type ForwardOutput

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

func (*ForwardOutput) Close

func (o *ForwardOutput) Close() error

func (*ForwardOutput) Encode

func (o *ForwardOutput) Encode(ev *message.Event) (buffer.Sizer, error)

func (*ForwardOutput) Init

func (o *ForwardOutput) Init(env *plugin.Env) (err error)

func (*ForwardOutput) Start

func (o *ForwardOutput) Start() (err error)

func (*ForwardOutput) Write

func (o *ForwardOutput) Write(l []buffer.Sizer) (int, error)

type RoundRobinWriter

type RoundRobinWriter struct {
	ErrorC chan error
	// contains filtered or unexported fields
}

func NewRoundRobinWriter

func NewRoundRobinWriter(minWeight int) *RoundRobinWriter

func (*RoundRobinWriter) Add

func (w *RoundRobinWriter) Add(writer io.Writer, weight int)

func (*RoundRobinWriter) Write

func (w *RoundRobinWriter) Write(b []byte) (n int, err error)