nativelog

Documentation

Index

• Constants
• type Forwarder
  • func (f *Forwarder) DefaultConfig() string
  • func (f *Forwarder) Description() string
  • func (f *Forwarder) Forward(batch event.BatchEvents) error
  • func (f *Forwarder) ForwardType() v1.SniffType
  • func (f *Forwarder) Name() string
  • func (f *Forwarder) Prepare(connection interface{}) error
  • func (f *Forwarder) ShowName() string
  • func (f *Forwarder) SupportedSyncInvoke() bool
  • func (f *Forwarder) SyncForward(_ *v1.SniffData) (*v1.SniffData, error)

Constants

const (
	Name     = "native-log-kafka-forwarder"
	ShowName = "Native Log Kafka Forwarder"
)

Types

type Forwarder

type Forwarder struct {
	config.CommonFields
	Topic string `mapstructure:"topic"` // The forwarder topic.
	// contains filtered or unexported fields
}

func (*Forwarder) DefaultConfig

func (f *Forwarder) DefaultConfig() string

func (*Forwarder) Description

func (f *Forwarder) Description() string

func (*Forwarder) Forward

func (f *Forwarder) Forward(batch event.BatchEvents) error

func (*Forwarder) ForwardType

func (f *Forwarder) ForwardType() v1.SniffType

func (*Forwarder) Name

func (f *Forwarder) Name() string

func (*Forwarder) Prepare

func (f *Forwarder) Prepare(connection interface{}) error

func (*Forwarder) ShowName

func (f *Forwarder) ShowName() string

func (*Forwarder) SupportedSyncInvoke

func (f *Forwarder) SupportedSyncInvoke() bool

func (*Forwarder) SyncForward

func (f *Forwarder) SyncForward(_ *v1.SniffData) (*v1.SniffData, error)