consumer

Documentation

Index

• func NewConsumer() stream.ConsumerCallbackFactory
• type Consumer
  • func (c *Consumer) Consume(ctx context.Context, model interface{}, _ map[string]interface{}) (bool, error)
  • func (c *Consumer) GetModel(map[string]interface{}) interface{}

Functions

func NewConsumer

func NewConsumer() stream.ConsumerCallbackFactory

Types

type Consumer

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

func (*Consumer) Consume

func (c *Consumer) Consume(ctx context.Context, model interface{}, _ map[string]interface{}) (bool, error)

func (*Consumer) GetModel

func (c *Consumer) GetModel(map[string]interface{}) interface{}