chordpb

type ChordClient interface {
	// Find the successor of the given ID
	FindSuccessor(ctx context.Context, in *PeerID, opts ...grpc.CallOption) (*Node, error)
	// Get the current predecessor of a node
	GetPredecessor(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Node, error)
	// A Node thinks it is our predecessor and it is notifying us!
	Notify(ctx context.Context, in *Node, opts ...grpc.CallOption) (*Empty, error)
	// Check if predecessor is still alive
	CheckPredecessor(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// Get successor list of a node
	GetSuccessorList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SuccessorList, error)
	// Receive coordinator messages from nodes who are the cooridinators
	// for replica groups around the chord ring
	RecvCoordinatorMsg(ctx context.Context, in *CoordinatorMsg, opts ...grpc.CallOption) (*Empty, error)
	// Get keys we are responsible for from a node (typically a new node calls this on their successor)
	GetKeys(ctx context.Context, in *PeerID, opts ...grpc.CallOption) (*KVs, error)
	// Receive replica KV pairs from the leader of the replica group
	SendReplicas(ctx context.Context, in *ReplicaMsg, opts ...grpc.CallOption) (*Empty, error)
	// Remove replica KV pairs
	RemoveReplicas(ctx context.Context, in *ReplicaMsg, opts ...grpc.CallOption) (*Empty, error)
	// Get a value
	Get(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Value, error)
	// Create a new key-value pair
	Put(ctx context.Context, in *KV, opts ...grpc.CallOption) (*Empty, error)
	// Locate the node containing a key
	Locate(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Node, error)
}

type ChordServer interface {
	// Find the successor of the given ID
	FindSuccessor(context.Context, *PeerID) (*Node, error)
	// Get the current predecessor of a node
	GetPredecessor(context.Context, *Empty) (*Node, error)
	// A Node thinks it is our predecessor and it is notifying us!
	Notify(context.Context, *Node) (*Empty, error)
	// Check if predecessor is still alive
	CheckPredecessor(context.Context, *Empty) (*Empty, error)
	// Get successor list of a node
	GetSuccessorList(context.Context, *Empty) (*SuccessorList, error)
	// Receive coordinator messages from nodes who are the cooridinators
	// for replica groups around the chord ring
	RecvCoordinatorMsg(context.Context, *CoordinatorMsg) (*Empty, error)
	// Get keys we are responsible for from a node (typically a new node calls this on their successor)
	GetKeys(context.Context, *PeerID) (*KVs, error)
	// Receive replica KV pairs from the leader of the replica group
	SendReplicas(context.Context, *ReplicaMsg) (*Empty, error)
	// Remove replica KV pairs
	RemoveReplicas(context.Context, *ReplicaMsg) (*Empty, error)
	// Get a value
	Get(context.Context, *Key) (*Value, error)
	// Create a new key-value pair
	Put(context.Context, *KV) (*Empty, error)
	// Locate the node containing a key
	Locate(context.Context, *Key) (*Node, error)
}

type CoordinatorMsg struct {
	OldLeaderId []byte `protobuf:"bytes,1,opt,name=oldLeaderId,proto3" json:"oldLeaderId,omitempty"`
	NewLeaderId []byte `protobuf:"bytes,2,opt,name=newLeaderId,proto3" json:"newLeaderId,omitempty"`
	// contains filtered or unexported fields
}

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

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

type KVs struct {
	Kvs []*KV `protobuf:"bytes,1,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// contains filtered or unexported fields
}

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

type Node struct {
	Id   []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

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

type ReplicaMsg struct {
	LeaderId []byte `protobuf:"bytes,1,opt,name=leaderId,proto3" json:"leaderId,omitempty"`
	Kv       []*KV  `protobuf:"bytes,2,rep,name=kv,proto3" json:"kv,omitempty"`
	// contains filtered or unexported fields
}

type SuccessorList struct {
	Successors []*Node `protobuf:"bytes,1,rep,name=successors,proto3" json:"successors,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedChordServer struct {
}

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