sync

type ClientFactory interface {
	Tag() string
	//opts just called at the beginning of ExecuteSyncTask so returned
	//object can be created just after being called
	Opts() *clientOpts
	PreFilter(rledger *pb.LedgerState) bool
	//notice this should provide a handling function and factory is
	//responsed to schedule tasks between its mutiple handling
	//functions
	//handling function MUST return nil to incidate current task
	//is finished and non-nil to indicate scheduler should retry
	//another peer
	AssignHandling() func(context.Context, *pb.StreamHandler, *syncCore) error
}

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

type ForceAck struct{}

type ISessionHandler interface {
	// contains filtered or unexported methods
}

type ISyncHandler interface {
	// contains filtered or unexported methods
}

type NewPeerHandshake struct{}

type NormalEnd struct{}

type SessionClientImpl interface {
	PreFilter(rledger *pb.LedgerState) bool
	//assign onconnect and next an id to distinguish the
	//different tasks, next can gen a user-custom object
	//and it was passed to OnData/Fail
	OnConnected(int, *pb.AcceptSession) error
	Next(int) (*pb.TransferRequest, interface{})
	//can return ForceAck or NormalEnd
	//if normalend is returned, Next() will
	//be call and the whole session is ended
	//if Next() return nil
	//Notice 1: if OnData return any error execpt
	//for ForceAck, session will end without
	//OnFail being called
	//Notice 2: we always ack when normal end
	OnData(interface{}, *pb.TransferResponse) error
	OnFail(interface{}, error)
}

type StateSyncer interface {
	GetTarget() []byte
	ApplySyncData(data *pb.SyncStateChunk) error
	AssignTasks() ([]*pb.SyncOffset, error)
}

type StreamFilter struct {
	*pb.PeerEndpoint
}

type SyncMsgPrefilter interface {
	ForSimple(*pb.SimpleReq) bool
	ForSession(*pb.OpenSession) bool
}

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