Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

grpc

package

Go to main page

Versions in this module

v1

v1.1.0

May 23, 2022

v1.0.3

May 16, 2022

v1.0.1

Apr 29, 2022

v1.0.0

Apr 1, 2022

Changes in this version

+ var ErrAlreadyConnected = errors.New("already connected")

+ var ErrNoConnection = errors.New("no connection available")

+ var ErrNodeDIDAuthFailed = errors.New("nodeDID authentication failed")

+ var File_transport_grpc_testprotocol_proto protoreflect.FileDescriptor

+ var MaxMessageSizeInBytes = defaultMaxMessageSizeInBytes

+ var Test_ServiceDesc = grpc.ServiceDesc

+ func GetStreamMethod(serviceName string, stream grpc.StreamDesc) string

+ func NewGRPCConnectionManager(config Config, nodeDIDResolver transport.NodeDIDResolver, ...) transport.ConnectionManager

+ func RandomBackoff(min, max time.Duration) time.Duration

+ func RegisterTestServer(s grpc.ServiceRegistrar, srv TestServer)

+ type Authenticator interface

+ Authenticate func(nodeDID did.DID, grpcPeer grpcPeer.Peer, peer transport.Peer) (transport.Peer, error)

+ func NewDummyAuthenticator(serviceResolver doc.ServiceResolver) Authenticator

+ func NewTLSAuthenticator(serviceResolver doc.ServiceResolver) Authenticator

+ type Backoff interface

+ Backoff func() time.Duration

+ Reset func()

+ type ClientStream interface

+ type Config struct

+ func NewBufconnConfig(peerID transport.PeerID, options ...ConfigOption) (Config, *bufconn.Listener)

+ func NewConfig(grpcAddress string, peerID networkTypes.PeerID, options ...ConfigOption) Config

+ type ConfigOption func(config *Config)

+ func WithBufconnDialer(listener *bufconn.Listener) ConfigOption

+ func WithTLS(clientCertificate tls.Certificate, trustStore *core.TrustStore, ...) ConfigOption

+ type Conn interface

+ type Connection interface

+ IsConnected func() bool

+ Peer func() transport.Peer

+ Send func(protocol Protocol, envelope interface{}) error

+ type ConnectionList interface

+ All func() []Connection

+ Get func(query ...Predicate) Connection

+ type ConnectorsStats []transport.ConnectorStats

+ func (a ConnectorsStats) Name() string

+ func (a ConnectorsStats) Result() interface{}

+ func (a ConnectorsStats) String() string

+ type MockAuthenticator struct

+ func NewMockAuthenticator(ctrl *gomock.Controller) *MockAuthenticator

+ func (m *MockAuthenticator) Authenticate(nodeDID did.DID, grpcPeer peer.Peer, peer transport.Peer) (transport.Peer, error)

+ func (m *MockAuthenticator) EXPECT() *MockAuthenticatorMockRecorder

+ type MockAuthenticatorMockRecorder struct

+ func (mr *MockAuthenticatorMockRecorder) Authenticate(nodeDID, grpcPeer, peer interface{}) *gomock.Call

+ type MockClientStream struct

+ func NewMockClientStream(ctrl *gomock.Controller) *MockClientStream

+ func (m *MockClientStream) CloseSend() error

+ func (m *MockClientStream) Context() context.Context

+ func (m *MockClientStream) EXPECT() *MockClientStreamMockRecorder

+ func (m *MockClientStream) Header() (metadata.MD, error)

+ func (m *MockClientStream) Trailer() metadata.MD

+ func (m_2 *MockClientStream) RecvMsg(m interface{}) error

+ func (m_2 *MockClientStream) SendMsg(m interface{}) error

+ type MockClientStreamMockRecorder struct

+ func (mr *MockClientStreamMockRecorder) CloseSend() *gomock.Call

+ func (mr *MockClientStreamMockRecorder) Context() *gomock.Call

+ func (mr *MockClientStreamMockRecorder) Header() *gomock.Call

+ func (mr *MockClientStreamMockRecorder) RecvMsg(m interface{}) *gomock.Call

+ func (mr *MockClientStreamMockRecorder) SendMsg(m interface{}) *gomock.Call

+ func (mr *MockClientStreamMockRecorder) Trailer() *gomock.Call

+ type MockConn struct

+ func NewMockConn(ctrl *gomock.Controller) *MockConn

