utils

Documentation

Index

• func ArgsToMap(capacity, ratePerSec, tRCap, tRRate, tSCap, tSRate float64, ...) map[string][]byte
• func Byte2String(bs []int8) string
• func CopyMap(from *map[string]string) map[string]string
• func GetLineByKeyword(path string, keyword string) string
• func GetStrByKeyword(path string, keyword string) string
• func GetStrByKeywordFiles(pathes []string, keyword string) (path string, line string)
• func GoVersion() string
• func InstallDir() string
• func InstallTsInSec() int64
• func IsHigherOrEqualGoVersion(version string) bool
• func LastRestartInUSec() int64
• func Max(x, y int) int
• func Min(x, y int) int
• func SPrintBson(message []byte) string
• func Version() string
• type SafeBuffer
  • func (b *SafeBuffer) Len() int
  • func (b *SafeBuffer) Read(p []byte) (int, error)
  • func (b *SafeBuffer) Reset()
  • func (b *SafeBuffer) String() string
  • func (b *SafeBuffer) Write(p []byte) (int, error)

Functions

func ArgsToMap

func ArgsToMap(capacity, ratePerSec, tRCap, tRRate, tSCap, tSRate float64,
	metricsFlushInterval, maxTransactions int, token []byte) map[string][]byte

ArgsToMap uses settings as float/int/bytes to create a map of string keys to bytes, for usability by oboe UpdateSetting.

func Byte2String

func Byte2String(bs []int8) string

Byte2String converts a byte array into a string

func CopyMap

func CopyMap(from *map[string]string) map[string]string

CopyMap makes a copy of all elements of a map.

func GetLineByKeyword

func GetLineByKeyword(path string, keyword string) string

GetLineByKeyword reads a file, searches for the keyword and returns the matched line. It returns empty string "" if no match found or failed to open the path. Pass an empty string "" if you just need to get the first line.

func GetStrByKeyword

func GetStrByKeyword(path string, keyword string) string

GetStrByKeyword read a file, searches for the keyword and returns the matched line with trailing line-feed character trimmed.

func GetStrByKeywordFiles

func GetStrByKeywordFiles(pathes []string, keyword string) (path string, line string)

GetStrByKeywordFiles does the same thing as GetStrByKeyword but searches for a list of files and returns the first matched files and line

func GoVersion

func GoVersion() string

GoVersion returns the Go version

func InstallDir

func InstallDir() string

func InstallTsInSec

func InstallTsInSec() int64

func IsHigherOrEqualGoVersion

func IsHigherOrEqualGoVersion(version string) bool

IsHigherOrEqualGoVersion checks if go version is higher or equal to the given version

func LastRestartInUSec

func LastRestartInUSec() int64

func Max

func Max(x, y int) int

Max returns the greater value

func Min

func Min(x, y int) int

Min returns the lower value

func SPrintBson

func SPrintBson(message []byte) string

SPrintBson prints the BSON message. It's not concurrent-safe and is for testing only

func Version

func Version() string

Version returns the agent's version

Types

type SafeBuffer

type SafeBuffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

SafeBuffer is goroutine-safe buffer. It is for internal test use only.

func (*SafeBuffer) Len

func (b *SafeBuffer) Len() int

func (*SafeBuffer) Read

func (b *SafeBuffer) Read(p []byte) (int, error)

func (*SafeBuffer) Reset

func (b *SafeBuffer) Reset()

Reset truncates the buffer

func (*SafeBuffer) String

func (b *SafeBuffer) String() string

func (*SafeBuffer) Write

func (b *SafeBuffer) Write(p []byte) (int, error)