grpcframe

Documentation

Index

• func ClientConnInvoke(cc *grpc.ClientConn, ctx context.Context, method string, ...) error
• func ClientConnNewStream(cc *grpc.ClientConn, ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
• func ServerRegisterService(s *grpc.Server, sd *grpc.ServiceDesc, ss interface{})
• func ServerServe(s *grpc.Server, lis net.Listener) error
• func WrapClientConnInvoke(cc *grpc.ClientConn, ctx context.Context, method string, ...) error
• func WrapClientConnNewStream(cc *grpc.ClientConn, ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
• func WrapServerRegisterService(s *grpc.Server, sd *grpc.ServiceDesc, ss interface{})
• func WrapServerServe(s *grpc.Server, lis net.Listener) error
• type ClientStreamWrapper
  • func (w *ClientStreamWrapper) CloseSend() error
  • func (w *ClientStreamWrapper) Context() context.Context
  • func (w *ClientStreamWrapper) Header() (metadata.MD, error)
  • func (w *ClientStreamWrapper) RecvMsg(m interface{}) error
  • func (w *ClientStreamWrapper) SendMsg(m interface{}) error
  • func (w *ClientStreamWrapper) Trailer() metadata.MD
• type StreamHandler

Functions

func ClientConnInvoke

func ClientConnInvoke(cc *grpc.ClientConn, ctx context.Context, method string, args, reply interface{}, opts ...grpc.CallOption) error

func ClientConnNewStream

func ClientConnNewStream(cc *grpc.ClientConn, ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)

func ServerRegisterService

func ServerRegisterService(s *grpc.Server, sd *grpc.ServiceDesc, ss interface{})

func ServerServe

func ServerServe(s *grpc.Server, lis net.Listener) error

func WrapClientConnInvoke

func WrapClientConnInvoke(cc *grpc.ClientConn, ctx context.Context, method string, args, reply interface{}, opts ...grpc.CallOption) error

func WrapClientConnNewStream

func WrapClientConnNewStream(cc *grpc.ClientConn, ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)

func WrapServerRegisterService

func WrapServerRegisterService(s *grpc.Server, sd *grpc.ServiceDesc, ss interface{})

func WrapServerServe

func WrapServerServe(s *grpc.Server, lis net.Listener) error

Types

type ClientStreamWrapper

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

func (*ClientStreamWrapper) CloseSend

func (w *ClientStreamWrapper) CloseSend() error

func (*ClientStreamWrapper) Context

func (w *ClientStreamWrapper) Context() context.Context

func (*ClientStreamWrapper) Header

func (w *ClientStreamWrapper) Header() (metadata.MD, error)

func (*ClientStreamWrapper) RecvMsg

func (w *ClientStreamWrapper) RecvMsg(m interface{}) error

func (*ClientStreamWrapper) SendMsg

func (w *ClientStreamWrapper) SendMsg(m interface{}) error

func (*ClientStreamWrapper) Trailer

func (w *ClientStreamWrapper) Trailer() metadata.MD

type StreamHandler

type StreamHandler func(srv interface{}, stream grpc.ServerStream) error