kk_grpc

Documentation

Index

• Constants
• func GetTraceIdFromGrpcCtx(ctx context.Context) (traceId string)
• func NewCallGrpcCtx(stage *kk_stage.Stage) (ctx context.Context, cancelFunc context.CancelFunc)
• func NewGrpcStage(tracerCtx context.Context, serviceName string, debugMode bool) (stage *kk_stage.Stage)

Constants

const TimeoutDur = 10 * time.Second

Functions

func GetTraceIdFromGrpcCtx

func GetTraceIdFromGrpcCtx(ctx context.Context) (traceId string)

GetTraceIdFromGrpcCtx get traceId from metadata set by

metadata.AppendToOutgoingContext() or metadata.NewOutgoingContext()

func NewCallGrpcCtx

func NewCallGrpcCtx(stage *kk_stage.Stage) (ctx context.Context, cancelFunc context.CancelFunc)

func NewGrpcStage

func NewGrpcStage(tracerCtx context.Context, serviceName string, debugMode bool) (stage *kk_stage.Stage)