consumer

Documentation

Index

• Variables
• type Consumer
• type PubSubConsumer
  • func NewPubSubConsumer(ctx context.Context, url string) (*PubSubConsumer, error)
  • func (c *PubSubConsumer) Next() (library.Package, error)

Variables

var ErrEmpty = errors.New("no messages in queue")

Types

type Consumer

type Consumer interface {
	Next() (library.Package, error)
}

type PubSubConsumer

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

func NewPubSubConsumer

func NewPubSubConsumer(ctx context.Context, url string) (*PubSubConsumer, error)

func (*PubSubConsumer) Next

func (c *PubSubConsumer) Next() (library.Package, error)