canal

README

基于 debezium 和 kafka 的 binlog 订阅

暂时用于处理用户密码修改。

需要 dev-env 的 mq/ 文件夹中的组件

Documentation

Index

• func Main() error
• type Msg
• type Payload
• type Stream
• type SubjectFieldKey
• type SubjectKey
• type UserKey

Functions

func Main

func Main() error

nolint: funlen

Types

type Msg

type Msg struct {
	ID    string
	Topic string
	Key   []byte
	Value []byte
}

type Payload

type Payload struct {
	Before json.RawMessage `json:"before"`
	After  json.RawMessage `json:"after"`
	Source source          `json:"source"`
	Op     string          `json:"op"`
}

type Stream

type Stream interface {
	Read(ctx context.Context, onMessage func(msg Msg) error) error
	// Ack(ctx context.Context, msg Msg) error
	Close() error
}

type SubjectFieldKey

type SubjectFieldKey struct {
	ID model.SubjectID `json:"field_sid"`
}

type SubjectKey

type SubjectKey struct {
	ID model.SubjectID `json:"subject_id"`
}

type UserKey

type UserKey struct {
	ID model.UserID `json:"uid"`
}