grpc

Documentation

Index

• Variables
• func LoadWhitelist()
• func StartGRPCServer(db *sql.DB, port string) error
• func StartGRPCServerWithRetries(db *sql.DB, port string, retries int)
• func UnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type Server
  • func (s *Server) AcceptBlock(ctx context.Context, req *pb.BlockRequest) (*emptypb.Empty, error)
  • func (s *Server) Initialize(ctx context.Context, req *pb.InitializeRequest) (*emptypb.Empty, error)

Variables

var (
	WhitelistedIPs   = make(map[string]bool)
	WhitelistedCIDRs []*net.IPNet
)

Functions

func LoadWhitelist

func LoadWhitelist()

LoadWhitelist loads the whitelist using the config package

func StartGRPCServer

func StartGRPCServer(db *sql.DB, port string) error

StartGRPCServer starts the gRPC server for receiving block data

func StartGRPCServerWithRetries

func StartGRPCServerWithRetries(db *sql.DB, port string, retries int)

StartGRPCServerWithRetries retries gRPC server startup in case of failure

func UnaryInterceptor

func UnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

UnaryInterceptor checks the IP of the client and allows/denies the connection

Types

type Server

type Server struct {
	pb.UnimplementedExternalSubscriberServer
	// contains filtered or unexported fields
}

Server implements the ExternalSubscriberServer

func (*Server) AcceptBlock

func (s *Server) AcceptBlock(ctx context.Context, req *pb.BlockRequest) (*emptypb.Empty, error)

AcceptBlock processes a new block, saves relevant data to the database, and stores transactions and actions

func (*Server) Initialize

func (s *Server) Initialize(ctx context.Context, req *pb.InitializeRequest) (*emptypb.Empty, error)

Initialize receives genesis data for initialization and saves it to the database Initialize receives genesis data for initialization and saves it to the database