data

Documentation

Index

• Constants
• type Roller
  • func NewRoller(minTimeGap time.Duration, limit int) *Roller
  • func (r *Roller) Clear()
  • func (r *Roller) Do(fnc func(packet.RocketPacket))
  • func (r *Roller) Last() packet.RocketPacket
  • func (r *Roller) Len() int
  • func (r *Roller) Limit() int
  • func (r *Roller) OnData(packets []packet.RocketPacket)
  • func (r *Roller) SetLimit(limit int)

Constants

const (
	DefaultMinTimeGap  = 50 * time.Millisecond
	DefaultRollerLimit = 100
)

Types

type Roller

type Roller struct {
	MinTimeGap time.Duration
	// contains filtered or unexported fields
}

func NewRoller

func NewRoller(minTimeGap time.Duration, limit int) *Roller

func (*Roller) Clear

func (r *Roller) Clear()

func (*Roller) Do

func (r *Roller) Do(fnc func(packet.RocketPacket))

func (*Roller) Last

func (r *Roller) Last() packet.RocketPacket

func (*Roller) Len

func (r *Roller) Len() int

func (*Roller) Limit

func (r *Roller) Limit() int

func (*Roller) OnData

func (r *Roller) OnData(packets []packet.RocketPacket)

func (*Roller) SetLimit

func (r *Roller) SetLimit(limit int)