+ func (m *MockConn) EXPECT() *MockConnMockRecorder

+ func (m *MockConn) Invoke(ctx context.Context, method string, args, reply interface{}, ...) error

+ func (m *MockConn) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)

+ type MockConnMockRecorder struct

+ func (mr *MockConnMockRecorder) Invoke(ctx, method, args, reply interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockConnMockRecorder) NewStream(ctx, desc, method interface{}, opts ...interface{}) *gomock.Call

+ type MockConnection struct

+ func NewMockConnection(ctrl *gomock.Controller) *MockConnection

+ func (m *MockConnection) EXPECT() *MockConnectionMockRecorder

+ func (m *MockConnection) IsConnected() bool

+ func (m *MockConnection) Peer() transport.Peer

+ func (m *MockConnection) Send(protocol Protocol, envelope interface{}) error

+ type MockConnectionList struct

+ func NewMockConnectionList(ctrl *gomock.Controller) *MockConnectionList

+ func (m *MockConnectionList) All() []Connection

+ func (m *MockConnectionList) EXPECT() *MockConnectionListMockRecorder

+ func (m *MockConnectionList) Get(query ...Predicate) Connection

+ type MockConnectionListMockRecorder struct

+ func (mr *MockConnectionListMockRecorder) All() *gomock.Call

+ func (mr *MockConnectionListMockRecorder) Get(query ...interface{}) *gomock.Call

+ type MockConnectionMockRecorder struct

+ func (mr *MockConnectionMockRecorder) IsConnected() *gomock.Call

+ func (mr *MockConnectionMockRecorder) Peer() *gomock.Call

+ func (mr *MockConnectionMockRecorder) Send(protocol, envelope interface{}) *gomock.Call

+ type MockProtocol struct

+ func NewMockProtocol(ctrl *gomock.Controller) *MockProtocol

+ func (m *MockProtocol) Configure(peerID transport.PeerID) error

+ func (m *MockProtocol) CreateClientStream(outgoingContext context.Context, grpcConn grpc.ClientConnInterface) (grpc.ClientStream, error)

+ func (m *MockProtocol) CreateEnvelope() interface{}

+ func (m *MockProtocol) Diagnostics() []core.DiagnosticResult

+ func (m *MockProtocol) EXPECT() *MockProtocolMockRecorder

+ func (m *MockProtocol) Handle(peer transport.Peer, envelope interface{}) error

+ func (m *MockProtocol) MethodName() string

+ func (m *MockProtocol) PeerDiagnostics() map[transport.PeerID]transport.Diagnostics

+ func (m *MockProtocol) Register(registrar grpc.ServiceRegistrar, acceptor func(grpc.ServerStream) error, ...)

+ func (m *MockProtocol) Start() error

+ func (m *MockProtocol) Stop()

+ func (m *MockProtocol) UnwrapMessage(envelope interface{}) interface{}

+ func (m *MockProtocol) Version() int

+ type MockProtocolMockRecorder struct

+ func (mr *MockProtocolMockRecorder) Configure(peerID interface{}) *gomock.Call

+ func (mr *MockProtocolMockRecorder) CreateClientStream(outgoingContext, grpcConn interface{}) *gomock.Call

+ func (mr *MockProtocolMockRecorder) CreateEnvelope() *gomock.Call

+ func (mr *MockProtocolMockRecorder) Diagnostics() *gomock.Call

+ func (mr *MockProtocolMockRecorder) Handle(peer, envelope interface{}) *gomock.Call

+ func (mr *MockProtocolMockRecorder) MethodName() *gomock.Call

+ func (mr *MockProtocolMockRecorder) PeerDiagnostics() *gomock.Call

+ func (mr *MockProtocolMockRecorder) Register(registrar, acceptor, connectionList, connectionManager interface{}) *gomock.Call

+ func (mr *MockProtocolMockRecorder) Start() *gomock.Call

+ func (mr *MockProtocolMockRecorder) Stop() *gomock.Call

+ func (mr *MockProtocolMockRecorder) UnwrapMessage(envelope interface{}) *gomock.Call

+ func (mr *MockProtocolMockRecorder) Version() *gomock.Call

+ type MockStream struct

+ func NewMockStream(ctrl *gomock.Controller) *MockStream

+ func (m *MockStream) Context() context.Context

+ func (m *MockStream) EXPECT() *MockStreamMockRecorder

