pnetserver

Documentation

Overview

Package pnetserver implements the ParanoidNetwork gRPC server. globals.go contains data used by each gRPC handler in pnetserver.

Index

• type ParanoidServer
  • func (s *ParanoidServer) JoinCluster(ctx context.Context, req *pb.JoinClusterRequest) (*pb.JoinClusterResponse, error)
  • func (s *ParanoidServer) NewGeneration(ctx context.Context, req *pb.NewGenerationRequest) (*pb.NewGenerationResponse, error)
  • func (s *ParanoidServer) Ping(ctx context.Context, req *pb.PingRequest) (*pb.PingResponse, error)
  • func (s *ParanoidServer) RequestKeyPiece(ctx context.Context, req *pb.RequestKeyPieceRequest) (*pb.RequestKeyPieceResponse, error)
  • func (s *ParanoidServer) SendKeyPiece(ctx context.Context, req *pb.SendKeyPieceRequest) (*pb.SendKeyPieceResponse, error)

Types

type ParanoidServer

type ParanoidServer struct {
	pb.UnimplementedParanoidNetworkServiceServer
}

ParanoidServer implements the paranoidnetwork gRPC server

func (*ParanoidServer) JoinCluster

func (s *ParanoidServer) JoinCluster(
	ctx context.Context, req *pb.JoinClusterRequest,
) (*pb.JoinClusterResponse, error)

JoinCluster receives requests from nodes asking to join raft cluster

func (*ParanoidServer) NewGeneration

func (s *ParanoidServer) NewGeneration(
	ctx context.Context, req *pb.NewGenerationRequest,
) (*pb.NewGenerationResponse, error)

NewGeneration receives requests from nodes asking to create a new KeyPiece generation in preparation for joining the cluster.

func (*ParanoidServer) Ping

func (s *ParanoidServer) Ping(ctx context.Context, req *pb.PingRequest) (*pb.PingResponse, error)

Ping implements the Ping RPC

func (*ParanoidServer) RequestKeyPiece

func (s *ParanoidServer) RequestKeyPiece(
	ctx context.Context, req *pb.RequestKeyPieceRequest,
) (*pb.RequestKeyPieceResponse, error)

RequestKeyPiece implements the RequestKeyPiece RPC

func (*ParanoidServer) SendKeyPiece

func (s *ParanoidServer) SendKeyPiece(
	ctx context.Context, req *pb.SendKeyPieceRequest,
) (*pb.SendKeyPieceResponse, error)

SendKeyPiece implements the SendKeyPiece RPC