kafka

Documentation

Index

• Variables
• type Config
• type Kafka
  • func New(config Config) (*Kafka, error)
  • func (k *Kafka) Close() error
  • func (k *Kafka) ProduceKeyEvent(ctx context.Context, eventType keyEventType, keyId, keyHash string) error
  • func (k *Kafka) RegisterOnKeyEvent(handler func(ctx context.Context, e KeyEvent) error)
  • func (k *Kafka) Start()
• type KeyEvent

Variables

var (
	KeyCreated keyEventType = "created"
	KeyUpdated keyEventType = "updated"
	KeyDeleted keyEventType = "deleted"
)

Types

type Config

type Config struct {
	GroupId  string
	Broker   string
	Username string
	Password string
	Logger   *zap.Logger
}

type Kafka

type Kafka struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(config Config) (*Kafka, error)

func (*Kafka) Close

func (k *Kafka) Close() error

func (*Kafka) ProduceKeyEvent

func (k *Kafka) ProduceKeyEvent(ctx context.Context, eventType keyEventType, keyId, keyHash string) error

func (*Kafka) RegisterOnKeyEvent

func (k *Kafka) RegisterOnKeyEvent(handler func(ctx context.Context, e KeyEvent) error)

func (*Kafka) Start

func (k *Kafka) Start()

Call Start in a goroutine

type KeyEvent

type KeyEvent struct {
	Type keyEventType `json:"type"`
	Key  struct {
		Id   string `json:"id"`
		Hash string `hson:"hash"`
	} `json:"key"`
}