kafka

Documentation

Index

• Constants
• func CommitUpdate(key, data interface{}, tblname string)
• func Init(brokers []string, waltopic, tracetopic, id string)
• func NewConsumer() (sarama.Consumer, error)
• func Trace(content map[string]*json.RawMessage)
• type WAL

Constants

const WALType = "WAL"

Functions

func CommitUpdate

func CommitUpdate(key, data interface{}, tblname string)

WAL

func Init

func Init(brokers []string, waltopic, tracetopic, id string)

func NewConsumer

func NewConsumer() (sarama.Consumer, error)

func Trace

func Trace(content map[string]*json.RawMessage)

Trace user events

Types

type WAL

type WAL struct {
	Type       string      `json:"type"`
	InstanceId string      `json:"instanceId"`
	Table      string      `json:"table"`
	Host       string      `json:"host"`
	Key        string      `json:"key"`
	CreatedAt  time.Time   `json:"created_at"`
	Data       interface{} `json:"data"`
}

related stream processor: https://github.com/xtaci/sp