requestid

README

micro-wrapper-requestid

Documentation

Index

• Variables
• type Hook
  • func (w *Hook) ClientBatchPublish(next client.FuncBatchPublish) client.FuncBatchPublish
  • func (w *Hook) ClientCall(next client.FuncCall) client.FuncCall
  • func (w *Hook) ClientPublish(next client.FuncPublish) client.FuncPublish
  • func (w *Hook) ClientStream(next client.FuncStream) client.FuncStream
  • func (w *Hook) ServerHandler(next server.FuncHandler) server.FuncHandler
  • func (w *Hook) ServerSubscriber(next server.FuncSubHandler) server.FuncSubHandler
• type XRequestIDKey

Variables

var DefaultMetadataFunc = func(ctx context.Context) (context.Context, error) {
	var xid string

	cid, cok := ctx.Value(XRequestIDKey{}).(string)
	if cok && cid != "" {
		xid = cid
	}

	imd, iok := metadata.FromIncomingContext(ctx)
	if !iok || imd == nil {
		imd = metadata.New(1)
		ctx = metadata.NewIncomingContext(ctx, imd)
	}

	omd, ook := metadata.FromOutgoingContext(ctx)
	if !ook || omd == nil {
		omd = metadata.New(1)
		ctx = metadata.NewOutgoingContext(ctx, omd)
	}

	if xid == "" {
		var id string
		if id, iok = imd.Get(DefaultMetadataKey); iok && id != "" {
			xid = id
		}
		if id, ook = omd.Get(DefaultMetadataKey); ook && id != "" {
			xid = id
		}
	}

	if xid == "" {
		var err error
		xid, err = id.New()
		if err != nil {
			return ctx, err
		}
	}

	if !cok {
		ctx = context.WithValue(ctx, XRequestIDKey{}, xid)
	}

	if !iok {
		imd.Set(DefaultMetadataKey, xid)
	}

	if !ook {
		omd.Set(DefaultMetadataKey, xid)
	}

	return ctx, nil
}

DefaultMetadataFunc wil be used if user not provide own func to fill metadata

var DefaultMetadataKey = textproto.CanonicalMIMEHeaderKey("x-request-id")

DefaultMetadataKey contains metadata key

var Wrapper = &Hook{}

Types

type Hook

type Hook struct{}

func (*Hook) ClientBatchPublish

func (w *Hook) ClientBatchPublish(next client.FuncBatchPublish) client.FuncBatchPublish

func (*Hook) ClientCall

func (w *Hook) ClientCall(next client.FuncCall) client.FuncCall

func (*Hook) ClientPublish

func (w *Hook) ClientPublish(next client.FuncPublish) client.FuncPublish

func (*Hook) ClientStream

func (w *Hook) ClientStream(next client.FuncStream) client.FuncStream

func (*Hook) ServerHandler

func (w *Hook) ServerHandler(next server.FuncHandler) server.FuncHandler

func (*Hook) ServerSubscriber

func (w *Hook) ServerSubscriber(next server.FuncSubHandler) server.FuncSubHandler

type XRequestIDKey

type XRequestIDKey struct{}