Versions in this module Expand all Collapse all v0 v0.0.1 Jun 19, 2018 Changes in this version + const SupportPackageIsVersion1 + func Invoke(ctx context.Context, api uint16, args interface{}, reply interface{}, ...) error + type ClientConn struct + func Dial(addr string, opt ...DialOption) (*ClientConn, error) + func DialContext(ctx context.Context, addr string, opts ...DialOption) (*ClientConn, error) + func (cc *ClientConn) Close() error + func (cc *ClientConn) NewStream() (*yamux.Stream, error) + type ClientStream interface + CloseSend func() error + func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, api uint16) (ClientStream, error) + type Codec interface + Marshal func(v interface{}) ([]byte, error) + Unmarshal func(data []byte, v interface{}) error + func NewCodec() Codec + type DialOption func(*dialOptions) + func WithCodec(c Codec) DialOption + type MethodDesc struct + Handler methodHandler + Index uint8 + MethodName string + type Server struct + func NewServer(opts ...ServerOption) *Server + func (s *Server) RegisterService(sd *ServiceDesc, ss interface{}) + func (s *Server) Serve(lis net.Listener) error + func (s *Server) Stop() + type ServerOption func(*options) + func CustomCodec(c Codec) ServerOption + type ServerStream interface + type ServiceDesc struct + HandlerType interface{} + Index uint8 + Metadata interface{} + Methods []MethodDesc + ServiceName string + Streams []StreamDesc + type Stream interface + Context func() context.Context + RecvMsg func(m interface{}) error + SendMsg func(m interface{}) error + type StreamDesc struct + ClientStreams bool + Handler StreamHandler + Index uint8 + ServerStreams bool + StreamName string + type StreamHandler func(srv interface{}, stream ServerStream) error
Go to main page