protofiles

type AddNeighborRequest struct {
	Neighbor *Node `protobuf:"bytes,1,opt,name=neighbor,proto3" json:"neighbor,omitempty"` // The node to add as a neighbor
	// contains filtered or unexported fields
}

type AddNeighborResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // Whether the neighbor was added successfully
	// contains filtered or unexported fields
}

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

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

type BootstrapServiceClient interface {
	// JoinInfo returns a list of active nodes in the network
	JoinInfo(ctx context.Context, in *JoinInfoRequest, opts ...grpc.CallOption) (*JoinInfoResponse, error)
	// Leave informs rpc of the leaving node
	Leave(ctx context.Context, in *BootstrapLeaveInfo, opts ...grpc.CallOption) (*BootstrapLeaveResponse, error)
	// GetRootCApem returns the root CA certificate
	GetRootCApem(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RootCApemResponse, error)
	// SignCSR signs a Certificate Signing Request (CSR) and returns the signed certificate
	SignCSR(ctx context.Context, in *SignCSRRequest, opts ...grpc.CallOption) (*SignCSRResponse, error)
}

type BootstrapServiceServer interface {
	// JoinInfo returns a list of active nodes in the network
	JoinInfo(context.Context, *JoinInfoRequest) (*JoinInfoResponse, error)
	// Leave informs rpc of the leaving node
	Leave(context.Context, *BootstrapLeaveInfo) (*BootstrapLeaveResponse, error)
	// GetRootCApem returns the root CA certificate
	GetRootCApem(context.Context, *emptypb.Empty) (*RootCApemResponse, error)
	// SignCSR signs a Certificate Signing Request (CSR) and returns the signed certificate
	SignCSR(context.Context, *SignCSRRequest) (*SignCSRResponse, error)
	// contains filtered or unexported methods
}

type CANNodeClient interface {
	// Join the CAN network
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
	// Get a key in the CAN network
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Put a key-value pair in the CAN network
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// Delete a key-value pair in the CAN network
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Add a neighbor to the routing table
	AddNeighbor(ctx context.Context, in *AddNeighborRequest, opts ...grpc.CallOption) (*AddNeighborResponse, error)
	// Send Heartbeat
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	// Send neighbour and zone information
	SendNeighbourInfo(ctx context.Context, in *NeighbourInfoRequest, opts ...grpc.CallOption) (*NeighbourInfoResponse, error)
	// Start the leave process
	InitiateLeave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*LeaveResponse, error)
	// Handle the DFS process
	PerformDFS(ctx context.Context, in *DFSRequest, opts ...grpc.CallOption) (*DFSResponse, error)
	// Handle the takeover process
	TakeoverZone(ctx context.Context, in *TakeoverRequest, opts ...grpc.CallOption) (*TakeoverResponse, error)
	TransferData(ctx context.Context, in *TransferDataRequest, opts ...grpc.CallOption) (*TransferDataResponse, error)
	GetNeighbors(ctx context.Context, in *GetNeighborsRequest, opts ...grpc.CallOption) (*GetNeighborsResponse, error)
	NotifyZoneMerge(ctx context.Context, in *ZoneMergeNotification, opts ...grpc.CallOption) (*ZoneMergeResponse, error)
	ElectTakeoverCoordinator(ctx context.Context, in *CoordinatorElectionRequest, opts ...grpc.CallOption) (*CoordinatorElectionResponse, error)
}

type CANNodeServer interface {
	// Join the CAN network
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	// Get a key in the CAN network
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Put a key-value pair in the CAN network
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// Delete a key-value pair in the CAN network
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Add a neighbor to the routing table
	AddNeighbor(context.Context, *AddNeighborRequest) (*AddNeighborResponse, error)
	// Send Heartbeat
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	// Send neighbour and zone information
	SendNeighbourInfo(context.Context, *NeighbourInfoRequest) (*NeighbourInfoResponse, error)
	// Start the leave process
	InitiateLeave(context.Context, *LeaveRequest) (*LeaveResponse, error)
	// Handle the DFS process
	PerformDFS(context.Context, *DFSRequest) (*DFSResponse, error)
	// Handle the takeover process
	TakeoverZone(context.Context, *TakeoverRequest) (*TakeoverResponse, error)
	TransferData(context.Context, *TransferDataRequest) (*TransferDataResponse, error)
	GetNeighbors(context.Context, *GetNeighborsRequest) (*GetNeighborsResponse, error)
	NotifyZoneMerge(context.Context, *ZoneMergeNotification) (*ZoneMergeResponse, error)
	ElectTakeoverCoordinator(context.Context, *CoordinatorElectionRequest) (*CoordinatorElectionResponse, error)
	// contains filtered or unexported methods
}

