Affected by 
Documentation
¶
Index ¶
- type Copier
- func (c *Copier) AddAsyncReplicationTargetNode(ctx context.Context, ...) error
- func (c *Copier) AsyncReplicationStatus(ctx context.Context, srcNodeId, targetNodeId, collectionName, shardName string) (models.AsyncReplicationStatus, error)
- func (c *Copier) CopyReplicaFiles(ctx context.Context, srcNodeId, collectionName, shardName string, ...) error
- func (c *Copier) InitAsyncReplicationLocally(ctx context.Context, collectionName, shardName string) error
- func (c *Copier) LoadLocalShard(ctx context.Context, collectionName, shardName string) error
- func (c *Copier) RemoveAsyncReplicationTargetNode(ctx context.Context, ...) error
- func (c *Copier) RevertAsyncReplicationLocally(ctx context.Context, collectionName, shardName string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Copier ¶
type Copier struct {
// contains filtered or unexported fields
}
Copier for shard replicas, can copy a shard replica from one node to another.
func New ¶
func New(t types.RemoteIndex, nodeSelector cluster.NodeSelector, rootPath string, dbWrapper types.DbWrapper, logger logrus.FieldLogger) *Copier
New creates a new shard replica Copier.
func (*Copier) AddAsyncReplicationTargetNode ¶
func (c *Copier) AddAsyncReplicationTargetNode(ctx context.Context, targetNodeOverride additional.AsyncReplicationTargetNodeOverride, schemaVersion uint64) error
AddAsyncReplicationTargetNode adds a target node override for a shard.
func (*Copier) AsyncReplicationStatus ¶
func (c *Copier) AsyncReplicationStatus(ctx context.Context, srcNodeId, targetNodeId, collectionName, shardName string) (models.AsyncReplicationStatus, error)
AsyncReplicationStatus returns the async replication status for a shard. The first two return values are the number of objects propagated and the start diff time in unix milliseconds.
func (*Copier) CopyReplicaFiles ¶
func (c *Copier) CopyReplicaFiles(ctx context.Context, srcNodeId, collectionName, shardName string, schemaVersion uint64) error
CopyReplicaFiles copies a shard replica from the source node to this node.
func (*Copier) InitAsyncReplicationLocally ¶
func (*Copier) LoadLocalShard ¶
func (*Copier) RemoveAsyncReplicationTargetNode ¶
func (c *Copier) RemoveAsyncReplicationTargetNode(ctx context.Context, targetNodeOverride additional.AsyncReplicationTargetNodeOverride) error
RemoveAsyncReplicationTargetNode removes a target node override for a shard.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.