route

Documentation

Index

• type Addresser
  • func NewDiscoveryAddresser(discoveryClient discovery.Client) Addresser
  • func NewSingleAddresser(address string, numShards int) Addresser
• type Dialer
  • func NewDialer(opts ...grpc.DialOption) Dialer
• type Router
  • func NewRouter(addresser Addresser, dialer Dialer, localAddress string) Router
• type Sharder
  • func NewSharder(numShards int) Sharder

Types

type Addresser

type Addresser interface {
	GetMasterShards(address string) (map[int]bool, error)
	GetSlaveShards(address string) (map[int]bool, error)
	GetAllAddresses() ([]string, error)
}

func NewDiscoveryAddresser

func NewDiscoveryAddresser(discoveryClient discovery.Client) Addresser

func NewSingleAddresser

func NewSingleAddresser(address string, numShards int) Addresser

type Dialer

type Dialer interface {
	Dial(address string) (*grpc.ClientConn, error)
	Clean() error
}

func NewDialer

func NewDialer(opts ...grpc.DialOption) Dialer

type Router

type Router interface {
	GetMasterShards() (map[int]bool, error)
	GetSlaveShards() (map[int]bool, error)
	GetMasterClientConn(shard int) (*grpc.ClientConn, error)
	GetMasterOrSlaveClientConn(shard int) (*grpc.ClientConn, error)
	GetAllClientConns() ([]*grpc.ClientConn, error)
}

func NewRouter

func NewRouter(
	addresser Addresser,
	dialer Dialer,
	localAddress string,
) Router

type Sharder

type Sharder interface {
	NumShards() int
	GetShard(path *pfs.Path) (int, error)
}

func NewSharder

func NewSharder(numShards int) Sharder