instrument

Documentation

Index

• Constants
• type Action
• type Collector
• type MultiCollector
  • func NewMultiCollector(collectors ...Collector) MultiCollector
  • func (m MultiCollector) After(message *confluent.Message, action Action, err error, start time.Time)
  • func (m MultiCollector) Before(message *confluent.Message, action Action, start time.Time)

Constants

const (
	// OverallTime represents the overall process from consume to project
	OverallTime = Action("kafka_transformer_overall")
	// KafkaConsumerConsume represents the consume action
	KafkaConsumerConsume = Action("kafka_consumer_consume")
	// KafkaProducerProduce represents the produce action to kafka
	KafkaProducerProduce = Action("kafka_producer_produce")
	// TransformerTransform represents the transform action to kafka
	TransformerTransform = Action("transformer_transform")
	// ProjectorProject represents the project action
	ProjectorProject = Action("projector_project")
)

Types

type Action

type Action string

Action represents the main action of the kafka transformer

type Collector

type Collector interface {
	Before(message *confluent.Message, action Action, start time.Time)
	After(message *confluent.Message, action Action, err error, start time.Time)
}

Collector allows to specify a collector for all the main actions of the kafka transformer. Main actions are : consume, transform, produce/project Before is called before the action and After called after. warning: message can be nil, check err != nil also for errors

type MultiCollector

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

MultiCollector allows you to compose a list of collector

func NewMultiCollector

func NewMultiCollector(collectors ...Collector) MultiCollector

NewMultiCollector is a constructor for multi collector

func (MultiCollector) After

func (m MultiCollector) After(message *confluent.Message, action Action, err error, start time.Time)

After calls all After method of inner collectors

func (MultiCollector) Before

func (m MultiCollector) Before(message *confluent.Message, action Action, start time.Time)

Before calls all Before method of inner collectors