Versions in this module Expand all Collapse all v0 v0.0.1 Dec 10, 2019 Changes in this version + func WithClusterFunk(cluster funk.Cluster, shardFn ShardConversionFunc, ...) []grpc.ServerOption + type ProxyConnections struct + Cluster funk.Cluster + EndpointName string + Shards sharding.ShardMap + func NewProxyConnections(endpointName string, shards sharding.ShardMap, cluster funk.Cluster) *ProxyConnections + func (p *ProxyConnections) GetConnection(shard int) (*grpc.ClientConn, string, error) + func (p *ProxyConnections) Options() []grpc.DialOption + type ShardConversionFunc func(request interface{}) (shard int, response interface{})
Go to main page