throttler

Documentation

Index

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

Constants

const (
	THROTTLE_BUCKET = 10 // 由于发送方是有突发的，需要累积一定时间做采样
)

Types

type ThrottlingQueue

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

func NewThrottlingQueue

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

func (*ThrottlingQueue) SendWithThrottling

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

func (*ThrottlingQueue) SendWithoutThrottling

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