Grpc

Documentation

Index

• func LoggingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• func NewClient(fs ...GrpcAttrFunc) *grpc.ClientConn
• func NewServer(fs ...GrpcAttrFunc) *grpc.Server
• func RecoveryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• func StreamLoggingInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• type Grpc
  • func (this *Grpc) GetClientcert(path string, host string) credentials.TransportCredentials
  • func (this *Grpc) GetServercert(path string) credentials.TransportCredentials
• type GrpcAttrFunc
  • func Host(host string) GrpcAttrFunc
  • func Ip(ip string) GrpcAttrFunc
  • func KeyPath(path string) GrpcAttrFunc
  • func ServerInterceptor(fn grpc.StreamServerInterceptor) GrpcAttrFunc
  • func StreamServerInterceptor(fn grpc.UnaryServerInterceptor) GrpcAttrFunc
• type GrpcAttrFuncs

Functions

func LoggingInterceptor

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

func NewClient

func NewClient(fs ...GrpcAttrFunc) *grpc.ClientConn

func NewServer

func NewServer(fs ...GrpcAttrFunc) *grpc.Server

func RecoveryInterceptor

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

func StreamLoggingInterceptor

func StreamLoggingInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

Types

type Grpc

type Grpc struct {
	KeyPath           string
	ChainStreamServer []grpc.StreamServerInterceptor
	ChainServer       []grpc.UnaryServerInterceptor
	Ip                string
	Host              string
}

func (*Grpc) GetClientcert

func (this *Grpc) GetClientcert(path string, host string) credentials.TransportCredentials

func (*Grpc) GetServercert

func (this *Grpc) GetServercert(path string) credentials.TransportCredentials

type GrpcAttrFunc

type GrpcAttrFunc func(grpc *Grpc) //设置User属性的 函数类型

func Host

func Host(host string) GrpcAttrFunc

func Ip

func Ip(ip string) GrpcAttrFunc

func KeyPath

func KeyPath(path string) GrpcAttrFunc

func ServerInterceptor

func ServerInterceptor(fn grpc.StreamServerInterceptor) GrpcAttrFunc

func StreamServerInterceptor

func StreamServerInterceptor(fn grpc.UnaryServerInterceptor) GrpcAttrFunc

type GrpcAttrFuncs

type GrpcAttrFuncs []GrpcAttrFunc