g

Documentation

Index

• Constants
• Variables
• func GetCometService() (addrs map[string]string, err error)
• func GetCometServiceMetas() (metas map[string]map[string]string, err error)
• func GetCurrentDir() string
• func InstanceDiscovery() error
• func NewZipkinReporter() reporter.Reporter
• func NewZipkinSpanFromCtx(ctx context.Context, f zipkinTracerFunc) (span zipkingo.Span, newCtx context.Context, err error)
• func NewZipkinTracer(opts ...zipkingo.TracerOption) (*zipkingo.Tracer, error)
• func SetPid(curPath string) int
• type FieldsFunc
• type LogFields
  • func NewLogFields() *LogFields
  • func (this LogFields) Append(k string, v interface{}) *LogFields
  • func (this LogFields) Get() logrus.Fields
• type ZipkinTag

Constants

const (
	ZIPKIN_OPTION_TAG = 1 + iota
	ZIPKIN_OPTION_ANNOTATE
)

Variables

var (
	ServiceRegistrar *consulsd.Registrar
	ServiceInstancer *consulsd.Instancer
)

var (
	ErrRouter         = errors.New("router rpc is not available")
	ErrDecodeKey      = errors.New("decode key error")
	ErrNetworkAddr    = errors.New("network addrs error, must network@address")
	ErrConnectArgs    = errors.New("connect rpc args error")
	ErrDisconnectArgs = errors.New("disconnect rpc args error")
)

var (
	Conf *conf.Config

	Logger logger
)

Functions

func GetCometService

func GetCometService() (addrs map[string]string, err error)

func GetCometServiceMetas

func GetCometServiceMetas() (metas map[string]map[string]string, err error)

func GetCurrentDir

func GetCurrentDir() string

func InstanceDiscovery

func InstanceDiscovery() error

func NewZipkinReporter

func NewZipkinReporter() reporter.Reporter

func NewZipkinSpanFromCtx

func NewZipkinSpanFromCtx(ctx context.Context, f zipkinTracerFunc) (span zipkingo.Span, newCtx context.Context, err error)

func NewZipkinTracer

func NewZipkinTracer(opts ...zipkingo.TracerOption) (*zipkingo.Tracer, error)

func SetPid

func SetPid(curPath string) int

Types

type FieldsFunc

type FieldsFunc func() *LogFields

type LogFields

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

func NewLogFields

func NewLogFields() *LogFields

func (LogFields) Append

func (this LogFields) Append(k string, v interface{}) *LogFields

func (LogFields) Get

func (this LogFields) Get() logrus.Fields

type ZipkinTag

type ZipkinTag struct {
	K string
	V string
}