dtmgimp

Jul 8, 2022

Changes in this version

+ func GetDtmRequest(s *dtmimp.TransBase) *dtmgpb.DtmRequest

+ func MustProtoUnmarshal(data []byte, msg proto.Message)

Mar 25, 2022

Changes in this version

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

+ func RequestTimeoutFromContext(ctx context.Context) int64

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

Jan 27, 2022

Changes in this version

+ func InvokeBranch(t *dtmimp.TransBase, isRaw bool, msg proto.Message, url string, ...) error

Jan 1, 2022

Changes in this version

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

Dec 31, 2021

Changes in this version

+ var ClientInterceptors = []grpc.UnaryClientInterceptor

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

Dec 24, 2021

Changes in this version

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

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

+ func GrpcClientLog(ctx context.Context, method string, req, reply interface{}, ...) error

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

+ func LogDtmCtx(ctx context.Context)

+ func MustGetDtmClient(grpcServer string) dtmgpb.DtmClient

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

+ func MustGetRawDtmClient(grpcServer string) dtmgpb.DtmClient

+ func MustProtoMarshal(msg proto.Message) []byte

+ func Result2Error(res interface{}, err error) error

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

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