gen

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

type AddPeersRequest struct {
	Id    string  `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Peers []*Peer `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

type AppendEntryReply struct {
	Id            string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,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"`
	ConflictIndex int64  `protobuf:"varint,4,opt,name=ConflictIndex,proto3" json:"ConflictIndex,omitempty"`
	ConflictTerm  int64  `protobuf:"varint,5,opt,name=ConflictTerm,proto3" json:"ConflictTerm,omitempty"`
	// contains filtered or unexported fields
}

type AppendEntryRequest struct {
	Id           string      `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Term         int64       `protobuf:"varint,2,opt,name=Term,proto3" json:"Term,omitempty"`
	Leader       *Peer       `protobuf:"bytes,3,opt,name=Leader,proto3" json:"Leader,omitempty"`
	PrevLogIndex int64       `protobuf:"varint,4,opt,name=PrevLogIndex,proto3" json:"PrevLogIndex,omitempty"`
	PrevLogTerm  int64       `protobuf:"varint,5,opt,name=PrevLogTerm,proto3" json:"PrevLogTerm,omitempty"`
	Entries      []*WalEntry `protobuf:"bytes,6,rep,name=Entries,proto3" json:"Entries,omitempty"`
	LeaderCommit int64       `protobuf:"varint,7,opt,name=LeaderCommit,proto3" json:"LeaderCommit,omitempty"`
	NextIndex    int64       `protobuf:"varint,8,opt,name=NextIndex,proto3" json:"NextIndex,omitempty"`
	// contains filtered or unexported fields
}

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

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

type ClusterStatusReply struct {
	Id         string         `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	PeerStatus []*StatusReply `protobuf:"bytes,2,rep,name=PeerStatus,proto3" json:"PeerStatus,omitempty"`
	// contains filtered or unexported fields
}

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

type ColumnValue struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

type CommandRequest struct {
	Id      string      `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Args    []byte      `protobuf:"bytes,2,opt,name=Args,proto3" json:"Args,omitempty"`
	CmdType CommandType `protobuf:"varint,3,opt,name=CmdType,proto3,enum=CommandType" json:"CmdType,omitempty"`
	// contains filtered or unexported fields
}

type CommandType int32

type ControllerServiceClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterReply, error)
	UnRegister(ctx context.Context, in *UnRegisterRequest, opts ...grpc.CallOption) (*UnRegisterReply, error)
	GetLeader(ctx context.Context, in *GetLeaderRequest, opts ...grpc.CallOption) (*GetLeaderReply, error)
}

type ControllerServiceServer interface {
	Register(context.Context, *RegisterRequest) (*RegisterReply, error)
	UnRegister(context.Context, *UnRegisterRequest) (*UnRegisterReply, error)
	GetLeader(context.Context, *GetLeaderRequest) (*GetLeaderReply, error)
	// contains filtered or unexported methods
}

type ExecuteQueryReply struct {
	Id           string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Error        string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	RowsAffected int64  `protobuf:"varint,3,opt,name=rowsAffected,proto3" json:"rowsAffected,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteQueryRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	StoreName string `protobuf:"bytes,2,opt,name=StoreName,proto3" json:"StoreName,omitempty"`
	SqlQuery  string `protobuf:"bytes,3,opt,name=SqlQuery,proto3" json:"SqlQuery,omitempty"`
	// contains filtered or unexported fields
}

type GetLeaderReply struct {
	Leader *Peer `protobuf:"bytes,1,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

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

type GetReply struct {
	Id    string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type GetRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	StoreName string `protobuf:"bytes,2,opt,name=StoreName,proto3" json:"StoreName,omitempty"`
	Key       string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

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

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

type Peer struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Port    int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

type PutReply struct {
	Id    string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type PutRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	StoreName string `protobuf:"bytes,2,opt,name=StoreName,proto3" json:"StoreName,omitempty"`
	Key       string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"`
	Value     string `protobuf:"bytes,4,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

type QueryReply struct {
	Id    string      `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Error string      `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	Rows  []*TableRow `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	StoreName string `protobuf:"bytes,2,opt,name=StoreName,proto3" json:"StoreName,omitempty"`
	SqlQuery  string `protobuf:"bytes,3,opt,name=SqlQuery,proto3" json:"SqlQuery,omitempty"`
	// contains filtered or unexported fields
}

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

type RegisterRequest struct {
	Server *Peer `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	// contains filtered or unexported fields
}

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

type RemovePeerRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Peer *Peer  `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	// contains filtered or unexported fields
}

type StatusReply struct {
	Id       string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Server   *Peer  `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"`
	Status   string `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"`
	IsLeader bool   `protobuf:"varint,4,opt,name=isLeader,proto3" json:"isLeader,omitempty"`
	// contains filtered or unexported fields
}

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

type StoreCreateReply struct {
	Id  string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

type StoreCreateRequest struct {
	Id   string    `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Name string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type StoreType `protobuf:"varint,3,opt,name=type,proto3,enum=StoreType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type StoreDeleteReply struct {
	Id    string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

type StoreDeleteRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	StoreName string `protobuf:"bytes,2,opt,name=StoreName,proto3" json:"StoreName,omitempty"`
	// contains filtered or unexported fields
}

type StoreType int32

type TableRow struct {
	Row []*ColumnValue `protobuf:"bytes,1,rep,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

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

type UnRegisterRequest struct {
	Server *Peer `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedControllerServiceServer struct {
}

type UnimplementedYadosServiceServer struct {
}

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

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

type VoteReply struct {
	Id            string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	VoteGranted   bool   `protobuf:"varint,2,opt,name=VoteGranted,proto3" json:"VoteGranted,omitempty"`
	CandidateName string `protobuf:"bytes,3,opt,name=CandidateName,proto3" json:"CandidateName,omitempty"`
	Term          int64  `protobuf:"varint,4,opt,name=Term,proto3" json:"Term,omitempty"`
	// contains filtered or unexported fields
}

type VoteRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Term          int64  `protobuf:"varint,2,opt,name=Term,proto3" json:"Term,omitempty"`
	CandidateName string `protobuf:"bytes,3,opt,name=CandidateName,proto3" json:"CandidateName,omitempty"`
	LastLogIndex  int64  `protobuf:"varint,4,opt,name=LastLogIndex,proto3" json:"LastLogIndex,omitempty"`
	LastLogTerm   int64  `protobuf:"varint,5,opt,name=LastLogTerm,proto3" json:"LastLogTerm,omitempty"`
	// contains filtered or unexported fields
}

type WalEntry struct {
	Term    int64       `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	Index   int64       `protobuf:"varint,2,opt,name=Index,proto3" json:"Index,omitempty"`
	Command *anypb.Any  `protobuf:"bytes,3,opt,name=Command,proto3" json:"Command,omitempty"`
	Id      string      `protobuf:"bytes,4,opt,name=Id,proto3" json:"Id,omitempty"`
	CmdType CommandType `protobuf:"varint,5,opt,name=CmdType,proto3,enum=CommandType" json:"CmdType,omitempty"`
	// contains filtered or unexported fields
}

type YadosServiceClient interface {
	RequestVotes(ctx context.Context, in *VoteRequest, opts ...grpc.CallOption) (*VoteReply, error)
	AppendEntries(ctx context.Context, in *AppendEntryRequest, opts ...grpc.CallOption) (*AppendEntryReply, error)
	AddPeers(ctx context.Context, in *AddPeersRequest, opts ...grpc.CallOption) (*AddPeersReply, error)
	RemovePeer(ctx context.Context, in *RemovePeerRequest, opts ...grpc.CallOption) (*RemovePeerReply, error)
	PeerStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusReply, error)
	ClusterStatus(ctx context.Context, in *ClusterStatusRequest, opts ...grpc.CallOption) (*ClusterStatusReply, error)
	CreateStore(ctx context.Context, in *StoreCreateRequest, opts ...grpc.CallOption) (*StoreCreateReply, error)
	ListStores(ctx context.Context, in *ListStoreRequest, opts ...grpc.CallOption) (*ListStoreReply, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutReply, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
	DeleteStore(ctx context.Context, in *StoreDeleteRequest, opts ...grpc.CallOption) (*StoreDeleteReply, error)
	ExecuteQuery(ctx context.Context, in *ExecuteQueryRequest, opts ...grpc.CallOption) (*ExecuteQueryReply, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryReply, error)
	GetLeader(ctx context.Context, in *GetLeaderRequest, opts ...grpc.CallOption) (*GetLeaderReply, error)
}

type YadosServiceServer interface {
	RequestVotes(context.Context, *VoteRequest) (*VoteReply, error)
	AppendEntries(context.Context, *AppendEntryRequest) (*AppendEntryReply, error)
	AddPeers(context.Context, *AddPeersRequest) (*AddPeersReply, error)
	RemovePeer(context.Context, *RemovePeerRequest) (*RemovePeerReply, error)
	PeerStatus(context.Context, *StatusRequest) (*StatusReply, error)
	ClusterStatus(context.Context, *ClusterStatusRequest) (*ClusterStatusReply, error)
	CreateStore(context.Context, *StoreCreateRequest) (*StoreCreateReply, error)
	ListStores(context.Context, *ListStoreRequest) (*ListStoreReply, error)
	Put(context.Context, *PutRequest) (*PutReply, error)
	Get(context.Context, *GetRequest) (*GetReply, error)
	DeleteStore(context.Context, *StoreDeleteRequest) (*StoreDeleteReply, error)
	ExecuteQuery(context.Context, *ExecuteQueryRequest) (*ExecuteQueryReply, error)
	Query(context.Context, *QueryRequest) (*QueryReply, error)
	GetLeader(context.Context, *GetLeaderRequest) (*GetLeaderReply, error)
	// contains filtered or unexported methods
}