producer

Documentation

Index

• type EventType
• type Message
  • func (m *Message) TargetKeys() []string
  • func (m *Message) TargetValues() []interface{}
• type Producer

Types

type EventType

type EventType string

var (
	Unknown EventType = "UNKNWON"
	Insert  EventType = "INSERT"
	Update  EventType = "UPDATE"
	Delete  EventType = "DELETE"
)

type Message

type Message struct {
	TableName string
	EventType EventType
	// key value pairs.
	// to insert, update, delete.
	Targets map[string]interface{}
}

func (*Message) TargetKeys

func (m *Message) TargetKeys() []string

func (*Message) TargetValues

func (m *Message) TargetValues() []interface{}

type Producer

type Producer interface {
	Produce([]byte) ([]*Message, error)
}

producer may return multiple messages. e.g. 1 mongo document can be nest and split to multiple tables.