canal

README

基于 debezium 和 kafka 的 binlog 订阅

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

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

Documentation

Index

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

Functions

func Main

func Main() error

nolint: funlen

Types

type Msg

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

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"`
}