source

Documentation

Index

• type Kafka
  • func (s *Kafka) ReadChan() chan interface{}
  • func (s *Kafka) Start(ctx context.Context, _ *http.ServeMux) error
• type Mysql
  • func (s Mysql) ReadChan() chan interface{}
  • func (s *Mysql) Start(ctx context.Context, _ *http.ServeMux) error
• type Noop
  • func (s Noop) ReadChan() chan interface{}
  • func (s *Noop) Start(ctx context.Context, handler *http.ServeMux) error

Types

type Kafka

type Kafka struct {
	Version string   `yaml:"version"`
	Brokers []string `yaml:"brokers"`
	Topics  []string `yaml:"topics"`
	Group   string   `yaml:"group"`

	Assignor string `yaml:"assignor"`
	Newest   bool   `yaml:"newest"`

	OutC chan interface{} `yaml:"-"`
}

func (*Kafka) ReadChan

func (s *Kafka) ReadChan() chan interface{}

func (*Kafka) Start

func (s *Kafka) Start(ctx context.Context, _ *http.ServeMux) error

type Mysql

type Mysql struct {
	DSN           string   `yaml:"dsn"`
	BinPosition   string   `yaml:"binPosition"`
	Tables        []string `yaml:"tables"`
	SyncMarkTable string   `yaml:"syncMarkTable"`
	SyncChannel   string   `yaml:"syncChannel"`

	OutC chan interface{} `yaml:"-"`
}

func (Mysql) ReadChan

func (s Mysql) ReadChan() chan interface{}

func (*Mysql) Start

func (s *Mysql) Start(ctx context.Context, _ *http.ServeMux) error

type Noop

type Noop struct {
	OutC chan interface{} `yaml:"-"`
}

func (Noop) ReadChan

func (s Noop) ReadChan() chan interface{}

func (*Noop) Start

func (s *Noop) Start(ctx context.Context, handler *http.ServeMux) error