dtmgimp

README

Notice

Please donot use this package, and this package should only be used in dtm internally. The interfaces are not stable, and package name has postfix "imp"

Documentation

Index

• Variables
• func DtmGrpcCall(s *dtmimp.TransBase, operation string) error
• func GetDtmMetaFromContext(ctx context.Context, name string) string
• func GetGrpcConn(grpcServer string, isRaw bool) (conn *grpc.ClientConn, rerr error)
• func GetMetaFromContext(ctx context.Context, name string) string
• func GrpcClientLog(ctx context.Context, method string, req, reply interface{}, ...) error
• func GrpcServerLog(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• func InvokeBranch(t *dtmimp.TransBase, isRaw bool, msg proto.Message, url string, ...) error
• func LogDtmCtx(ctx context.Context)
• func Map2Kvs(m map[string]string) []string
• func MustGetDtmClient(grpcServer string) dtmgpb.DtmClient
• func MustGetGrpcConn(grpcServer string, isRaw bool) *grpc.ClientConn
• func MustProtoMarshal(msg proto.Message) []byte
• func RequestTimeoutFromContext(ctx context.Context) int64
• func RequestTimeoutNewContext(ctx context.Context, requestTimeout int64) context.Context
• func TransBaseFromGrpc(ctx context.Context) *dtmimp.TransBase
• func TransInfo2Ctx(ctx context.Context, gid, transType, branchID, op, dtm string) context.Context

Variables

var ClientInterceptors = []grpc.UnaryClientInterceptor{}

ClientInterceptors declares grpc.UnaryClientInterceptors slice

Functions

func DtmGrpcCall

func DtmGrpcCall(s *dtmimp.TransBase, operation string) error

DtmGrpcCall make a convenient call to dtm

func GetDtmMetaFromContext

func GetDtmMetaFromContext(ctx context.Context, name string) string

GetDtmMetaFromContext get dtm header from context

func GetGrpcConn

func GetGrpcConn(grpcServer string, isRaw bool) (conn *grpc.ClientConn, rerr error)

GetGrpcConn 1

func GetMetaFromContext

func GetMetaFromContext(ctx context.Context, name string) string

GetMetaFromContext get header from context

func GrpcClientLog

func GrpcClientLog(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

GrpcClientLog middleware to print client-side grpc log

func GrpcServerLog

func GrpcServerLog(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

GrpcServerLog middleware to print server-side grpc log

func InvokeBranch

func InvokeBranch(t *dtmimp.TransBase, isRaw bool, msg proto.Message, url string, reply interface{}, branchID string, op string) error

InvokeBranch invoke a url for trans

func LogDtmCtx

func LogDtmCtx(ctx context.Context)

LogDtmCtx logout dtm info in context metadata

func Map2Kvs

func Map2Kvs(m map[string]string) []string

Map2Kvs map to metadata kv

func MustGetDtmClient

func MustGetDtmClient(grpcServer string) dtmgpb.DtmClient

MustGetDtmClient 1

func MustGetGrpcConn

func MustGetGrpcConn(grpcServer string, isRaw bool) *grpc.ClientConn

MustGetGrpcConn 1

func MustProtoMarshal

func MustProtoMarshal(msg proto.Message) []byte

MustProtoMarshal must version of proto.Marshal

func RequestTimeoutFromContext

func RequestTimeoutFromContext(ctx context.Context) int64

RequestTimeoutFromContext returns requestTime of transOption option

func RequestTimeoutNewContext

func RequestTimeoutNewContext(ctx context.Context, requestTimeout int64) context.Context

RequestTimeoutNewContext sets requestTimeout of transOption option to context

func TransBaseFromGrpc

func TransBaseFromGrpc(ctx context.Context) *dtmimp.TransBase

TransBaseFromGrpc get trans base info from a context metadata

func TransInfo2Ctx

func TransInfo2Ctx(ctx context.Context, gid, transType, branchID, op, dtm string) context.Context

TransInfo2Ctx add trans info to grpc context