Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + var ErrBootstrapEnqueued = errors.New("database bootstrapping enqueued bootstrap") + var ErrDatanodeIsBootstrapping = errors.New("datanode is bootstrapping") + var ErrDatanodeNotBootstrapped = errors.New("datanode is not yet bootstrapped") + var ErrTableShardIsBootstrapping = errors.New("table shard is bootstrapping") + var ErrTableShardNotBootstrappedToFlush = errors.New("table shard is not yet bootstrapped to flush") + var ErrTableShardNotBootstrappedToRead = errors.New("table shard is not yet bootstrapped to read") + var ErrTableShardNotBootstrappedToSnapshot = errors.New("table shard is not yet bootstrapped to snapshot") + func NewPeerDataNodeServer(metaStore common.MetaStore, diskStore diskstore.DiskStore) pb.PeerDataNodeServer + type BootstrapDetails interface + AddVPToCopy func(batch int32, columnID uint32) + Clear func() + MarkVPFinished func(batch int32, columnID uint32) + SetBootstrapStage func(stage BootstrapStage) + SetNumColumns func(numColumns int) + SetSource func(source string) + func NewBootstrapDetails() BootstrapDetails + type BootstrapStage string + const Finished + const PeerCopy + const Preload + const Recovery + const Waiting + type BootstrapState int + const BootstrapNotStarted + const Bootstrapped + const Bootstrapping + type Bootstrapable interface + Bootstrap func(peerSource client.PeerSource, origin string, topo topology.Topology, ...) error + type Options interface + BootstrapSessionTTL func() int64 + MaxConcurrentStreamsPerTableShards func() int + MaxConcurrentTableShards func() int + SetBootstrapSessionTTL func(ttl int64) Options + SetMaxConcurrentShards func(numShards int) Options + SetMaxConcurrentStreamsPerTableShards func(numStreams int) Options + func NewOptions() Options + type PeerDataNodeServerImpl struct + func (p *PeerDataNodeServerImpl) AcquireToken(tableName string, shardID uint32) bool + func (p *PeerDataNodeServerImpl) BenchmarkFileTransfer(req *pb.BenchmarkRequest, stream pb.PeerDataNode_BenchmarkFileTransferServer) error + func (p *PeerDataNodeServerImpl) FetchTableShardMetaData(ctx context.Context, req *pb.TableShardMetaDataRequest) (*pb.TableShardMetaData, error) + func (p *PeerDataNodeServerImpl) FetchVectorPartyRawData(req *pb.VectorPartyRawDataRequest, ...) error + func (p *PeerDataNodeServerImpl) Health(ctx context.Context, req *pb.HealthCheckRequest) (*pb.HealthCheckResponse, error) + func (p *PeerDataNodeServerImpl) KeepAlive(stream pb.PeerDataNode_KeepAliveServer) error + func (p *PeerDataNodeServerImpl) ReleaseToken(tableName string, shardID uint32) + func (p *PeerDataNodeServerImpl) StartSession(ctx context.Context, req *pb.StartSessionRequest) (*pb.Session, error)
Go to main page