consumertest

Documentation

Index

• func NewConsumer(ctx context.Context, config cfg.Config, logger log.Logger) (stream.ConsumerCallback, error)
• type Consumer
  • func (c Consumer) Consume(ctx context.Context, model interface{}, attributes map[string]string) (bool, error)
  • func (c Consumer) GetModel(attributes map[string]string) interface{}
• type Todo

Functions

func NewConsumer

func NewConsumer(ctx context.Context, config cfg.Config, logger log.Logger) (stream.ConsumerCallback, error)

Types

type Consumer

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

func (Consumer) Consume

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

func (Consumer) GetModel

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

type Todo

type Todo struct {
	Id     int
	Text   string
	Status string
}