metadata

README

net/metadata

项目简介

用于储存各种元信息

Documentation

Index

• Constants
• Variables
• func Bool(ctx context.Context, key string) bool
• func GetGrpcTrace(ctx context.Context) []string
• func GetHttpTrace(ctx context.Context) map[string]string
• func GetTraceId(ctx context.Context) string
• func Int64(ctx context.Context, key string) int64
• func IsIncomingKey(key string) (ok bool)
• func IsOutgoingKey(key string) bool
• func NewContext(ctx context.Context, md MD) context.Context
• func Range(ctx context.Context, rangeFunc func(key string, value interface{}), ...)
• func String(ctx context.Context, key string) string
• func Value(ctx context.Context, key string) interface{}
• func WithContext(c context.Context) context.Context
• type MD
  • func FromContext(ctx context.Context) (md MD, ok bool)
  • func Join(mds ...MD) MD
  • func New(m map[string]interface{}) MD
  • func Pairs(kv ...interface{}) MD
  • func (md MD) Copy() MD
  • func (md MD) Len() int

Constants

const (

	// Network
	RemoteIP   = "remote_ip"
	RemotePort = "remote_port"
	ServerAddr = "server_addr"
	ClientAddr = "client_addr"

	// Router
	Cluster = "cluster"
	Color   = "color"

	// Trace
	Trace  = "trace"
	Caller = "caller"

	// Timeout
	Timeout = "timeout"

	// Dispatch
	CPUUsage = "cpu_usage"
	Errors   = "errors"
	Requests = "requests"

	// Mirror
	Mirror = "mirror"

	// Mid 外网账户用户id
	Mid = "mid" // NOTE: ！！！业务可重新修改key名！！！

	// Device 客户端信息
	Device = "device"

	// Criticality 重要性
	Criticality = "criticality"
)

metadata common key

Variables

var Incomingheaders = []string{

	"x-request-id",

	"x-ot-span-context",

	"x-datadog-trace-id",
	"x-datadog-parent-id",
	"x-datadog-sampling-priority",

	"traceparent",
	"tracestate",

	"x-cloud-trace-context",

	"grpc-trace-bin",

	"x-b3-traceid",
	"x-b3-spanid",
	"x-b3-parentspanid",
	"x-b3-sampled",
	"x-b3-flags",

	"end-user",
	"user-agent",
}

Functions

func Bool

func Bool(ctx context.Context, key string) bool

Bool get boolean from metadata in context use strconv.Parse.

func GetGrpcTrace

func GetGrpcTrace(ctx context.Context) []string

grpc server从请求中获取向外传递的链路追踪信息

func GetHttpTrace

func GetHttpTrace(ctx context.Context) map[string]string

http server从请求中获取向外传递的链路追踪信息

func GetTraceId

func GetTraceId(ctx context.Context) string

func Int64

func Int64(ctx context.Context, key string) int64

Int64 get int64 value from metadata in context

func IsIncomingKey

func IsIncomingKey(key string) (ok bool)

IsIncomingKey represent this key should extract from rpc metadata.

func IsOutgoingKey

func IsOutgoingKey(key string) bool

IsOutgoingKey represent this key should propagate by rpc.

func NewContext

func NewContext(ctx context.Context, md MD) context.Context

NewContext creates a new context with md attached.

func Range

func Range(ctx context.Context, rangeFunc func(key string, value interface{}), filterFunc ...func(key string) bool)

Range range value from metadata in context filtered by filterFunc.

func String

func String(ctx context.Context, key string) string

String get string value from metadata in context

func Value

func Value(ctx context.Context, key string) interface{}

Value get value from metadata in context return nil if not found

func WithContext

func WithContext(c context.Context) context.Context

WithContext return no deadline context and retain metadata.

Types

type MD

type MD map[string]interface{}

MD is a mapping from metadata keys to values.

func FromContext

func FromContext(ctx context.Context) (md MD, ok bool)

FromContext returns the incoming metadata in ctx if it exists. The returned MD should not be modified. Writing to it may cause races. Modification should be made to copies of the returned MD.

func Join

func Join(mds ...MD) MD

Join joins any number of mds into a single MD. The order of values for each key is determined by the order in which the mds containing those values are presented to Join.

func New

func New(m map[string]interface{}) MD

New creates an MD from a given key-value map.

func Pairs

func Pairs(kv ...interface{}) MD

Pairs returns an MD formed by the mapping of key, value ... Pairs panics if len(kv) is odd.

func (MD) Copy

func (md MD) Copy() MD

Copy returns a copy of md.

func (MD) Len

func (md MD) Len() int

Len returns the number of items in md.