wrapper

Documentation

Index

• func Read(ctx context.Context, topic, broker, group string, msgchan chan kafka.Message, ...)
• type PS
  • func Create(topic, broker string, numparts int) (*PS, error)
  • func (ps *PS) Delete() error
  • func (ps *PS) Write(ctx context.Context, s Sender) (chan *kafka.Message, chan string, error)
• type Sender

Functions

func Read

func Read(ctx context.Context, topic, broker, group string,
	msgchan chan kafka.Message, errorchan chan error)

Types

type PS

type PS struct {
	Topic    string
	Broker   string
	NumParts int
	// contains filtered or unexported fields
}

func Create

func Create(topic, broker string, numparts int) (*PS, error)

func (*PS) Delete

func (ps *PS) Delete() error

func (*PS) Write

func (ps *PS) Write(ctx context.Context, s Sender) (chan *kafka.Message, chan string, error)

type Sender

type Sender interface {
	Send(chan []byte)
}