raftchunking

type ApplyFunc func(raft.Log, time.Duration) raft.ApplyFuture

type ChunkInfo struct {
	OpNum       uint64
	SequenceNum uint32
	NumChunks   uint32
	Term        uint64
	Data        []byte
}

type ChunkMap map[uint64][]*ChunkInfo

type ChunkStorage interface {
	// StoreChunk stores Data from ChunkInfo according to the other metadata
	// (OpNum, SeqNum). The bool returns whether or not all chunks have been
	// received, as in, the number of non-nil chunks is the same as NumChunks.
	StoreChunk(*ChunkInfo) (bool, error)

	// FinalizeOp gets all chunks for an op number and then removes the chunk
	// info for that op from the store. It should only be called when
	// StoreChunk for a given op number returns true but should be safe to call
	// at any time; clearing an op can be accomplished by calling this function
	// and ignoring the non-error result.
	FinalizeOp(uint64) ([]*ChunkInfo, error)

	// GetState gets all currently tracked ops, for snapshotting
	GetChunks() (ChunkMap, error)

	// RestoreChunks restores the current FSM state from a map
	RestoreChunks(ChunkMap) error
}

type ChunkingBatchingFSM struct {
	*ChunkingFSM
	// contains filtered or unexported fields
}

type ChunkingConfigurationStore struct {
	*ChunkingFSM
	// contains filtered or unexported fields
}

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

type ChunkingSuccess struct {
	Response interface{}
}

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

type State struct {
	ChunkMap ChunkMap
}