surfstore

type AppendEntryInput struct {
	Term         int64              `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	LeaderId     int64              `protobuf:"varint,2,opt,name=leaderId,proto3" json:"leaderId,omitempty"`
	PrevLogIndex int64              `protobuf:"varint,3,opt,name=prevLogIndex,proto3" json:"prevLogIndex,omitempty"`
	PrevLogTerm  int64              `protobuf:"varint,4,opt,name=prevLogTerm,proto3" json:"prevLogTerm,omitempty"`
	Entries      []*UpdateOperation `protobuf:"bytes,5,rep,name=entries,proto3" json:"entries,omitempty"`
	LeaderCommit int64              `protobuf:"varint,6,opt,name=leaderCommit,proto3" json:"leaderCommit,omitempty"`
	// contains filtered or unexported fields
}

type AppendEntryOutput struct {
	ServerId     int64 `protobuf:"varint,1,opt,name=serverId,proto3" json:"serverId,omitempty"`
	Term         int64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Success      bool  `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
	MatchedIndex int64 `protobuf:"varint,4,opt,name=matchedIndex,proto3" json:"matchedIndex,omitempty"`
	// contains filtered or unexported fields
}

type Block struct {
	BlockData []byte `protobuf:"bytes,1,opt,name=blockData,proto3" json:"blockData,omitempty"`
	BlockSize int32  `protobuf:"varint,2,opt,name=blockSize,proto3" json:"blockSize,omitempty"`
	// contains filtered or unexported fields
}

type BlockHash struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

type BlockHashes struct {
	Hashes []string `protobuf:"bytes,1,rep,name=hashes,proto3" json:"hashes,omitempty"`
	// contains filtered or unexported fields
}

type BlockStore struct {
	BlockMap map[string]*Block
	UnimplementedBlockStoreServer
}

type BlockStoreAddrs struct {
	BlockStoreAddrs []string `protobuf:"bytes,1,rep,name=blockStoreAddrs,proto3" json:"blockStoreAddrs,omitempty"`
	// contains filtered or unexported fields
}

type BlockStoreClient interface {
	GetBlock(ctx context.Context, in *BlockHash, opts ...grpc.CallOption) (*Block, error)
	PutBlock(ctx context.Context, in *Block, opts ...grpc.CallOption) (*Success, error)
	MissingBlocks(ctx context.Context, in *BlockHashes, opts ...grpc.CallOption) (*BlockHashes, error)
	GetBlockHashes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*BlockHashes, error)
}

type BlockStoreInterface interface {

	// Get a block based on
	GetBlock(ctx context.Context, blockHash *BlockHash) (*Block, error)

	// Put a block
	PutBlock(ctx context.Context, block *Block) (*Success, error)

	// Given a list of hashes “in”, returns a list containing the
	// subset of in that are NOT stored in the key-value store
	MissingBlocks(ctx context.Context, blockHashesIn *BlockHashes) (*BlockHashes, error)

	// Get which blocks are on this BlockStore server
	GetBlockHashes(ctx context.Context, _ *emptypb.Empty) (*BlockHashes, error)
}

