raft.proto

syntax = "proto3";

package raft_pb;

import "google/api/annotations.proto";
import "google/api/http.proto";
import "protoc-gen-openapiv2/options/annotations.proto";
import "protoc-gen-openapiv2/options/openapiv2.proto";

option go_package = "github.com/escalopa/raft-kv/pkg/raft";

service RaftService {
  rpc AppendEntries(AppendEntriesRequest) returns (AppendEntriesResponse){
    option (google.api.http) = {
      post: "/raft/append-entry"
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      description: "Append entries to the log"
    };
  }

  rpc RequestVote(RequestVoteRequest) returns (RequestVoteResponse){
    option (google.api.http) = {
      post: "/raft/vote"
      body: "*"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      description: "RequestVote for a candidate"
    };
  }

  rpc Info(InfoRequest) returns (InfoResponse){
    option (google.api.http) = {
      get: "/raft/info"
    };
    option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation) = {
      description: "Get Raft node info"
    };
  }
}

message AppendEntriesRequest{
  uint64 term = 1;
  uint64 leader_id = 2;
  uint64 prev_log_term = 3;
  uint64 prev_log_index = 4;
  uint64 leader_commit = 5;
  repeated Entry entries = 6;
}

message AppendEntriesResponse{
  uint64 term = 1;
  bool success = 2;
  uint64 last_log_index = 3;
}

message RequestVoteRequest {
  uint64 term = 1;
  uint64 candidate_id = 2;
  uint64 last_log_term = 3;
  uint64 last_log_index = 4;
}

message RequestVoteResponse {
  uint64 term = 1;
  bool vote_granted = 2;
}

message InfoRequest {}

message InfoResponse {
  uint64 term = 1;
  uint64 commit_index = 2;
  uint64 last_applied = 3;
  uint64 last_log_index = 4;
  uint64 last_log_term = 5;
  string state = 6;
}

message Entry {
  uint64 term = 1;
  uint64 index = 2;
  repeated string data = 3;
}