Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultMaxPingsOutstanding int = 3
View Source
var DefaultMaxReconnects int = -1
View Source
var DefaultPingInterval int64 = 10
View Source
var DefaultWorkerCount int = 128
Default settings
Functions ¶
func StrToBytes ¶
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
Consumer represents a Sarama consumer group consumer
func NewConsumer ¶
func (*Consumer) Cleanup ¶
func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error
Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited
func (*Consumer) ConsumeClaim ¶
func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages().
type ConsumerEvent ¶
type ConsumerEvent struct { Session sarama.ConsumerGroupSession Message *sarama.ConsumerMessage }
type Event ¶
type Event struct {
Payload EventPayload `json:"payload"`
}
type EventPayload ¶
type EventPayload struct { Before map[string]interface{} `json:"before"` After map[string]interface{} `json:"after"` Source EventSource `json:"source"` Op string `json:"op"` }
type EventSource ¶
func (*EventSource) IsSnapshot ¶
func (es *EventSource) IsSnapshot() bool
type Source ¶
type Source struct {
// contains filtered or unexported fields
}
func (*Source) HandleRequest ¶
func (*Source) InitDebezium ¶
func (*Source) InitSubscription ¶
type SourceConfig ¶
type SourceConfig struct {
Sources map[string]SourceInfo `json:"sources"`
}
type SourceInfo ¶
type SourceInfo struct { Host string `json:"host"` KafkaHosts string `json:"kafka.hosts"` Tables map[string]SourceTable `json:"tables"` Configs map[string]interface{} `json:"configs"` }
type SourceManager ¶
type SourceManager struct {
// contains filtered or unexported fields
}
func NewSourceManager ¶
func NewSourceManager(adapter *Adapter) *SourceManager
func (*SourceManager) Initialize ¶
func (sm *SourceManager) Initialize() error
func (*SourceManager) LoadSourceConfig ¶
func (sm *SourceManager) LoadSourceConfig(filename string) (*SourceConfig, error)
type SourceTable ¶
type SourceTable struct {
Events SourceTableEvents `json:"events"`
}
Click to show internal directories.
Click to hide internal directories.