utils

Documentation

Index

• func CalculateEndToEndLatency(payload *[]byte) (time.Time, time.Duration)
• func FormatTimestamp(timestamp uint64) time.Time
• func MessageBody(size int) []byte
• func ParseURI(rawURI string, defaultScheme string, defaultPort string) uri
• func UpdatePayload(useMillis bool, payload *[]byte) *[]byte
• func WrappedSequence(len int, start int) []int

Functions

func CalculateEndToEndLatency

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

func FormatTimestamp

func FormatTimestamp(timestamp uint64) time.Time

func MessageBody

func MessageBody(size int) []byte

func ParseURI

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

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