dropevents

Documentation

Index

• Constants
• type CounterHandler
  • func (h *CounterHandler) Skip() bool
• type Skipper
  • func SkipperAlgorithm(algorithm string) Skipper

Constants

const (
	Fibonacci        = "fibonacci"
	Sequence         = "sequence"
	SkipAlgorithmKey = "SKIP_ALGORITHM"
	NumberKey        = "NUMBER"
)

Types

type CounterHandler

type CounterHandler struct {
	Skipper Skipper
	sync.Mutex
	// contains filtered or unexported fields
}

func (*CounterHandler) Skip

func (h *CounterHandler) Skip() bool

type Skipper

type Skipper interface {
	// Skip returns true if the message must be rejected
	Skip(counter uint64) bool
}

Skipper represents the logic to apply to accept/reject events.

func SkipperAlgorithm

func SkipperAlgorithm(algorithm string) Skipper