Versions in this module Expand all Collapse all v0 v0.0.1 Apr 26, 2024 Changes in this version + type Option func(o *options) + func WithClientCredentials(certFile string, serverName string) Option + func WithClientDialOptions(opts ...grpc.DialOption) Option + func WithClientDiscovery(discovery registry.Discovery) Option + func WithClientKeepAliveParams(time int, timeout int, permitWithoutStream bool) Option + func WithClientPoolSize(size int) Option + func WithServerCredentials(certFile, keyFile string) Option + func WithServerListenAddr(addr string) Option + func WithServerOptions(opts ...grpc.ServerOption) Option + type Transporter struct + func NewTransporter(opts ...Option) *Transporter + func (t *Transporter) NewGateClient(ep *endpoint.Endpoint) (transport.GateClient, error) + func (t *Transporter) NewGateServer(provider transport.GateProvider) (transport.Server, error) + func (t *Transporter) NewNodeClient(ep *endpoint.Endpoint) (transport.NodeClient, error) + func (t *Transporter) NewNodeServer(provider transport.NodeProvider) (transport.Server, error) + func (t *Transporter) NewServiceClient(target string) (transport.ServiceClient, error) + func (t *Transporter) NewServiceServer() (transport.Server, error) + func (t *Transporter) SetDefaultDiscovery(discovery registry.Discovery)