Versions in this module Expand all Collapse all v0 v0.6.1 Jul 31, 2023 v0.0.4 Jul 31, 2023 Changes in this version + const Colon + const Comma + const DQuotation + const DefaultConfDir + const DefaultConfFile + const DefaultErrorSeparator + const DefaultLogDir + const EmptyJSON + const EnvConfDir + const EnvConfFile + const EnvLogDir + const LeftBrace + const RightBrace + var ErrRingFull = errors.New("ring is full") + func CalculateEventCost(rpcstats rpcinfo.RPCStats, start, end stats.Event) time.Duration + func GetConfDir() string + func GetConfFile() string + func GetEnvLogDir() string + func GetFuncName(i interface{}) string + func GetLogDir() string + func GetUIntLen(n uint64) int + func JSONStr2Map(jsonStr string) (mapInfo map[string]string, err error) + func Map2JSONStr(mapInfo map[string]string) (str string, err error) + func MarshalError(method string, err error) []byte + func NewNetAddr(network, address string) net.Addr + func SliceByteToString(b []byte) string + func StringDeepCopy(s string) string + func StringToSliceByte(s string) []byte + func UnmarshalError(b []byte) error + func WriteInt64ToStringBuilder(sb *strings.Builder, value int64) + type AtomicInt int32 + func (i *AtomicInt) Dec() + func (i *AtomicInt) Inc() + func (i *AtomicInt) Value() int + type ErrChain struct + func (e *ErrChain) Append(err error) + func (e *ErrChain) UseSeparator(sep string) + func (e ErrChain) Error() string + func (e ErrChain) HasError() bool + type KitexArgs interface + GetFirstArgument func() interface{} + type KitexResult interface + GetResult func() interface{} + SetSuccess func(interface{}) + type MaxCounter struct + func NewMaxCounter(max int) *MaxCounter + func (cl *MaxCounter) Dec() + func (cl *MaxCounter) DecN(n int64) + func (cl *MaxCounter) Inc() bool + func (cl *MaxCounter) Now() int64 + type NetAddr struct + func (na *NetAddr) Network() string + func (na *NetAddr) String() string + type Ring struct + func NewRing(size int) *Ring + func (r *Ring) Dump() interface{} + func (r *Ring) Pop() interface{} + func (r *Ring) Push(obj interface{}) error + type SharedTicker struct + Interval time.Duration + func NewSharedTicker(interval time.Duration) *SharedTicker + func (t *SharedTicker) Add(b TickerTask) + func (t *SharedTicker) Closed() bool + func (t *SharedTicker) Delete(b TickerTask) + func (t *SharedTicker) Tick(interval time.Duration) + type Slice []interface + func (s *Slice) Pop() (res interface{}) + func (s *Slice) Push(any interface{}) + type ThriftMessageCodec struct + func NewThriftMessageCodec() *ThriftMessageCodec + func (t *ThriftMessageCodec) Decode(b []byte, msg thrift.TStruct) (method string, seqID int32, err error) + func (t *ThriftMessageCodec) Deserialize(msg thrift.TStruct, b []byte) (err error) + func (t *ThriftMessageCodec) Encode(method string, msgType thrift.TMessageType, seqID int32, msg thrift.TStruct) (b []byte, err error) + func (t *ThriftMessageCodec) Serialize(msg thrift.TStruct) (b []byte, err error) + type TickerTask interface + Tick func() + type YamlConfig struct + func ReadYamlConfigFile(yamlFile string) (*YamlConfig, error) + func (yc *YamlConfig) Get(key string) (interface{}, bool) + func (yc *YamlConfig) GetDuration(key string) (time.Duration, bool)