nodepb

type Descriptor struct {

	// id within the ring. Any token whose value is equal or closer to this id
	// than any other id from other nodes will be assigned ownership to this
	// node.
	Id *ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Address of the node, used for both inter-node communication and for
	// clients to send requests.
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

type DescriptorHealth struct {

	// The peer this DescriptorHealth is for.
	Peer *Descriptor `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"`
	// The health of the peer.
	Health Health `protobuf:"varint,2,opt,name=health,proto3,enum=croissant.v1.Health" json:"health,omitempty"`
	// contains filtered or unexported fields
}

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

type GetStateResponse struct {

	// State holds the state of the node.
	State *State `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type GoodbyeRequest struct {

	// The node leaving the cluster.
	Node *Descriptor `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

type Health int32

type HelloRequest struct {

	// The node initiating the Hello.
	Initiator *Descriptor `protobuf:"bytes,1,opt,name=initiator,proto3" json:"initiator,omitempty"`
	// The next node, if any, that will also send a Hello.
	Next *Descriptor `protobuf:"bytes,2,opt,name=next,proto3" json:"next,omitempty"`
	// State of the initiator.
	State *State `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// Ack ID identifies the Hello as the acknowledgement of a previous hello. The ID
	// is set to the state ID of the state of the receiver. If the receiver's
	// state ID has changed, it should reply with the new state.
	//
	// 0 indicates "not an acknowledgement".
	AckId uint64 `protobuf:"varint,4,opt,name=ack_id,json=ackId,proto3" json:"ack_id,omitempty"`
	// contains filtered or unexported fields
}

type HelloResponse struct {

	// If ack_id was > 0 in in the Hello request and the state ID of the
	// receiver has changed, new_state should be set to the current state
	// of the receiver.
	NewState *State `protobuf:"bytes,1,opt,name=new_state,json=newState,proto3" json:"new_state,omitempty"`
	// contains filtered or unexported fields
}

type ID struct {
	High uint64 `protobuf:"varint,1,opt,name=high,proto3" json:"high,omitempty"`
	Low  uint64 `protobuf:"varint,2,opt,name=low,proto3" json:"low,omitempty"`
	// contains filtered or unexported fields
}

type JoinRequest struct {

	// The joiner is the node that is trying to join.
	Joiner *Descriptor `protobuf:"bytes,1,opt,name=joiner,proto3" json:"joiner,omitempty"`
	// contains filtered or unexported fields
}

type NodeClient interface {
	// Join initiates a series of handshakes to join the ring as a new node.
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Hello is used between two nodes to share their state. If the
	// HelloRequest is an Ack and state has been changed, should respond
	// with the new state.
	Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
	// Goodbye informs a node that a node is leaving the cluster.
	Goodbye(ctx context.Context, in *GoodbyeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetState requests the state tables for this node.
	GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)
}

type NodeServer interface {
	// Join initiates a series of handshakes to join the ring as a new node.
	Join(context.Context, *JoinRequest) (*emptypb.Empty, error)
	// Hello is used between two nodes to share their state. If the
	// HelloRequest is an Ack and state has been changed, should respond
	// with the new state.
	Hello(context.Context, *HelloRequest) (*HelloResponse, error)
	// Goodbye informs a node that a node is leaving the cluster.
	Goodbye(context.Context, *GoodbyeRequest) (*emptypb.Empty, error)
	// GetState requests the state tables for this node.
	GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
	// contains filtered or unexported methods
}

type State struct {

	// Descriptor of the node that this state belongs to.
	Node *Descriptor `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// Nodes that appear immediately before this node in the ring.
	Predecessors []*Descriptor `protobuf:"bytes,2,rep,name=predecessors,proto3" json:"predecessors,omitempty"`
	// Nodes that appear immediately after this node in the ring.
	Successors []*Descriptor `protobuf:"bytes,3,rep,name=successors,proto3" json:"successors,omitempty"`
	// The bit length used to represent IDs for routing. Must be one of
	// 8/16/32/64/128.
	IdBitLength uint32 `protobuf:"varint,4,opt,name=id_bit_length,json=idBitLength,proto3" json:"id_bit_length,omitempty"`
	// The base used to represent the ID for routing (i.e., hexadecimal,
	// base-16). Must be one of 2/4/8/16.
	IdBase uint32 `protobuf:"varint,5,opt,name=id_base,json=idBase,proto3" json:"id_base,omitempty"`
	// The 2D routing table used to route messages to far away nodes.
	// Key is the index in the routing table, where the position is
	// (width*y)+x.
	Routing map[uint32]*Descriptor `` /* 156-byte string literal not displayed */
	// List of nodes that are geographically located close to this node.
	Neighborhood []*Descriptor `protobuf:"bytes,7,rep,name=neighborhood,proto3" json:"neighborhood,omitempty"`
	// ID representing this table. A change to the table must change this ID.
	// It is common to use modified timestamp for this.
	StateId uint64 `protobuf:"varint,8,opt,name=state_id,json=stateId,proto3" json:"state_id,omitempty"`
	// A set of health of descriptors in the map. This MUST be sorted in order
	// of peer ID. Descriptors inside MUST be unique.
	HealthSet []*DescriptorHealth `protobuf:"bytes,9,rep,name=health_set,json=healthSet,proto3" json:"health_set,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedNodeServer struct {
}

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