type CoordinatorElectionRequest struct {
	CandidateNodeId string  `protobuf:"bytes,1,opt,name=candidate_node_id,json=candidateNodeId,proto3" json:"candidate_node_id,omitempty"`
	CandidateVolume float32 `protobuf:"fixed32,2,opt,name=candidate_volume,json=candidateVolume,proto3" json:"candidate_volume,omitempty"`
	CrashedNodeId   string  `protobuf:"bytes,3,opt,name=crashed_node_id,json=crashedNodeId,proto3" json:"crashed_node_id,omitempty"`
	// contains filtered or unexported fields
}

type CoordinatorElectionResponse struct {
	ShouldBeCoordinator bool `protobuf:"varint,1,opt,name=should_be_coordinator,json=shouldBeCoordinator,proto3" json:"should_be_coordinator,omitempty"`
	// contains filtered or unexported fields
}

type DFSRequest struct {
	LeavingNodeId string `protobuf:"bytes,1,opt,name=leaving_node_id,json=leavingNodeId,proto3" json:"leaving_node_id,omitempty"`
	ParentZone    *Zone  `protobuf:"bytes,2,opt,name=parent_zone,json=parentZone,proto3" json:"parent_zone,omitempty"`
	ParentNodeId  string `protobuf:"bytes,3,opt,name=parent_node_id,json=parentNodeId,proto3" json:"parent_node_id,omitempty"`
	// contains filtered or unexported fields
}

type DFSResponse struct {
	FoundSibling    bool   `protobuf:"varint,1,opt,name=found_sibling,json=foundSibling,proto3" json:"found_sibling,omitempty"`
	TakeoverNodeId  string `protobuf:"bytes,2,opt,name=takeover_node_id,json=takeoverNodeId,proto3" json:"takeover_node_id,omitempty"`
	TakeoverAddress string `protobuf:"bytes,3,opt,name=takeover_address,json=takeoverAddress,proto3" json:"takeover_address,omitempty"`
	TakeoverZone    *Zone  `protobuf:"bytes,4,opt,name=takeover_zone,json=takeoverZone,proto3" json:"takeover_zone,omitempty"`
	// contains filtered or unexported fields
}

type DeleteRequest struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	HashToUse int32  `protobuf:"varint,2,opt,name=hash_to_use,json=hashToUse,proto3" json:"hash_to_use,omitempty"` // Hash function to use for the key
	// contains filtered or unexported fields
}

type DeleteResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // Whether the key-value pair was deleted successfully
	// contains filtered or unexported fields
}

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

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

type GetRequest struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	HashToUse int32  `protobuf:"varint,2,opt,name=hash_to_use,json=hashToUse,proto3" json:"hash_to_use,omitempty"`
	// contains filtered or unexported fields
}

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

type HeartbeatRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // IP:Port of the node
	// contains filtered or unexported fields
}

type HeartbeatResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // Whether the heartbeat was acknowledged
	// contains filtered or unexported fields
}

type JoinInfoRequest struct {

	// Address where the node can be reached
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

type JoinInfoResponse struct {
	Dimensions  uint32   `protobuf:"varint,1,opt,name=dimensions,proto3" json:"dimensions,omitempty"`
	NumHashes   uint32   `protobuf:"varint,2,opt,name=num_hashes,json=numHashes,proto3" json:"num_hashes,omitempty"`
	NodeId      string   `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ActiveNodes []string `protobuf:"bytes,4,rep,name=active_nodes,json=activeNodes,proto3" json:"active_nodes,omitempty"` // IP Addresses of active nodes
	// contains filtered or unexported fields
}

type JoinRequest struct {

	// coordinates of the zone to be split - should be exactly d floats
	Coordinates []float32 `protobuf:"fixed32,1,rep,packed,name=coordinates,proto3" json:"coordinates,omitempty"`
	NodeId      string    `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // Unique identifier for the node
	Address     string    `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`             // IP:Port of the node
	// contains filtered or unexported fields
}

type JoinResponse struct {
	AssignedZone    *Zone           `protobuf:"bytes,1,opt,name=assigned_zone,json=assignedZone,proto3" json:"assigned_zone,omitempty"`          // The zone assigned to the node
	Neighbors       []*Node         `protobuf:"bytes,2,rep,name=neighbors,proto3" json:"neighbors,omitempty"`                                    // List of neighboring nodes
	TransferredData []*KeyValuePair `protobuf:"bytes,3,rep,name=transferred_data,json=transferredData,proto3" json:"transferred_data,omitempty"` // Key-value pairs for the assigned zone
	// contains filtered or unexported fields
}

type KeyValuePair 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 LeaveRequest struct {
	LeavingNodeId string `protobuf:"bytes,1,opt,name=leaving_node_id,json=leavingNodeId,proto3" json:"leaving_node_id,omitempty"`
	LeavingZone   *Zone  `protobuf:"bytes,2,opt,name=leaving_zone,json=leavingZone,proto3" json:"leaving_zone,omitempty"`
	// contains filtered or unexported fields
}

type LeaveResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

type NeighbourInfoRequest struct {
	NodeId     string  `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // Unique identifier for the node
	Zone       *Zone   `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`                   // The zone assigned to the node
	Neighbours []*Node `protobuf:"bytes,3,rep,name=neighbours,proto3" json:"neighbours,omitempty"`       // List of neighboring nodes
	Zones      []*Zone `protobuf:"bytes,4,rep,name=zones,proto3" json:"zones,omitempty"`                 // List of neighbor zones
	// contains filtered or unexported fields
}

type NeighbourInfoResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // Whether the neighbor information was sent successfully
	// contains filtered or unexported fields
}

type Node struct {
	NodeId  string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // Unique identifier for the node
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`             // IP:Port of the node
	Zone    *Zone  `protobuf:"bytes,3,opt,name=zone,proto3" json:"zone,omitempty"`                   // The zone assigned to the node
	// contains filtered or unexported fields
}

type PutRequest 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"`
	HashToUse int32  `protobuf:"varint,3,opt,name=hash_to_use,json=hashToUse,proto3" json:"hash_to_use,omitempty"` // Hash function to use for the key
	// contains filtered or unexported fields
}

type PutResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // Whether the key-value pair was stored successfully
	// contains filtered or unexported fields
}

type RootCApemResponse struct {
	RootCaPem []byte `protobuf:"bytes,1,opt,name=root_ca_pem,json=rootCaPem,proto3" json:"root_ca_pem,omitempty"` // PEM encoded root CA certificate
	// contains filtered or unexported fields
}

type SignCSRRequest struct {
	CsrPem []byte `protobuf:"bytes,1,opt,name=csr_pem,json=csrPem,proto3" json:"csr_pem,omitempty"` // PEM-encoded CSR generated by node
	IpSan  string `protobuf:"bytes,2,opt,name=ip_san,json=ipSan,proto3" json:"ip_san,omitempty"`    // IP SAN for the certificate
	// contains filtered or unexported fields
}

type SignCSRResponse struct {
	SignedCertPem []byte `protobuf:"bytes,1,opt,name=signed_cert_pem,json=signedCertPem,proto3" json:"signed_cert_pem,omitempty"` // Signed certificate (PEM)
	// contains filtered or unexported fields
}

type TakeoverRequest struct {
	LeavingNodeId      string `protobuf:"bytes,1,opt,name=leaving_node_id,json=leavingNodeId,proto3" json:"leaving_node_id,omitempty"`
	LeavingNodeAddress string `protobuf:"bytes,2,opt,name=leaving_node_address,json=leavingNodeAddress,proto3" json:"leaving_node_address,omitempty"`
	LeavingZone        *Zone  `protobuf:"bytes,3,opt,name=leaving_zone,json=leavingZone,proto3" json:"leaving_zone,omitempty"`
	IsGraceful         bool   `protobuf:"varint,4,opt,name=is_graceful,json=isGraceful,proto3" json:"is_graceful,omitempty"` // Whether this is a graceful leave or a crash
	// contains filtered or unexported fields
}

type TakeoverResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

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

type TransferDataResponse struct {
	Data []*KeyValuePair `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedBootstrapServiceServer struct{}

type UnimplementedCANNodeServer struct{}

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

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

type Zone struct {
	MinCoordinates []float32 `protobuf:"fixed32,1,rep,packed,name=minCoordinates,proto3" json:"minCoordinates,omitempty"` // coordinates of the zone (d)
	MaxCoordinates []float32 `protobuf:"fixed32,2,rep,packed,name=maxCoordinates,proto3" json:"maxCoordinates,omitempty"` // coordinates of the zone (d)
	// contains filtered or unexported fields
}

type ZoneMergeNotification struct {
	TakeoverNodeId string `protobuf:"bytes,1,opt,name=takeover_node_id,json=takeoverNodeId,proto3" json:"takeover_node_id,omitempty"`
	OldZone        *Zone  `protobuf:"bytes,2,opt,name=old_zone,json=oldZone,proto3" json:"old_zone,omitempty"`
	NewZone        *Zone  `protobuf:"bytes,3,opt,name=new_zone,json=newZone,proto3" json:"new_zone,omitempty"`
	LeavingNodeId  string `protobuf:"bytes,4,opt,name=leaving_node_id,json=leavingNodeId,proto3" json:"leaving_node_id,omitempty"`
	// contains filtered or unexported fields
}

type ZoneMergeResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}