consumer

Documentation

Index

• type Config
• type Consumer
  • func New(config *Config) (*Consumer, error)
  • func (c *Consumer) Close() error
  • func (c *Consumer) Consume(ctx context.Context, topic string) <-chan Payload
• type Payload
  • func (p Payload) Err() error
  • func (p Payload) JsonUnmarshal(v interface{}) error
  • func (p Payload) ProtoUnmarshal(m proto.Message) error

Types

type Config

type Config struct {
	Addr string
}

type Consumer

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

func New

func New(config *Config) (*Consumer, error)

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Consume

func (c *Consumer) Consume(ctx context.Context, topic string) <-chan Payload

type Payload

type Payload struct {
	Message []byte
	// contains filtered or unexported fields
}

func (Payload) Err

func (p Payload) Err() error

func (Payload) JsonUnmarshal

func (p Payload) JsonUnmarshal(v interface{}) error

func (Payload) ProtoUnmarshal

func (p Payload) ProtoUnmarshal(m proto.Message) error