grpc

Documentation

Index

• Constants
• Variables
• func ContextWithValueAndTimeout(value interface{}, duration time.Duration) context.Context
• func GenerateSign(secret string, message []byte) (auth string, err error)
• func ProtoMessage2JSON(message proto.Message) (string, error)
• func ProtoMessage2Map(message proto.Message) (map[string]interface{}, error)
• type ClientConn
  • func New() (ClientConn, error)
• type ClientInterceptor
  • func NewClientInterceptor(sign Sign) *ClientInterceptor
  • func (c *ClientInterceptor) UnaryInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
• type Sign

Constants

const (
	// ProxyAuthorization used by signature, both gateway and grpc
	ProxyAuthorization = "proxy-authorization"
)

const (
	TraceID = "trace-id"
)

Variables

var ClientWithContextKey = clientWithContextKeyType{"_client_with_context"}

Functions

func ContextWithValueAndTimeout

func ContextWithValueAndTimeout(value interface{}, duration time.Duration) context.Context

func GenerateSign

func GenerateSign(secret string, message []byte) (auth string, err error)

func ProtoMessage2JSON

func ProtoMessage2JSON(message proto.Message) (string, error)

ProtoMessage2JSON marshal protobuf message to json string

func ProtoMessage2Map

func ProtoMessage2Map(message proto.Message) (map[string]interface{}, error)

ProtoMessage2Map marshal protobuf message to map[string]interface{}

Types

type ClientConn

type ClientConn interface {
	Conn() *grpc.ClientConn
	// contains filtered or unexported methods
}

func New

func New() (ClientConn, error)

type ClientInterceptor

type ClientInterceptor struct {
	// contains filtered or unexported fields
}

ClientInterceptor the client's interceptor

func NewClientInterceptor

func NewClientInterceptor(sign Sign) *ClientInterceptor

NewClientInterceptor create a client interceptor

func (*ClientInterceptor) UnaryInterceptor

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

UnaryInterceptor a interceptor for client unary operations

type Sign

type Sign func(message []byte) (auth string, err error)