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

comm

package

Go to main page

Versions in this module

v2

v2.0.1

Feb 26, 2020

v2.0.0

Jan 29, 2020

Changes in this version

+ var DefaultConnectionTimeout = 5 * time.Second

+ var DefaultKeepaliveOptions = KeepaliveOptions

+ var DefaultTLSCipherSuites = []uint16

+ var ErrClientHandshakeNotImplemented = errors.New("core/comm: client handshakes are not implemented with serverCreds")

+ var ErrOverrideHostnameNotSupported = errors.New("core/comm: OverrideServerName is not supported")

+ var ErrServerHandshakeNotImplemented = errors.New("core/comm: server handshakes are not implemented with clientCreds")

+ var MaxRecvMsgSize = 100 * 1024 * 1024

+ var MaxSendMsgSize = 100 * 1024 * 1024

+ func AddPemToCertPool(pemCerts []byte, pool *x509.CertPool) error

+ func ClientKeepaliveOptions(ka KeepaliveOptions) []grpc.DialOption

+ func ExtractCertificateFromContext(ctx context.Context) *x509.Certificate

+ func ExtractCertificateHashFromContext(ctx context.Context) []byte

+ func ExtractRawCertificateFromContext(ctx context.Context) []byte

+ func GetLocalIP() (string, error)

+ func NewServerTransportCredentials(serverConfig *tls.Config, logger *flogging.FabricLogger) credentials.TransportCredentials

+ func ServerKeepaliveOptions(ka KeepaliveOptions) []grpc.ServerOption

+ type BindingInspector func(context.Context, proto.Message) error

+ func NewBindingInspector(mutualTLS bool, extractTLSCertHash CertHashExtractor) BindingInspector

+ type CertHashExtractor func(proto.Message) []byte

+ type ClientConfig struct

+ AsyncConnect bool

+ KaOpts KeepaliveOptions

+ SecOpts SecureOptions

+ Timeout time.Duration

+ func (cc ClientConfig) Clone() ClientConfig

+ type CredentialSupport struct

+ func NewCredentialSupport(rootCAs ...[]byte) *CredentialSupport

+ func (cs *CredentialSupport) AppRootCAsByChain() map[string][][]byte

+ func (cs *CredentialSupport) BuildTrustedRootsForChain(cm channelconfig.Resources)

+ func (cs *CredentialSupport) GetClientCertificate() tls.Certificate

+ func (cs *CredentialSupport) GetPeerCredentials() credentials.TransportCredentials

+ func (cs *CredentialSupport) SetClientCertificate(cert tls.Certificate)

+ type DynamicClientCredentials struct

+ TLSConfig *tls.Config

+ TLSOptions []TLSOption

+ func (dtc *DynamicClientCredentials) ClientHandshake(ctx context.Context, authority string, rawConn net.Conn) (net.Conn, credentials.AuthInfo, error)

+ func (dtc *DynamicClientCredentials) Clone() credentials.TransportCredentials

+ func (dtc *DynamicClientCredentials) Info() credentials.ProtocolInfo

+ func (dtc *DynamicClientCredentials) OverrideServerName(name string) error

+ func (dtc *DynamicClientCredentials) ServerHandshake(rawConn net.Conn) (net.Conn, credentials.AuthInfo, error)

+ type GRPCClient struct

+ func NewGRPCClient(config ClientConfig) (*GRPCClient, error)

+ func (client *GRPCClient) Certificate() tls.Certificate

+ func (client *GRPCClient) MutualTLSRequired() bool

+ func (client *GRPCClient) NewConnection(address string, tlsOptions ...TLSOption) (*grpc.ClientConn, error)

+ func (client *GRPCClient) SetMaxRecvMsgSize(size int)

+ func (client *GRPCClient) SetMaxSendMsgSize(size int)

+ func (client *GRPCClient) SetServerRootCAs(serverRoots [][]byte) error

+ func (client *GRPCClient) TLSEnabled() bool

+ type GRPCServer struct

+ func NewGRPCServer(address string, serverConfig ServerConfig) (*GRPCServer, error)

+ func NewGRPCServerFromListener(listener net.Listener, serverConfig ServerConfig) (*GRPCServer, error)

+ func (gServer *GRPCServer) Address() string

+ func (gServer *GRPCServer) AppendClientRootCAs(clientRoots [][]byte) error

+ func (gServer *GRPCServer) Listener() net.Listener

+ func (gServer *GRPCServer) MutualTLSRequired() bool

+ func (gServer *GRPCServer) Server() *grpc.Server

+ func (gServer *GRPCServer) ServerCertificate() tls.Certificate

+ func (gServer *GRPCServer) SetClientRootCAs(clientRoots [][]byte) error

+ func (gServer *GRPCServer) SetServerCertificate(cert tls.Certificate)

+ func (gServer *GRPCServer) Start() error

+ func (gServer *GRPCServer) Stop()

+ func (gServer *GRPCServer) TLSEnabled() bool

+ type KeepaliveOptions struct

+ ClientInterval time.Duration

+ ClientTimeout time.Duration

+ ServerInterval time.Duration

+ ServerMinInterval time.Duration

+ ServerTimeout time.Duration

+ type Metrics struct

+ ClosedConnCounter metrics.Counter

+ OpenConnCounter metrics.Counter

+ type SecureOptions struct

+ Certificate []byte

+ CipherSuites []uint16

+ ClientRootCAs [][]byte

+ Key []byte

+ RequireClientCert bool

+ ServerRootCAs [][]byte

+ TimeShift time.Duration

+ UseTLS bool

+ VerifyCertificate func(rawCerts [][]byte, verifiedChains [][]*x509.Certificate) error

+ type ServerConfig struct

+ ConnectionTimeout time.Duration

+ HealthCheckEnabled bool

+ KaOpts KeepaliveOptions

+ Logger *flogging.FabricLogger

+ SecOpts SecureOptions

+ ServerStatsHandler *ServerStatsHandler

+ StreamInterceptors []grpc.StreamServerInterceptor

+ UnaryInterceptors []grpc.UnaryServerInterceptor

+ type ServerStatsHandler struct

+ ClosedConnCounter metrics.Counter

+ OpenConnCounter metrics.Counter

+ func NewServerStatsHandler(p metrics.Provider) *ServerStatsHandler

+ func (h *ServerStatsHandler) HandleConn(ctx context.Context, s stats.ConnStats)

+ func (h *ServerStatsHandler) HandleRPC(ctx context.Context, s stats.RPCStats)

+ func (h *ServerStatsHandler) TagConn(ctx context.Context, info *stats.ConnTagInfo) context.Context

+ func (h *ServerStatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context

+ type TLSOption func(tlsConfig *tls.Config)

+ func CertPoolOverride(pool *x509.CertPool) TLSOption

+ func ServerNameOverride(name string) TLSOption

v2.0.0-beta

Dec 12, 2019

v2.0.0-alpha

Apr 9, 2019

Other modules containing this package

gopkg.in/hyperledger/fabric.v0

gopkg.in/hyperledger/fabric.v1