deduplicate

Documentation

Index

• Variables
• type Deduplicate
  • func NewDeduplicate() *Deduplicate
  • func (d *Deduplicate) HandleDisconnect(ctx middleware.Context, msg *types.DisconnectMessage) error
  • func (d *Deduplicate) HandleUplink(_ middleware.Context, msg *types.UplinkMessage) error

Variables

var ErrDuplicateMessage = errors.New("deduplicate: already handled this message")

ErrDuplicateMessage is returned when an uplink message is received multiple times

Types

type Deduplicate

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

Deduplicate middleware

func NewDeduplicate

func NewDeduplicate() *Deduplicate

NewDeduplicate returns a middleware that deduplicates duplicate uplink messages received from broken gateways

func (*Deduplicate) HandleDisconnect

func (d *Deduplicate) HandleDisconnect(ctx middleware.Context, msg *types.DisconnectMessage) error

HandleDisconnect cleans up

func (*Deduplicate) HandleUplink

func (d *Deduplicate) HandleUplink(_ middleware.Context, msg *types.UplinkMessage) error

HandleUplink blocks duplicate messages