types

type ApplyRequest struct {
	proto.Envelope
	Instance string
	Log      *Log
}

type FetchRequest struct {
	proto.Envelope
	Instance string
	Index    uint64
}

type FetchResponse struct {
	proto.Envelope
	Instance string
	Log      *Log
}

type Handler interface {
	EncodePayload(req interface{}) (data []byte, err error)
	DecodePayload(data []byte) (req interface{}, err error)
	Check(request interface{}) error
	Commit(request interface{}, isLeader bool) (result interface{}, err error)
}

type Log struct {
	LogHeader
	// Data could be detected and handle decode properly by log layer
	Data []byte
}

type LogHeader struct {
	Index      uint64       // log index
	Version    uint64       // log version
	Type       LogType      // log type
	Producer   proto.NodeID // producer node
	DataLength uint64       // data length
}

type LogType uint16

type RuntimeConfig struct {
	// underlying handler.
	Handler Handler
	// minimum rpc success node percent requirement for prepare operation.
	PrepareThreshold float64
	// minimum rpc success node percent requirement for commit operation.
	CommitThreshold float64
	// maximum allowed time for prepare operation.
	PrepareTimeout time.Duration
	// maximum allowed time for commit operation.
	CommitTimeout time.Duration
	// init peers of node.
	Peers *proto.Peers
	// wal for kayak.
	Wal Wal
	// current node id.
	NodeID proto.NodeID
	// current instance id.
	InstanceID string
	// mux service name.
	ServiceName string
	// apply service method.
	ApplyMethodName string
	// fetch service method.
	FetchMethodName string
	// fetch timeout.
	LogWaitTimeout time.Duration
}

type Wal interface {
	// sequential write
	Write(*Log) error
	// sequential read, return io.EOF if there is no more records to read
	Read() (*Log, error)
	// random access
	Get(index uint64) (*Log, error)
}