plugin

Documentation

Index

• func NewPluginClient(pluginCmd, pluginName string, tlsConfig *tls.Config, tlsEnabled bool) (*plugin.Client, plugin.ClientProtocol, shared.KafkaPlugin, error)
• func NewSink() (metrics.Sink, error)
• type Sink

Functions

func NewPluginClient

func NewPluginClient(pluginCmd, pluginName string, tlsConfig *tls.Config, tlsEnabled bool) (*plugin.Client, plugin.ClientProtocol, shared.KafkaPlugin, error)

NewPluginClient build new go-plugin client

func NewSink

func NewSink() (metrics.Sink, error)

NewSink build sink

Types

type Sink

type Sink struct {
	*common.Sink
	// contains filtered or unexported fields
}

Sink default sink use logrus to print metrics