kafka_output

package

v0.26.0 Latest Latest Go to latest Published: Jun 29, 2022 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/karimra/gnmic

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

var KafkaNumberOfFailSendMsgs = prometheus.NewCounterVec(prometheus.CounterOpts{
	Namespace: "gnmic",
	Subsystem: "kafka_output",
	Name:      "number_of_kafka_msgs_sent_fail_total",
	Help:      "Number of failed msgs sent by gnmic kafka output",
}, []string{"producer_id", "reason"})

View Source

var KafkaNumberOfSentBytes = prometheus.NewCounterVec(prometheus.CounterOpts{
	Namespace: "gnmic",
	Subsystem: "kafka_output",
	Name:      "number_of_written_kafka_bytes_total",
	Help:      "Number of bytes written by gnmic kafka output",
}, []string{"producer_id"})

View Source

var KafkaNumberOfSentMsgs = prometheus.NewCounterVec(prometheus.CounterOpts{
	Namespace: "gnmic",
	Subsystem: "kafka_output",
	Name:      "number_of_kafka_msgs_sent_success_total",
	Help:      "Number of msgs successfully sent by gnmic kafka output",
}, []string{"producer_id"})

View Source

var KafkaSendDuration = prometheus.NewGaugeVec(prometheus.GaugeOpts{
	Namespace: "gnmic",
	Subsystem: "kafka_output",
	Name:      "msg_send_duration_ns",
	Help:      "gnmic kafka output send duration in ns",
}, []string{"producer_id"})

View Source

var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }

View Source

var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Address            string        `mapstructure:"address,omitempty"`
	Topic              string        `mapstructure:"topic,omitempty"`
	Name               string        `mapstructure:"name,omitempty"`
	SASL               *sasl         `mapstructure:"sasl,omitempty"`
	TLS                *tlsConfig    `mapstructure:"tls,omitempty"`
	MaxRetry           int           `mapstructure:"max-retry,omitempty"`
	Timeout            time.Duration `mapstructure:"timeout,omitempty"`
	RecoveryWaitTime   time.Duration `mapstructure:"recovery-wait-time,omitempty"`
	Format             string        `mapstructure:"format,omitempty"`
	AddTarget          string        `mapstructure:"add-target,omitempty"`
	TargetTemplate     string        `mapstructure:"target-template,omitempty"`
	MsgTemplate        string        `mapstructure:"msg-template,omitempty"`
	NumWorkers         int           `mapstructure:"num-workers,omitempty"`
	Debug              bool          `mapstructure:"debug,omitempty"`
	BufferSize         int           `mapstructure:"buffer-size,omitempty"`
	OverrideTimestamps bool          `mapstructure:"override-timestamps,omitempty"`
	EnableMetrics      bool          `mapstructure:"enable-metrics,omitempty"`
	EventProcessors    []string      `mapstructure:"event-processors,omitempty"`
}

Config //

type KafkaOutput ¶

type KafkaOutput struct {
	Cfg *Config
	// contains filtered or unexported fields
}

KafkaOutput //

func (*KafkaOutput) Close ¶

func (k *KafkaOutput) Close() error

Close //

func (*KafkaOutput) Init ¶

func (k *KafkaOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, opts ...outputs.Option) error

Init /

func (*KafkaOutput) RegisterMetrics ¶ added in v0.7.0

func (k *KafkaOutput) RegisterMetrics(reg *prometheus.Registry)

Metrics //

func (*KafkaOutput) SetClusterName ¶ added in v0.8.0

func (k *KafkaOutput) SetClusterName(name string)

func (*KafkaOutput) SetEventProcessors ¶ added in v0.6.0

func (k *KafkaOutput) SetEventProcessors(ps map[string]map[string]interface{},
	logger *log.Logger,
	tcs map[string]*types.TargetConfig,
	acts map[string]map[string]interface{})

func (*KafkaOutput) SetLogger ¶ added in v0.5.2

func (k *KafkaOutput) SetLogger(logger *log.Logger)

func (*KafkaOutput) SetName ¶ added in v0.7.0

func (k *KafkaOutput) SetName(name string)

func (*KafkaOutput) SetTargetsConfig ¶ added in v0.18.0

func (k *KafkaOutput) SetTargetsConfig(map[string]*types.TargetConfig)

func (*KafkaOutput) String ¶

func (k *KafkaOutput) String() string

func (*KafkaOutput) Write ¶

func (k *KafkaOutput) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)

Write //

func (*KafkaOutput) WriteEvent ¶ added in v0.7.0

func (k *KafkaOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)

type XDGSCRAMClient ¶ added in v0.9.0

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

func (*XDGSCRAMClient) Begin ¶ added in v0.9.0

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

func (*XDGSCRAMClient) Done ¶ added in v0.9.0

func (x *XDGSCRAMClient) Done() bool

func (*XDGSCRAMClient) Step ¶ added in v0.9.0

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL