protocol

package

v0.9.0 Latest Latest Go to latest Published: Dec 27, 2018 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/moiot/gravity

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type KafkaMsgMeta
type MessageRouter
type MessageTracer
type MsgTimestamp

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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
)

Source Files ¶

View all Source files

meta.go

Directories ¶

Path	Synopsis
dcp Package dcp is a generated protocol buffer package.	Package dcp is a generated protocol buffer package.
msgpb Package msgpb is a generated protocol buffer package.	Package msgpb is a generated protocol buffer package.
tidb Package slave_binlog is a generated protocol buffer package.	Package slave_binlog is a generated protocol buffer package.

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