protocol

Documentation

Index

• Constants
• type KafkaMsgMeta
  • func (m *KafkaMsgMeta) AddMetrics()
  • func (m *KafkaMsgMeta) AddTimestamp(t MsgTimestamp)
  • func (m *KafkaMsgMeta) GetPartitions() []int32
  • func (m *KafkaMsgMeta) GetTopic() string
  • func (m *KafkaMsgMeta) MetricsString() string
  • func (m *KafkaMsgMeta) SetKafkaPartitions(partitions []int32)
  • func (m *KafkaMsgMeta) SetKafkaTopic(topic string)
  • func (m *KafkaMsgMeta) SetPipelineName(name string)
• type MessageRouter
• type MessageTracer
• type MsgTimestamp

Constants

const (
	MsgDurationStartEnqueue   = "start_enqueue"
	MsgDurationEnqueueDequeue = "enqueue_dequeue"
	MsgDurationDequeueSent    = "dequeue_sent"
	MsgDurationAll            = "all"
)

Types

type KafkaMsgMeta

type KafkaMsgMeta struct {
	PipelineName string
	StartTime    time.Time
	EnqueueTime  time.Time
	DequeueTime  time.Time
	SentTime     time.Time
	KafkaTopic   string
	// KafkaPartitions is an array of partitions, DdlMsg message might be sent to all partitions
	KafkaPartitions []int32
}

func (*KafkaMsgMeta) AddMetrics

func (m *KafkaMsgMeta) AddMetrics()

func (*KafkaMsgMeta) AddTimestamp

func (m *KafkaMsgMeta) AddTimestamp(t MsgTimestamp)

func (*KafkaMsgMeta) GetPartitions

func (m *KafkaMsgMeta) GetPartitions() []int32

func (*KafkaMsgMeta) GetTopic

func (m *KafkaMsgMeta) GetTopic() string

func (*KafkaMsgMeta) MetricsString

func (m *KafkaMsgMeta) MetricsString() string

func (*KafkaMsgMeta) SetKafkaPartitions

func (m *KafkaMsgMeta) SetKafkaPartitions(partitions []int32)

func (*KafkaMsgMeta) SetKafkaTopic

func (m *KafkaMsgMeta) SetKafkaTopic(topic string)

func (*KafkaMsgMeta) SetPipelineName

func (m *KafkaMsgMeta) SetPipelineName(name string)

type MessageRouter

type MessageRouter interface {
	GetTopic() string
	GetPartitions() []int32
}

type MessageTracer

type MessageTracer interface {
	AddTimestamp(t MsgTimestamp)
	AddMetrics()
	MetricsString() string
}

type MsgTimestamp

type MsgTimestamp int

const (
	MsgTime MsgTimestamp = iota
	MsgStartTime
	MsgEnqueueTime
	MsgDequeueTime
	MsgSentTime
)