util

Documentation

Index

• Constants
• Variables
• func DebugInfo(msg string, v interface{})
• func ExtractMap(m map[string]string) string
• func FormatMapper(typ, id, name string) string
• func GetV1ResultBadRequest(msg string) *v1.Result
• func GetV1ResultInternalError(msg string) *v1.Result
• func GetV1ResultOK() *v1.Result
• func Hash32(text string) uint32
• func ParseSearchEngine(dsn string) (drive driver.Type, username, password string, urls []string, err error)
• func ResolveAddr() string
• func Search(slice sort.StringSlice, elem string) int
• func SliceAppend(slice sort.StringSlice, vals []string) sort.StringSlice
• func UUID(prefix string) string
• func Unique(slice sort.StringSlice) sort.StringSlice
• func UnixMilli() int64
• func UnwrapS(s string) string
• func WrapS(str string) string
• type ElapsedTime
  • func NewElapsed() *ElapsedTime
  • func NewElapsedFrom(t time.Time) *ElapsedTime
  • func (et *ElapsedTime) Elapsed() time.Duration
  • func (et *ElapsedTime) ElapsedMicro() int64
  • func (et *ElapsedTime) ElapsedMilli() int64
  • func (et *ElapsedTime) ElapsedNano() int64
  • func (et *ElapsedTime) ElapsedSecond() int64
  • func (et *ElapsedTime) Reset() *ElapsedTime
• type ReEntryLock
  • func NewReEntryLock(maxStackDepth int32) *ReEntryLock
  • func (a *ReEntryLock) Lock(requestID *string) error
  • func (a *ReEntryLock) Unlock()
• type Waiter
  • func NewWaiter() Waiter

Constants

const (
	EtcdMapperPrefix = "core.mapper."
)

const RangeOutIndex = -1

Variables

var ErrMaxStackDepthExceeded = errors.New("maximum stack depth exceeded")

Functions

func DebugInfo

func DebugInfo(msg string, v interface{})

func ExtractMap

func ExtractMap(m map[string]string) string

func FormatMapper

func FormatMapper(typ, id, name string) string

func GetV1ResultBadRequest

func GetV1ResultBadRequest(msg string) *v1.Result

func GetV1ResultInternalError

func GetV1ResultInternalError(msg string) *v1.Result

func GetV1ResultOK

func GetV1ResultOK() *v1.Result

func Hash32

func Hash32(text string) uint32

func ParseSearchEngine

func ParseSearchEngine(dsn string) (drive driver.Type, username, password string, urls []string, err error)

func ResolveAddr

func ResolveAddr() string

func Search

func Search(slice sort.StringSlice, elem string) int

func SliceAppend

func SliceAppend(slice sort.StringSlice, vals []string) sort.StringSlice

func UUID

func UUID(prefix string) string

uuid generate an uuid.

func Unique

func Unique(slice sort.StringSlice) sort.StringSlice

Unique input order slice.

func UnixMilli

func UnixMilli() int64

func UnwrapS

func UnwrapS(s string) string

func WrapS

func WrapS(str string) string

Types

type ElapsedTime

type ElapsedTime struct {
	// contains filtered or unexported fields
}

func NewElapsed

func NewElapsed() *ElapsedTime

NewElapsed returns ElapsedTime.

func NewElapsedFrom

func NewElapsedFrom(t time.Time) *ElapsedTime

NewElapsedFrom construct ElapsedTime from t.

func (*ElapsedTime) Elapsed

func (et *ElapsedTime) Elapsed() time.Duration

Elapsed returns elapsed duration.

func (*ElapsedTime) ElapsedMicro

func (et *ElapsedTime) ElapsedMicro() int64

ElapsedMicro returns elapsed microseconds.

func (*ElapsedTime) ElapsedMilli

func (et *ElapsedTime) ElapsedMilli() int64

ElapsedMill returns elapsed milliseconds.

func (*ElapsedTime) ElapsedNano

func (et *ElapsedTime) ElapsedNano() int64

ElapsedNano returns elapsed nanoseconds.

func (*ElapsedTime) ElapsedSecond

func (et *ElapsedTime) ElapsedSecond() int64

ElapsedSecond returns elapsed seconds.

func (*ElapsedTime) Reset

func (et *ElapsedTime) Reset() *ElapsedTime

type ReEntryLock

type ReEntryLock struct {
	// contains filtered or unexported fields
}

ReEntryLock re-entry lock.

func NewReEntryLock

func NewReEntryLock(maxStackDepth int32) *ReEntryLock

func (*ReEntryLock) Lock

func (a *ReEntryLock) Lock(requestID *string) error

func (*ReEntryLock) Unlock

func (a *ReEntryLock) Unlock()

type Waiter

type Waiter interface {
	Add(int)
	Done()
	Wait()
}

func NewWaiter

func NewWaiter() Waiter