grpc

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 23, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WrapClient

func WrapClient(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() *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, 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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL