grpc

Documentation

Index

• func WrapClient(ctx context.Context, s network.Stream) (*grpc.ClientConn, error)
• type Context
• type GrpcStream
  • func NewGrpcStream(ctx context.Context) *GrpcStream
  • func (g *GrpcStream) Accept() (net.Conn, error)
  • func (g *GrpcStream) Addr() net.Addr
  • func (g *GrpcStream) Client(ctx context.Context, stream network.Stream) (*grpc.ClientConn, error)
  • 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(ctx context.Context, s network.Stream) (*grpc.ClientConn, error)

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(ctx context.Context) *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(ctx context.Context, stream network.Stream) (*grpc.ClientConn, error)

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()