comm

package

Go to main page

Versions in this module

v1

v1.4.7

May 14, 2020

Changes in this version

+ type TLSConfig struct

+ func NewTLSConfig(config *tls.Config) *TLSConfig

+ func (t *TLSConfig) AddClientRootCA(cert *x509.Certificate)

+ func (t *TLSConfig) Config() tls.Config

+ func (t *TLSConfig) SetClientCAs(certPool *x509.CertPool)

v1.4.6

Feb 25, 2020

v1.4.5

Feb 19, 2020

Changes in this version

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

+ 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 TLSOption func(tlsConfig *tls.Config)

v1.4.4

Nov 14, 2019

Changes in this version

+ type OrdererEndpoint struct

+ Address string

+ PEMs []byte

type ServerConfig

+ ServerStatsHandler *ServerStatsHandler

v1.4.3

Aug 26, 2019

Changes in this version

type SecureOptions

+ TimeShift time.Duration

v1.4.2

Jul 17, 2019

Changes in this version

+ type CertificateBundle [][]byte

type ClientConfig

+ func (cc ClientConfig) Clone() ClientConfig

+ type ConnProducer struct

+ func (cp *ConnProducer) GetEndpoints() []EndpointCriteria

+ func (cp *ConnProducer) NewConnection() (*grpc.ClientConn, string, error)

+ func (cp *ConnProducer) UpdateEndpoints(endpoints []EndpointCriteria)

type CredentialSupport

+ AppRootCAsByChain map[string]CertificateBundle

+ ClientRootCAs CertificateBundle

+ OrdererRootCAsByChainAndOrg OrgRootCAs

+ ServerRootCAs CertificateBundle

+ type EndpointCriteria struct

+ Endpoint string

+ Organizations []string

+ func (ec EndpointCriteria) Equals(other EndpointCriteria) bool

+ type OrgRootCAs map[string]PerOrgCertificateBundle

+ func (orc OrgRootCAs) AppendCertificates(channel string, org string, rootCAs CertificateBundle)

+ func (orc OrgRootCAs) CertificatesByChannelAndOrg(channel string, org string) CertificateBundle

+ type PerOrgCertificateBundle map[string]CertificateBundle

v1.4.1

Apr 11, 2019

Changes in this version

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

+ type NewSemaphoreFunc func(size int) Semaphore

+ type Semaphore interface

+ Acquire func(ctx context.Context) error

+ Release func()

+ type Throttle struct

+ func NewThrottle(maxConcurrency int, options ...ThrottleOption) *Throttle

+ func (t *Throttle) StreamServerInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error

+ func (t *Throttle) UnaryServerIntercptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

+ type ThrottleOption func(t *Throttle)

+ func WithNewSemaphore(newSemaphore NewSemaphoreFunc) ThrottleOption

v1.4.1-rc1

Mar 29, 2019

v1.4.0

Jan 9, 2019

Changes in this version

+ var ClientHandshakeNotImplError = errors.New(...)

+ var DefaultConnectionTimeout = 5 * time.Second

+ var DefaultKeepaliveOptions = &KeepaliveOptions

+ var DefaultTLSCipherSuites = []uint16

+ var EndpointDisableInterval = time.Second * 10

+ var MaxRecvMsgSize = 100 * 1024 * 1024

+ var MaxSendMsgSize = 100 * 1024 * 1024

+ var MissingServerConfigError = errors.New("core/comm: `serverConfig` cannot be nil")

+ var OverrrideHostnameNotSupportedError = errors.New(...)

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

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

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

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

+ func InitTLSForShim(key, certStr string) credentials.TransportCredentials

+ func NewClientConnectionWithAddress(peerAddress string, block bool, tslEnabled bool, ...) (*grpc.ClientConn, 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 CASupport struct

+ AppRootCAsByChain map[string][][]byte

+ ClientRootCAs [][]byte

+ OrdererRootCAsByChain map[string][][]byte

+ ServerRootCAs [][]byte

+ func (cas *CASupport) GetClientRootCAs() (appRootCAs, ordererRootCAs [][]byte)

+ func (cas *CASupport) GetServerRootCAs() (appRootCAs, ordererRootCAs [][]byte)

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

+ type ClientConfig struct

+ AsyncConnect bool

+ KaOpts *KeepaliveOptions

+ SecOpts *SecureOptions

+ Timeout time.Duration

+ type ConnectionFactory func(endpoint string) (*grpc.ClientConn, error)

+ type ConnectionProducer interface

+ DisableEndpoint func(endpoint string)

+ GetEndpoints func() []string

+ NewConnection func() (*grpc.ClientConn, string, error)

+ UpdateEndpoints func(endpoints []string)

+ func NewConnectionProducer(factory ConnectionFactory, endpoints []string) ConnectionProducer

+ type CredentialSupport struct

+ func GetCredentialSupport() *CredentialSupport

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

+ func (cs *CredentialSupport) GetDeliverServiceCredentials(channelID string) (credentials.TransportCredentials, error)

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

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

+ 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, serverNameOverride string) (*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) RemoveClientRootCAs(clientRoots [][]byte) error

+ 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

+ UseTLS bool

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

+ type ServerConfig struct

+ ConnectionTimeout time.Duration

+ KaOpts *KeepaliveOptions

+ Logger *flogging.FabricLogger

+ MetricsProvider metrics.Provider

+ SecOpts *SecureOptions

+ 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

v1.4.0-rc2

Dec 20, 2018

v1.4.0-rc1

Dec 10, 2018

Incompatible versions in this module

v2.0.1+incompatible

Feb 26, 2020

v2.0.0+incompatible

Jan 29, 2020

v2.0.0-beta+incompatible

Dec 12, 2019

v2.0.0-alpha+incompatible

Apr 9, 2019

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