raftstore

type Cfg struct {
	DataPath         string
	StoreOptionsPath string
	Lables           []meta.Label

	ProphetName    string
	ProphetAddr    string
	ProphetOptions []prophet.Option

	// about raft
	ElectionTick           int
	HeartbeatTick          int
	MaxSizePerMsg          uint64
	MaxInflightMsgs        int
	MinRaftLogCount        uint64
	MaxRaftLogCount        uint64
	MaxRaftLogBytes        uint64
	MaxRaftLogLag          uint64
	MaxRaftEntryBytes      uint64
	MaxPeerDownTime        time.Duration
	RaftTickDuration       time.Duration
	RaftLogCompactDuration time.Duration
	RaftCheckSplitDuration time.Duration
	SyncWrite              bool

	// about batching
	MaxBatchingSize int

	// about db
	MaxDBRecords uint64

	// about worker
	ApplyWorkerCount    uint64
	SentRaftWorkerCount uint64
	SentSnapWorkerCount uint64

	// about snapshot
	LimitSnapChunkRate  int
	LimitSnapChunkBytes uint64

	// about prophet
	DBHBInterval    time.Duration
	StoreHBInterval time.Duration

	// about vectordb
	Dim                  int
	FlatThr              int
	DistThr              float32
	LimitRebuildIndex    int
	RebuildIndexDuration time.Duration

	// about mq
	Topic, GroupPrefix string
	MQAddrs            []string
}

type ContainerAdapter struct {
	// contains filtered or unexported fields
}

type Option func(*options)

type PeerReplicate struct {
	// contains filtered or unexported fields
}

type ProphetAdapter struct {
	// contains filtered or unexported fields
}

type ResourceAdapter struct {
	// contains filtered or unexported fields
}

type SnapshotManager interface {
	Register(msg *raftpb.SnapshotMessage, step int) bool
	Deregister(msg *raftpb.SnapshotMessage, step int)
	Create(msg *raftpb.SnapshotMessage) error
	Exists(msg *raftpb.SnapshotMessage) bool
	WriteTo(msg *raftpb.SnapshotMessage, conn goetty.IOSession) (uint64, error)
	CleanSnap(msg *raftpb.SnapshotMessage) error
	ReceiveSnapData(msg *raftpb.SnapshotMessage) error
	Apply(msg *raftpb.SnapshotMessage) error
}

type Store struct {
	// contains filtered or unexported fields
}