sra

Documentation

Index

• type EsSelector
  • func (s *EsSelector) Select([]*estransport.Connection) (*estransport.Connection, error)
• type RedisLimiter
  • func NewRedisLimiter() *RedisLimiter
  • func (l *RedisLimiter) Allow() error
  • func (l *RedisLimiter) ReportResult(result error)

Types

type EsSelector

type EsSelector struct {
}

func (*EsSelector) Select

func (s *EsSelector) Select([]*estransport.Connection) (*estransport.Connection, error)

type RedisLimiter

type RedisLimiter struct {
}

func NewRedisLimiter

func NewRedisLimiter() *RedisLimiter

func (*RedisLimiter) Allow

func (l *RedisLimiter) Allow() error

func (*RedisLimiter) ReportResult

func (l *RedisLimiter) ReportResult(result error)