+ func (m_2 *MockStream) RecvMsg(m interface{}) error

+ func (m_2 *MockStream) SendMsg(m interface{}) error

+ type MockStreamMockRecorder struct

+ func (mr *MockStreamMockRecorder) Context() *gomock.Call

+ func (mr *MockStreamMockRecorder) RecvMsg(m interface{}) *gomock.Call

+ func (mr *MockStreamMockRecorder) SendMsg(m interface{}) *gomock.Call

+ type Predicate interface

+ Match func(conn Connection) bool

+ func ByConnected() Predicate

+ func ByNodeDID(nodeDID did.DID) Predicate

+ func ByNotConnected() Predicate

+ func ByPeerID(peerID transport.PeerID) Predicate

+ type Protocol interface

+ CreateClientStream func(outgoingContext context.Context, grpcConn grpc.ClientConnInterface) (grpc.ClientStream, error)

+ CreateEnvelope func() interface{}

+ Handle func(peer transport.Peer, envelope interface{}) error

+ MethodName func() string

+ Register func(registrar grpc.ServiceRegistrar, acceptor func(stream grpc.ServerStream) error, ...)

+ UnwrapMessage func(envelope interface{}) interface{}

+ type Stream interface

+ Context func() context.Context

+ RecvMsg func(m interface{}) error

+ SendMsg func(m interface{}) error

+ type StubConnection struct

+ NodeDID did.DID

+ Open bool

+ PeerID transport.PeerID

+ SentMsgs []interface{}

+ func (s *StubConnection) Send(_ Protocol, envelope interface{}) error

+ func (s StubConnection) IsConnected() bool

+ func (s StubConnection) Peer() transport.Peer

+ type StubConnectionList struct

+ Conn *StubConnection

+ func (s *StubConnectionList) Get(query ...Predicate) Connection

+ func (s StubConnectionList) All() []Connection

+ type StubStreamReceiver struct

+ ExpectedError error

+ ExpectedMessage proto.Message

+ func (s *StubStreamReceiver) RecvMsg(m interface{}) error

+ type TestClient interface

+ DoStuff func(ctx context.Context, opts ...grpc.CallOption) (Test_DoStuffClient, error)

+ func NewTestClient(cc grpc.ClientConnInterface) TestClient

+ type TestMessage struct

+ Data []byte

+ func (*TestMessage) Descriptor() ([]byte, []int)

+ func (*TestMessage) ProtoMessage()

+ func (x *TestMessage) GetData() []byte

+ func (x *TestMessage) ProtoReflect() protoreflect.Message

+ func (x *TestMessage) Reset()

+ func (x *TestMessage) String() string

+ type TestNodeDIDResolver struct

+ func (s TestNodeDIDResolver) Resolve() (did.DID, error)

+ type TestProtocol struct

+ func (s *TestProtocol) CreateClientStream(outgoingContext context.Context, grpcConn grpc.ClientConnInterface) (grpc.ClientStream, error)

+ func (s *TestProtocol) CreateEnvelope() interface{}

+ func (s *TestProtocol) DoStuff(serverStream Test_DoStuffServer) error

+ func (s *TestProtocol) Handle(peer transport.Peer, envelope interface{}) error

+ func (s *TestProtocol) MethodName() string

+ func (s *TestProtocol) Register(registrar grpc.ServiceRegistrar, acceptor func(stream grpc.ServerStream) error, ...)

+ func (s *TestProtocol) UnwrapMessage(envelope interface{}) interface{}

+ func (s *TestProtocol) Version() int

+ func (s TestProtocol) Configure(_ transport.PeerID) error

+ func (s TestProtocol) Diagnostics() []core.DiagnosticResult

+ func (s TestProtocol) PeerDiagnostics() map[transport.PeerID]transport.Diagnostics

+ func (s TestProtocol) Start() error

+ func (s TestProtocol) Stop()

+ type TestServer interface

+ DoStuff func(Test_DoStuffServer) error

+ type Test_DoStuffClient interface

+ Recv func() (*TestMessage, error)

+ Send func(*TestMessage) error

+ type Test_DoStuffServer interface

+ Recv func() (*TestMessage, error)

+ Send func(*TestMessage) error

+ type UnimplementedTestServer struct

+ func (UnimplementedTestServer) DoStuff(Test_DoStuffServer) error

+ type UnsafeTestServer interface