pb

type APIServiceClient interface {
	Apply(ctx context.Context, in *LogBody, opts ...grpc.CallOption) (*ApplyLogResponse, error)
	ApplyCommand(ctx context.Context, in *Command, opts ...grpc.CallOption) (*ApplyLogResponse, error)
}

type APIServiceServer interface {
	Apply(context.Context, *LogBody) (*ApplyLogResponse, error)
	ApplyCommand(context.Context, *Command) (*ApplyLogResponse, error)
	// contains filtered or unexported methods
}

type AppendEntriesRequest struct {
	Term         uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	LeaderId     string `protobuf:"bytes,2,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	LeaderCommit uint64 `protobuf:"varint,3,opt,name=leader_commit,json=leaderCommit,proto3" json:"leader_commit,omitempty"`
	PrevLogIndex uint64 `protobuf:"varint,4,opt,name=prev_log_index,json=prevLogIndex,proto3" json:"prev_log_index,omitempty"`
	PrevLogTerm  uint64 `protobuf:"varint,5,opt,name=prev_log_term,json=prevLogTerm,proto3" json:"prev_log_term,omitempty"`
	Entries      []*Log `protobuf:"bytes,7,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

type AppendEntriesResponse struct {
	ServerId string     `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	Term     uint64     `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Status   ReplStatus `protobuf:"varint,3,opt,name=status,proto3,enum=pb.ReplStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type ApplyLogRequest struct {
	Body *LogBody `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type ApplyLogResponse struct {

	// Types that are assignable to Response:
	//	*ApplyLogResponse_Meta
	//	*ApplyLogResponse_Error
	Response isApplyLogResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type ApplyLogResponse_Error struct {
	Error string `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type ApplyLogResponse_Meta struct {
	Meta *LogMeta `protobuf:"bytes,1,opt,name=meta,proto3,oneof"`
}

type Command struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

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

type Configuration struct {
	Current *Config `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	Next    *Config `protobuf:"bytes,2,opt,name=next,proto3" json:"next,omitempty"`
	// contains filtered or unexported fields
}

type InstallSnapshotRequestData struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type InstallSnapshotRequestMeta struct {
	Term              uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	LeaderId          string `protobuf:"bytes,2,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	LastIncludedIndex uint64 `protobuf:"varint,3,opt,name=last_included_index,json=lastIncludedIndex,proto3" json:"last_included_index,omitempty"`
	LastIncludedTerm  uint64 `protobuf:"varint,4,opt,name=last_included_term,json=lastIncludedTerm,proto3" json:"last_included_term,omitempty"`
	SnapshotMetadata  []byte `protobuf:"bytes,5,opt,name=snapshot_metadata,json=snapshotMetadata,proto3" json:"snapshot_metadata,omitempty"`
	// contains filtered or unexported fields
}

type InstallSnapshotResponse struct {
	Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	// contains filtered or unexported fields
}

type Log struct {
	Meta *LogMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Body *LogBody `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type LogArray []*Log

type LogBody struct {
	Type LogType `protobuf:"varint,1,opt,name=type,proto3,enum=pb.LogType" json:"type,omitempty"`
	Data []byte  `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type LogMeta struct {
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Term  uint64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	// contains filtered or unexported fields
}

type LogType int32

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

type PeerArray []*Peer

type ReplStatus int32

type RequestVoteRequest struct {
	Term         uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	CandidateId  string `protobuf:"bytes,2,opt,name=candidate_id,json=candidateId,proto3" json:"candidate_id,omitempty"`
	LastLogIndex uint64 `protobuf:"varint,3,opt,name=last_log_index,json=lastLogIndex,proto3" json:"last_log_index,omitempty"`
	LastLogTerm  uint64 `protobuf:"varint,4,opt,name=last_log_term,json=lastLogTerm,proto3" json:"last_log_term,omitempty"`
	// contains filtered or unexported fields
}

type RequestVoteResponse struct {
	ServerId string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	Term     uint64 `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"`
	Granted  bool   `protobuf:"varint,3,opt,name=granted,proto3" json:"granted,omitempty"`
	// contains filtered or unexported fields
}

type TransportClient interface {
	AppendEntries(ctx context.Context, in *AppendEntriesRequest, opts ...grpc.CallOption) (*AppendEntriesResponse, error)
	RequestVote(ctx context.Context, in *RequestVoteRequest, opts ...grpc.CallOption) (*RequestVoteResponse, error)
	InstallSnapshot(ctx context.Context, opts ...grpc.CallOption) (Transport_InstallSnapshotClient, error)
	ApplyLog(ctx context.Context, in *ApplyLogRequest, opts ...grpc.CallOption) (*ApplyLogResponse, error)
}

type TransportServer interface {
	AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesResponse, error)
	RequestVote(context.Context, *RequestVoteRequest) (*RequestVoteResponse, error)
	InstallSnapshot(Transport_InstallSnapshotServer) error
	ApplyLog(context.Context, *ApplyLogRequest) (*ApplyLogResponse, error)
	// contains filtered or unexported methods
}

type Transport_InstallSnapshotClient interface {
	Send(*InstallSnapshotRequestData) error
	CloseAndRecv() (*InstallSnapshotResponse, error)
	grpc.ClientStream
}

type Transport_InstallSnapshotServer interface {
	SendAndClose(*InstallSnapshotResponse) error
	Recv() (*InstallSnapshotRequestData, error)
	grpc.ServerStream
}

type UnimplementedAPIServiceServer struct {
}

type UnimplementedTransportServer struct {
}

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

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