util

Documentation

Index

• Constants
• func CurrentMillis() int64
• func DeepCopyMap(params map[string]string) map[string]string
• func GetConfigCacheKey(dataId string, group string, tenant string) string
• func GetDurationWithDefault(metadata map[string]string, key string, defaultDuration time.Duration) time.Duration
• func GetGroupName(serviceName string, groupName string) string
• func GetServiceCacheKey(serviceName string, clusters string) string
• func GetStatusCode(response *http.Response) string
• func GetUrlFormedMap(source map[string]string) (urlEncoded string)
• func JsonToService(result string) *model.Service
• func LocalIP() string
• func Md5(content string) (md string)
• func ToJsonString(object interface{}) string
• func TransformObject2Param(object interface{}) (params map[string]string)
• func TruncateContent(content string) string
• type Semaphore
  • func NewSemaphore(concurrencyNum int) *Semaphore
  • func (this *Semaphore) Acquire()
  • func (this *Semaphore) AvailablePermits() int
  • func (this *Semaphore) Release()
  • func (this *Semaphore) TryAcquire() bool

Constants

const SHOW_CONTENT_SIZE = 100

Functions

func CurrentMillis

func CurrentMillis() int64

func DeepCopyMap

func DeepCopyMap(params map[string]string) map[string]string

func GetConfigCacheKey

func GetConfigCacheKey(dataId string, group string, tenant string) string

func GetDurationWithDefault

func GetDurationWithDefault(metadata map[string]string, key string, defaultDuration time.Duration) time.Duration

func GetGroupName

func GetGroupName(serviceName string, groupName string) string

func GetServiceCacheKey

func GetServiceCacheKey(serviceName string, clusters string) string

func GetStatusCode

func GetStatusCode(response *http.Response) string

get status code by response,default is NA

func GetUrlFormedMap

func GetUrlFormedMap(source map[string]string) (urlEncoded string)

func JsonToService

func JsonToService(result string) *model.Service

func LocalIP

func LocalIP() string

func Md5

func Md5(content string) (md string)

func ToJsonString

func ToJsonString(object interface{}) string

func TransformObject2Param

func TransformObject2Param(object interface{}) (params map[string]string)

func TruncateContent

func TruncateContent(content string) string

Types

type Semaphore

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

func NewSemaphore

func NewSemaphore(concurrencyNum int) *Semaphore

func (*Semaphore) Acquire

func (this *Semaphore) Acquire()

func (*Semaphore) AvailablePermits

func (this *Semaphore) AvailablePermits() int

func (*Semaphore) Release

func (this *Semaphore) Release()

func (*Semaphore) TryAcquire

func (this *Semaphore) TryAcquire() bool