input

Documentation

Index

• type Input
  • func NewInput(parameter Parameter) (*Input, error)
  • func (c *Input) Start() error
  • func (c *Input) Stop() error
• type Parameter

Types

type Input

type Input struct {
	Partitions chan cluster.PartitionConsumer
	// contains filtered or unexported fields
}

func NewInput

func NewInput(parameter Parameter) (*Input, error)

func (*Input) Start

func (c *Input) Start() error

func (*Input) Stop

func (c *Input) Stop() error

type Parameter

type Parameter struct {
	Addr                 []string
	Group                string
	Topic                string
	ConsumerReturnErrors bool
	OffsetsInitial       int64

	Partitions chan cluster.PartitionConsumer
}