grpc

Documentation

Index

• func WrapClient(s network.Stream) *grpc.ClientConn
• type Context
• type GrpcStream
  • func NewGrpcStream() *GrpcStream
  • func (g *GrpcStream) Accept() (net.Conn, error)
  • func (g *GrpcStream) Addr() net.Addr
  • func (g *GrpcStream) Client(stream network.Stream) *grpc.ClientConn
  • func (g *GrpcStream) Close() error
  • func (g *GrpcStream) GrpcServer() *grpc.Server
  • func (g *GrpcStream) Handler() func(network.Stream)
  • func (g *GrpcStream) RegisterService(sd *grpc.ServiceDesc, ss interface{})
  • func (g *GrpcStream) Serve()

Functions

func WrapClient

func WrapClient(s network.Stream) *grpc.ClientConn

Types

type Context

type Context struct {
	context.Context
	PeerID peer.ID
}

type GrpcStream

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

func NewGrpcStream

func NewGrpcStream() *GrpcStream

func (*GrpcStream) Accept

func (g *GrpcStream) Accept() (net.Conn, error)

func (*GrpcStream) Addr

func (g *GrpcStream) Addr() net.Addr

Addr implements the net.Listener interface

func (*GrpcStream) Client

func (g *GrpcStream) Client(stream network.Stream) *grpc.ClientConn

func (*GrpcStream) Close

func (g *GrpcStream) Close() error

func (*GrpcStream) GrpcServer

func (g *GrpcStream) GrpcServer() *grpc.Server

func (*GrpcStream) Handler

func (g *GrpcStream) Handler() func(network.Stream)

func (*GrpcStream) RegisterService

func (g *GrpcStream) RegisterService(sd *grpc.ServiceDesc, ss interface{})

func (*GrpcStream) Serve

func (g *GrpcStream) Serve()