utils

Documentation

Index

• func AntsPool(maxInFlight int) (*ants.Pool, error)
• func CalculateEndToEndLatency(payload *[]byte) (time.Time, time.Duration)
• func FormatTimestamp(timestamp uint64) time.Time
• func GetEndpoints(serviceName string) ([]string, error)
• func InjectId(s string, id int) string
• func MessageBody(size int) []byte
• func ParseURI(rawURI string, defaultScheme string, defaultPort string) uri
• func Rate(rate float32) string
• func RateLimiter(publishRate float32) *rate.Limiter
• func UpdatePayload(useMillis bool, payload *[]byte) *[]byte
• func WrappedSequence(len int, start int) []int

Functions

func AntsPool

func AntsPool(maxInFlight int) (*ants.Pool, error)

func CalculateEndToEndLatency

func CalculateEndToEndLatency(payload *[]byte) (time.Time, time.Duration)

func FormatTimestamp

func FormatTimestamp(timestamp uint64) time.Time

func GetEndpoints

func GetEndpoints(serviceName string) ([]string, error)

K8sGet performs a GET request on the Kubernetes API with the given URL; We only need 1 GET on a simple REST endpoint, and this way we avoid importing go-client with lots of dependencies

func InjectId

func InjectId(s string, id int) string

func MessageBody

func MessageBody(size int) []byte

func ParseURI

func ParseURI(rawURI string, defaultScheme string, defaultPort string) uri

func Rate

func Rate(rate float32) string

func RateLimiter

func RateLimiter(publishRate float32) *rate.Limiter

func UpdatePayload

func UpdatePayload(useMillis bool, payload *[]byte) *[]byte

func WrappedSequence

func WrappedSequence(len int, start int) []int

generate a sequence of `len` integres starting with `start` and wrapped, so that it contains all values from 0 to len-1