kitGrpc

Documentation

Index

• Constants
• func FilterVersion(version string) nodeSelector.NodeFilter
• func GetBeforeTime(day int) (int64, string, time.Time)
• func GetConn(ctx context.Context, endpoint string) (*grpc.ClientConn, error)
• func GetCurDayHalfTimeFormat() string
• func GetCurDayHalfTimestamp() int64
• func GetCurDayZeroTimeFormat() string
• func GetCurDayZeroTimestamp() int64
• func GetCurrentTimestampByMill() int64
• func GetCurrentTimestampByNano() int64
• func GetCurrentTimestampBySecond() int64
• func GetGrpcClient(ctx context.Context, opt GetConnOption) (*grpc.ClientConn, error)
• func GetTimeStampByFormat(datetime string) string
• func GetTracerProvider() trace.TracerProvider
• func NewConfigClient(ipAddr string, port uint64, opts ...ClientOption) (config_client.IConfigClient, error)
• func NewNamingClient(ipAddr string, port uint64, opts ...ClientOption) (naming_client.INamingClient, error)
• func NewTracerProvider(opt TracerProviderOption) (*tracesdk.TracerProvider, error)
• func TimeStampChangeTimeStr(timeStamp int64) string
• func TimeStringFormatTimeTime(timeFormat string, timeSrc string) time.Time
• func TimeStringFormatTimeUnix(timeFormat string, timeSrc string) int64
• func TimeStringToTime(timeString string) (time.Time, error)
• func TimeStringToTimeTime(timeSrc string) time.Time
• func TimeToString(t time.Time) string
• func UnixMillSecondToTime(millSecond int64) time.Time
• func UnixNanoSecondToTime(nanoSecond int64) time.Time
• func UnixSecondToTime(second int64) time.Time
• type ClientOption
  • func WithLogLevel(lv string) ClientOption
  • func WithNamespaceID(ns string) ClientOption
  • func WithTimeout(timeout uint64) ClientOption
• type GetConnOption
• type TracerProviderOption

Constants

const (
	BaseVersion        = "latest"
	VersionKeyInHeader = "x-md-global-version"
)

const (
	TimeOffset = 8 * 3600  //8 hour offset
	HalfOffset = 12 * 3600 //Half-day hourly offset
)

Functions

func FilterVersion

func FilterVersion(version string) nodeSelector.NodeFilter

func GetBeforeTime

func GetBeforeTime(day int) (int64, string, time.Time)

GetBeforeTime 获取n天前的秒时间戳、日期时间戳 day为负则代表取前几天，为正则代表取后几天，0则为今天

func GetConn

func GetConn(ctx context.Context, endpoint string) (*grpc.ClientConn, error)

Deprecated: Use GetGrpcClient

func GetCurDayHalfTimeFormat

func GetCurDayHalfTimeFormat() string

Get the formatted time at 12 o'clock of the day, the format is "2006-01-02_12-00-00"

func GetCurDayHalfTimestamp

func GetCurDayHalfTimestamp() int64

Get the timestamp at 12 o'clock on the day

func GetCurDayZeroTimeFormat

func GetCurDayZeroTimeFormat() string

Get the formatted time at 0 o'clock of the day, the format is "2006-01-02_00-00-00"

func GetCurDayZeroTimestamp

func GetCurDayZeroTimestamp() int64

Get the timestamp at 0 o'clock of the day

func GetCurrentTimestampByMill

func GetCurrentTimestampByMill() int64

Get the current timestamp by Mill

func GetCurrentTimestampByNano

func GetCurrentTimestampByNano() int64

Get the current timestamp by Nano

func GetCurrentTimestampBySecond

func GetCurrentTimestampBySecond() int64

Get the current timestamp by Second

func GetGrpcClient

func GetGrpcClient(ctx context.Context, opt GetConnOption) (*grpc.ClientConn, error)

GetGrpcClient 获取grpc客户端 Timeout 默认3秒

func GetTimeStampByFormat

func GetTimeStampByFormat(datetime string) string

func GetTracerProvider

func GetTracerProvider() trace.TracerProvider

func NewConfigClient

func NewConfigClient(ipAddr string, port uint64, opts ...ClientOption) (config_client.IConfigClient, error)

func NewNamingClient

func NewNamingClient(ipAddr string, port uint64, opts ...ClientOption) (naming_client.INamingClient, error)

func NewTracerProvider

func NewTracerProvider(opt TracerProviderOption) (*tracesdk.TracerProvider, error)

func TimeStampChangeTimeStr

func TimeStampChangeTimeStr(timeStamp int64) string

时间戳转时间字符串

func TimeStringFormatTimeTime

func TimeStringFormatTimeTime(timeFormat string, timeSrc string) time.Time

func TimeStringFormatTimeUnix

func TimeStringFormatTimeUnix(timeFormat string, timeSrc string) int64

func TimeStringToTime

func TimeStringToTime(timeString string) (time.Time, error)

func TimeStringToTimeTime

func TimeStringToTimeTime(timeSrc string) time.Time

func TimeToString

func TimeToString(t time.Time) string

func UnixMillSecondToTime

func UnixMillSecondToTime(millSecond int64) time.Time

func UnixNanoSecondToTime

func UnixNanoSecondToTime(nanoSecond int64) time.Time

Convert nano timestamp to time.Time type

func UnixSecondToTime

func UnixSecondToTime(second int64) time.Time

Convert timestamp to time.Time type

Types

type ClientOption

type ClientOption func(o *constant.ClientConfig)

func WithLogLevel

func WithLogLevel(lv string) ClientOption

func WithNamespaceID

func WithNamespaceID(ns string) ClientOption

func WithTimeout

func WithTimeout(timeout uint64) ClientOption

type GetConnOption

type GetConnOption struct {
	Endpoint     string
	Timeout      time.Duration
	Logger       log.Logger
	Discovery    registry.Discovery
	SelectFilter grpcSelector.NodeFilter
	Caller       string
}

type TracerProviderOption

type TracerProviderOption struct {
	Endpoint    string
	ServiceName string
	Sampler     tracesdk.Sampler
	Attrubtes   []attribute.KeyValue
}