openconfig

Documentation

Index

• func ElasticsearchMessageEncoder(topic string, key sarama.Encoder, message proto.Message) (*sarama.ProducerMessage, error)
• type UnhandledMessageError
  • func (e UnhandledMessageError) Error() string
• type UnhandledSubscribeResponseError
  • func (e UnhandledSubscribeResponseError) Error() string

Functions

func ElasticsearchMessageEncoder

func ElasticsearchMessageEncoder(topic string, key sarama.Encoder,
	message proto.Message) (*sarama.ProducerMessage, error)

ElasticsearchMessageEncoder defines the encoding from SubscribeResponse to sarama.ProducerMessage for Elasticsearch

Types

type UnhandledMessageError

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

UnhandledMessageError is used for proto messages not matching the handled types

func (UnhandledMessageError) Error

func (e UnhandledMessageError) Error() string

type UnhandledSubscribeResponseError

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

UnhandledSubscribeResponseError is used for subscribe responses not matching the handled types

func (UnhandledSubscribeResponseError) Error

func (e UnhandledSubscribeResponseError) Error() string