consumer

Documentation

Index

• Constants
• type Approach
  • func Approaches() []Approach
  • func NewApproach(name string) Approach
• type Config
• type Consumer
  • func New(config Config, totalRealms int) *Consumer
  • func (c *Consumer) NumMessages() int
  • func (c *Consumer) Run(ctx context.Context) error

Constants

const (
	MultipleFilterSubjects = Approach("multiple-filter-subjects")
	ManyConsumers          = Approach("many-consumers")
	Wildcard               = Approach("wildcard")
)

Types

type Approach

type Approach string

func Approaches

func Approaches() []Approach

func NewApproach

func NewApproach(name string) Approach

type Config

type Config struct {
	NatsURL  string
	Stream   string
	ClientID string
	Approach Approach
	Realms   []string
	Suffixes []string
}

type Consumer

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

func New

func New(config Config, totalRealms int) *Consumer

func (*Consumer) NumMessages

func (c *Consumer) NumMessages() int

func (*Consumer) Run

func (c *Consumer) Run(ctx context.Context) error