grpc

package

Go to main page

Versions in this module

v0

v0.4.0

Jan 6, 2025

Changes in this version

type ConnectionConfig

+ TLSClientSideAuth bool

type SecureOptions

+ func CreateSecOpts(connConfig ConnectionConfig, cliConfig TLSClientConfig) (*SecureOptions, error)

+ type TLSClientConfig struct

+ TLSClientAuthRequired bool

+ TLSClientCertFile string

+ TLSClientKeyFile string

v0.3.0

Oct 5, 2023

Changes in this version

type ConnectionConfig

+ TLSDisabled bool

+ Usage string

v0.2.0

Dec 7, 2022

v0.1.0

Nov 16, 2022

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 GetTLSCertHash(cert *tls.Certificate, hasher Hasher) ([]byte, error)

+ func NewServerTransportCredentials(serverConfig *TLSConfig, 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 Client struct

+ func CreateGRPCClient(config *ConnectionConfig) (*Client, error)

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

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

+ func (client *Client) Close()

+ func (client *Client) MutualTLSRequired() bool

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

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

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

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

+ func (client *Client) TLSEnabled() bool

+ type ClientConfig struct

+ AsyncConnect bool

+ KaOpts KeepaliveOptions

+ SecOpts SecureOptions

+ Timeout time.Duration

+ func (cc ClientConfig) Clone() ClientConfig

+ type ConnectionConfig struct

+ Address string

+ ConnectionTimeout time.Duration

+ ServerNameOverride string

+ TLSEnabled bool

+ TLSRootCertBytes [][]byte

+ TLSRootCertFile string

+ type CredentialSupport struct

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

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

+ 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 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) 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 Hasher interface

+ Hash func(msg []byte) (hash []byte, err error)

+ type KeepaliveOptions struct

+ ClientInterval time.Duration

+ ClientTimeout time.Duration

+ ServerInterval time.Duration

+ ServerMinInterval time.Duration

+ ServerTimeout time.Duration

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

+ type TLSOption func(tlsConfig *tls.Config)

+ func CertPoolOverride(pool *x509.CertPool) TLSOption

+ func ServerNameOverride(name string) TLSOption

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