Documentation
¶
Index ¶
- type Router
- func (r *Router) AllHostnames() []string
- func (r *Router) BuildReadRoutingPlan(params types.RoutingPlanBuildOptions) (types.RoutingPlan, error)
- func (r *Router) BuildWriteRoutingPlan(params types.RoutingPlanBuildOptions) (types.RoutingPlan, error)
- func (r *Router) GetReadReplicasLocation(collection string, shard string) ([]string, error)
- func (r *Router) GetReadWriteReplicasLocation(collection string, shard string) ([]string, []string, []string, error)
- func (r *Router) GetWriteReplicasLocation(collection string, shard string) ([]string, []string, error)
- func (r *Router) NodeHostname(nodeName string) (string, bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Router ¶
type Router struct {
// contains filtered or unexported fields
}
func New ¶
func New(logger *logrus.Logger, clusterStateReader cluster.NodeSelector, metadataReader schemaTypes.SchemaReader, replicationFSMReader replicationTypes.ReplicationFSMReader) *Router
func (*Router) AllHostnames ¶
func (*Router) BuildReadRoutingPlan ¶
func (r *Router) BuildReadRoutingPlan(params types.RoutingPlanBuildOptions) (types.RoutingPlan, error)
func (*Router) BuildWriteRoutingPlan ¶
func (r *Router) BuildWriteRoutingPlan(params types.RoutingPlanBuildOptions) (types.RoutingPlan, error)
func (*Router) GetReadReplicasLocation ¶
func (*Router) GetReadWriteReplicasLocation ¶
func (*Router) GetWriteReplicasLocation ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.