throttler

Documentation

Index

• Constants
• type ThrottlingQueue
  • func NewThrottlingQueue(throttle, throttleBucket int, flowLogWriter *dbwriter.FlowLogWriter, index int) *ThrottlingQueue
  • func (thq *ThrottlingQueue) SampleDisabled() bool
  • func (thq *ThrottlingQueue) SendWithThrottling(flow interface{}) bool
  • func (thq *ThrottlingQueue) SendWithoutThrottling(flow interface{})

Constants

const (
	QUEUE_BATCH = 1 << 14
)

Types

type ThrottlingQueue

type ThrottlingQueue struct {
	Throttle int
	// contains filtered or unexported fields
}

func NewThrottlingQueue

func NewThrottlingQueue(throttle, throttleBucket int, flowLogWriter *dbwriter.FlowLogWriter, index int) *ThrottlingQueue

func (*ThrottlingQueue) SampleDisabled

func (thq *ThrottlingQueue) SampleDisabled() bool

func (*ThrottlingQueue) SendWithThrottling

func (thq *ThrottlingQueue) SendWithThrottling(flow interface{}) bool

func (*ThrottlingQueue) SendWithoutThrottling

func (thq *ThrottlingQueue) SendWithoutThrottling(flow interface{})