util

Documentation

Index

• func AddrToPath(s string) string
• func Key(routeName, addr string) string
• type Limiter
  • func NewLimiter(limit int) Limiter
  • func (l Limiter) Add()
  • func (l Limiter) Done()

Functions

func AddrToPath

func AddrToPath(s string) string

some.host:2003 -> some_host_2003 http://some.host:8080 -> http_some_host_8080

func Key

func Key(routeName, addr string) string

some.host:2003, kafkaRoute -> kafkaRoute_some_host_2003 http://some.host:8080, kafkaRoute -> kafkaRoute_http_some_host_8080

Types

type Limiter

type Limiter chan struct{}

Limiter limits concurrency Users need to call Add() before starting work and Done() when the work is done. Add() will block if the Limiters limit has already been reached and unblock when another thread calls Done()

func NewLimiter

func NewLimiter(limit int) Limiter

NewLimiter creates a limiter with l slots

func (Limiter) Add

func (l Limiter) Add()

func (Limiter) Done

func (l Limiter) Done()