sharding

type Cfg struct {
	Addr                string
	ShardingAddr        string
	DataPath            string
	Labels              []prophet.Pair
	ProphetName         string
	FragHBInterval      time.Duration
	StoreHBInterval     time.Duration
	MaxPeerDownDuration time.Duration
	RMLease             time.Duration
	CoreOptions         []core.Option
	InitFragments       int
	Concurrency         int
	OverloadPercentage  uint64
	OverloadPeriod      uint64
	TransSendCB         func(meta.ResourceManager, meta.Notify) error
	TransWorkerCount    int
	PRWorkerCount       int
	// contains filtered or unexported fields
}

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

type FragmentsState struct {
	FragmentCount, FragmentLeaderCount uint64
}

type PeerReplicate struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

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

type Seata struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Store interface {
	// Meta returns the current store's metadata
	Meta() meta.StoreMeta
	// Cfg returns the configuration
	Cfg() Cfg
	// Start start all fragments managed by the store
	Start()

	// FragmentsState returns the state of the fragments
	FragmentsState() FragmentsState
	// GetStoreAddr returns the store address
	GetStoreAddr(storeID uint64) (string, error)

	// LeaderPeer returns the fragment's leader peer
	LeaderPeer(fid uint64) (prophet.Peer, error)
	// CreateFragment create a new fragment and save it to the local data
	CreateFragment() meta.Fragment
	// MustPutFragment update the store's fragment metadata
	MustPutFragment(frag meta.Fragment)
	// GetFragment returns a fragment replicatation from the store,
	// when `leader` is true, only return the leader replicatation
	GetFragment(fid uint64, leader bool) *PeerReplicate

	// ForeachReplicate do something on every `replicatations`, break if the funcation return false
	ForeachReplicate(func(*PeerReplicate) bool)
	// AddReplicate add a replicatation
	AddReplicate(*PeerReplicate)
	// AddPeer add a peer to the exist fragment
	AddPeer(fid uint64, peer prophet.Peer)
	// RemovePeer remove the peer from the exist fragment
	RemovePeer(uint64, prophet.Peer)

	// Transport returns the seata message transport
	Transport() transport.Transport
	// ShardingTransport returns the sharding message transport
	ShardingTransport() Transport

	// HandleShardingMsg handle the sharding message, maybe returns a response.
	HandleShardingMsg(data interface{}) interface{}

	// AddRM add a resource manager
	AddRM(rms meta.ResourceManagerSet)
	// RenewRMLease renew the resource manager's lease
	RenewRMLease(pid, sid string)
}

type Transport interface {
	Start()
	Stop()

	Send(uint64, interface{})
}