bigcache

Documentation

Index

• type Checker
  • func New(cache *bigcache.BigCache) *Checker
  • func NewByConfig(config bigcache.Config) (*Checker, error)
  • func NewDefault(duration time.Duration) (*Checker, error)
  • func (ch *Checker) IsSkip(msg any) bool
  • func (ch *Checker) MarkAsSent(msg any) error

Types

type Checker

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

Checker provides inmemory messages test

func New

func New(cache *bigcache.BigCache) *Checker

New checker wraps bigcache

func NewByConfig

func NewByConfig(config bigcache.Config) (*Checker, error)

NewByConfig checker

func NewDefault

func NewDefault(duration time.Duration) (*Checker, error)

NewDefault checker

func (*Checker) IsSkip

func (ch *Checker) IsSkip(msg any) bool

IsSkip message if was sent

func (*Checker) MarkAsSent

func (ch *Checker) MarkAsSent(msg any) error

MarkAsSent message to the publisher