type BlockStoreMap struct {
	BlockStoreMap map[string]*BlockHashes `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

type BlockStoreServer interface {
	GetBlock(context.Context, *BlockHash) (*Block, error)
	PutBlock(context.Context, *Block) (*Success, error)
	MissingBlocks(context.Context, *BlockHashes) (*BlockHashes, error)
	GetBlockHashes(context.Context, *empty.Empty) (*BlockHashes, error)
	// contains filtered or unexported methods
}

type ClientInterface interface {
	// MetaStore
	GetFileInfoMap(serverFileInfoMap *map[string]*FileMetaData) error
	UpdateFile(fileMetaData *FileMetaData) (int32, error)
	GetBlockStoreMap(blockHashesIn []string, blockStoreMap *map[string][]string) error
	GetBlockStoreAddrs(blockStoreAddrs *[]string) error

	// BlockStore
	GetBlock(blockHash string, blockStoreAddr string, block *Block) error
	PutBlock(block *Block, blockStoreAddr string) (bool, error)
	MissingBlocks(blockHashesIn []string, blockStoreAddr string, blockHashesOut *[]string) error
	GetBlockHashes(blockStoreAddr string, blockHashes *[]string) error
}

type ConsistentHashRing struct {
	ServerMap map[string]string
}

type FileInfoMap struct {
	FileInfoMap map[string]*FileMetaData `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

type FileMetaData struct {
	Filename      string   `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Version       int32    `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	BlockHashList []string `protobuf:"bytes,3,rep,name=blockHashList,proto3" json:"blockHashList,omitempty"`
	// contains filtered or unexported fields
}

type MetaStore struct {
	FileMetaMap        map[string]*FileMetaData
	BlockStoreAddrs    []string
	ConsistentHashRing *ConsistentHashRing
	UnimplementedMetaStoreServer
}

type MetaStoreClient interface {
	GetFileInfoMap(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*FileInfoMap, error)
	UpdateFile(ctx context.Context, in *FileMetaData, opts ...grpc.CallOption) (*Version, error)
	GetBlockStoreMap(ctx context.Context, in *BlockHashes, opts ...grpc.CallOption) (*BlockStoreMap, error)
	GetBlockStoreAddrs(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*BlockStoreAddrs, error)
}

type MetaStoreInterface interface {
	// Retrieves the server's FileInfoMap
	GetFileInfoMap(ctx context.Context, _ *emptypb.Empty) (*FileInfoMap, error)

	// Update a file's fileinfo entry
	UpdateFile(ctx context.Context, fileMetaData *FileMetaData) (*Version, error)

	// Retrieve the mapping of BlockStore addresses to block hashes
	GetBlockStoreMap(ctx context.Context, blockHashesIn *BlockHashes) (*BlockStoreMap, error)

	// Retrieve all BlockStore Addresses
	GetBlockStoreAddrs(ctx context.Context, _ *emptypb.Empty) (*BlockStoreAddrs, error)
}

type MetaStoreServer interface {
	GetFileInfoMap(context.Context, *empty.Empty) (*FileInfoMap, error)
	UpdateFile(context.Context, *FileMetaData) (*Version, error)
	GetBlockStoreMap(context.Context, *BlockHashes) (*BlockStoreMap, error)
	GetBlockStoreAddrs(context.Context, *empty.Empty) (*BlockStoreAddrs, error)
	// contains filtered or unexported methods
}

type RPCClient struct {
	MetaStoreAddrs []string
	BaseDir        string
	BlockSize      int
}

type RaftConfig struct {
	RaftAddrs  []string
	BlockAddrs []string
}

type RaftInterface interface {
	AppendEntries(ctx context.Context, input *AppendEntryInput) (*AppendEntryOutput, error)
	SetLeader(ctx context.Context, _ *emptypb.Empty) (*Success, error)
	SendHeartbeat(ctx context.Context, _ *emptypb.Empty) (*Success, error)
}

type RaftInternalState struct {
	Status      ServerStatus       `protobuf:"varint,1,opt,name=status,proto3,enum=surfstore.ServerStatus" json:"status,omitempty"`
	Term        int64              `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	CommitIndex int64              `protobuf:"varint,3,opt,name=commitIndex,proto3" json:"commitIndex,omitempty"`
	Log         []*UpdateOperation `protobuf:"bytes,4,rep,name=log,proto3" json:"log,omitempty"`
	MetaMap     *FileInfoMap       `protobuf:"bytes,5,opt,name=metaMap,proto3" json:"metaMap,omitempty"`
	// contains filtered or unexported fields
}

type RaftSurfstore struct {
	UnimplementedRaftSurfstoreServer
	// contains filtered or unexported fields
}

type RaftSurfstoreClient interface {
	// Raft
	AppendEntries(ctx context.Context, in *AppendEntryInput, opts ...grpc.CallOption) (*AppendEntryOutput, error)
	SetLeader(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Success, error)
	SendHeartbeat(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Success, error)
	// Metastore
	GetFileInfoMap(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*FileInfoMap, error)
	UpdateFile(ctx context.Context, in *FileMetaData, opts ...grpc.CallOption) (*Version, error)
	GetBlockStoreMap(ctx context.Context, in *BlockHashes, opts ...grpc.CallOption) (*BlockStoreMap, error)
	GetBlockStoreAddrs(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*BlockStoreAddrs, error)
	// Testing Interface
	MakeServerUnreachableFrom(ctx context.Context, in *UnreachableFromServers, opts ...grpc.CallOption) (*Success, error)
	Crash(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Success, error)
	Restore(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Success, error)
	GetInternalState(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*RaftInternalState, error)
}

type RaftSurfstoreInterface interface {
	MetaStoreInterface
	RaftInterface
	RaftTestingInterface
}

type RaftSurfstoreServer interface {
	// Raft
	AppendEntries(context.Context, *AppendEntryInput) (*AppendEntryOutput, error)
	SetLeader(context.Context, *empty.Empty) (*Success, error)
	SendHeartbeat(context.Context, *empty.Empty) (*Success, error)
	// Metastore
	GetFileInfoMap(context.Context, *empty.Empty) (*FileInfoMap, error)
	UpdateFile(context.Context, *FileMetaData) (*Version, error)
	GetBlockStoreMap(context.Context, *BlockHashes) (*BlockStoreMap, error)
	GetBlockStoreAddrs(context.Context, *empty.Empty) (*BlockStoreAddrs, error)
	// Testing Interface
	MakeServerUnreachableFrom(context.Context, *UnreachableFromServers) (*Success, error)
	Crash(context.Context, *empty.Empty) (*Success, error)
	Restore(context.Context, *empty.Empty) (*Success, error)
	GetInternalState(context.Context, *empty.Empty) (*RaftInternalState, error)
	// contains filtered or unexported methods
}

type RaftTestingInterface interface {
	GetInternalState(ctx context.Context, _ *emptypb.Empty) (*RaftInternalState, error)
	Crash(ctx context.Context, _ *emptypb.Empty) (*Success, error)
	MakeServerUnreachableFrom(ctx context.Context, servers *UnreachableFromServers) (*Success, error)
	Restore(ctx context.Context, _ *emptypb.Empty) (*Success, error)
}

type ServerStatus int32

type Success struct {
	Flag bool `protobuf:"varint,1,opt,name=flag,proto3" json:"flag,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedBlockStoreServer struct {
}

type UnimplementedMetaStoreServer struct {
}

type UnimplementedRaftSurfstoreServer struct {
}

type UnreachableFromServers struct {
	ServerIds []int64 `protobuf:"varint,1,rep,packed,name=serverIds,proto3" json:"serverIds,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type UpdateOperation struct {
	Term         int64         `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	FileMetaData *FileMetaData `protobuf:"bytes,2,opt,name=fileMetaData,proto3" json:"fileMetaData,omitempty"`
	// contains filtered or unexported fields
}

type Version struct {
	Version int32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}