endpoints

type BulkItem esutil.BulkIndexerItem

type Config struct {
	EndpointType  int
	Kafka         KafkaConfig
	Elasticsearch EsConfig
}

type ElasticsearchConfig elasticsearch.Config

type EsBulkIdxCfg esutil.BulkIndexerConfig

type EsConfig struct {
	BulkIndexerCfg   EsBulkIdxCfg
	ElasticsearchCfg ElasticsearchConfig

	OnSuccess func(context.Context, esutil.BulkIndexerItem, esutil.BulkIndexerResponseItem)
	OnFailure func(context.Context, esutil.BulkIndexerItem, esutil.BulkIndexerResponseItem, error)
	Hook      func(data *handler.BinlogEvent) (item BulkItem, err error)
}

type EsEndpoint struct {
	Cli *elasticsearch.Client

	OnSuccess func(context.Context, esutil.BulkIndexerItem, esutil.BulkIndexerResponseItem)
	OnFailure func(context.Context, esutil.BulkIndexerItem, esutil.BulkIndexerResponseItem, error)

	Hook func(data *handler.BinlogEvent) (item BulkItem, err error)
	// contains filtered or unexported fields
}

type IEndpoint interface {
	Send(data *handler.BinlogEvent) error
	Close() error
}

type KafkaCfg sarama.Config

type KafkaConfig struct {
	Addrs          []string
	Cfg            KafkaCfg
	OnSuccess      func(msg *sarama.ProducerMessage)
	OnFailure      func(err *sarama.ProducerError)
	TopicConfigMap map[string]TopicCfg `json:"topic_config_map"`
}

type KafkaEndPoint struct {
	Addrs []string
	Cfg   sarama.Config

	TopicCfgMap map[string]TopicCfg
	// contains filtered or unexported fields
}

type TopicCfg struct {
	Topic string `json:"topic"`
	Shard int    `json:"shard_count"`
}