Versions in this module Expand all Collapse all v0 v0.9.0 Jul 23, 2015 Changes in this version + type Addresser interface + GetAllAddresses func() ([]string, error) + GetMasterShards func(address string) (map[int]bool, error) + GetSlaveShards func(address string) (map[int]bool, error) + func NewDiscoveryAddresser(discoveryClient discovery.Client) Addresser + func NewSingleAddresser(address string, numShards int) Addresser + type Dialer interface + Clean func() error + Dial func(address string) (*grpc.ClientConn, error) + func NewDialer(opts ...grpc.DialOption) Dialer + type Router interface + GetAllClientConns func() ([]*grpc.ClientConn, error) + GetMasterClientConn func(shard int) (*grpc.ClientConn, error) + GetMasterOrSlaveClientConn func(shard int) (*grpc.ClientConn, error) + GetMasterShards func() (map[int]bool, error) + GetSlaveShards func() (map[int]bool, error) + func NewRouter(addresser Addresser, dialer Dialer, localAddress string) Router + type Sharder interface + GetShard func(path *pfs.Path) (int, error) + NumShards func() int + func NewSharder(numShards int) Sharder
Go to main page