gokamux

README

gokamux

Gokamux is a service written in Go to mux Kafka streams, filtering, transforming and joining the result in different output topics

Documentation

Index

• type Muxer
  • func NewMuxer() *Muxer
  • func (m *Muxer) Brokers(broker ...string) *Muxer
  • func (m *Muxer) ConsumerGroup(consumerGroup string) *Muxer
  • func (m *Muxer) Input(topic ...string) *Muxer
  • func (m *Muxer) Output(topic ...string) *Muxer
  • func (m Muxer) Run(ctx context.Context) error
  • func (m *Muxer) Step(steps ...Step) *Muxer
• type Step

Types

type Muxer

type Muxer struct {
	// contains filtered or unexported fields
}

func NewMuxer

func NewMuxer() *Muxer

func (*Muxer) Brokers

func (m *Muxer) Brokers(broker ...string) *Muxer

func (*Muxer) ConsumerGroup

func (m *Muxer) ConsumerGroup(consumerGroup string) *Muxer

func (*Muxer) Input

func (m *Muxer) Input(topic ...string) *Muxer

func (*Muxer) Output

func (m *Muxer) Output(topic ...string) *Muxer

func (Muxer) Run

func (m Muxer) Run(ctx context.Context) error

func (*Muxer) Step

func (m *Muxer) Step(steps ...Step) *Muxer

type Step

type Step struct {
	ID     string
	Module string
	Params []string
}