validation

Documentation

Index

• type Server
  • func NewServer(log log.FieldLogger) *Server
  • func (r *Server) CheckBandwidth(ctx context.Context, req *pb.CheckBandwidthRequest) (*pb.CheckBandwidthResponse, error)
  • func (r *Server) CheckDisks(ctx context.Context, req *proto.CheckDisksRequest) (*proto.CheckDisksResponse, error)
  • func (r *Server) CheckPorts(ctx context.Context, req *pb.CheckPortsRequest) (*pb.CheckPortsResponse, error)
  • func (*Server) Validate(ctx context.Context, req *pb.ValidateRequest) (resp *pb.ValidateResponse, err error)

Types

type Server

type Server struct {
	// FieldLogger specifies the logger to use for the server
	log.FieldLogger
}

Server is a validation server. Implements pb.ValidationServer

func NewServer

func NewServer(log log.FieldLogger) *Server

NewServer creates a new validation server

func (*Server) CheckBandwidth

func (r *Server) CheckBandwidth(ctx context.Context, req *pb.CheckBandwidthRequest) (*pb.CheckBandwidthResponse, error)

CheckBandwidth launches a special type of a ping-pong game that measures network bandwidth between servers specified in the request

func (*Server) CheckDisks

func (r *Server) CheckDisks(ctx context.Context, req *proto.CheckDisksRequest) (*proto.CheckDisksResponse, error)

CheckDisks executes the disk performance test using fio tool with the provided configuration and returns the test results.

func (*Server) CheckPorts

func (r *Server) CheckPorts(ctx context.Context, req *pb.CheckPortsRequest) (*pb.CheckPortsResponse, error)

CheckPorts executes a network ports test

func (*Server) Validate

func (*Server) Validate(ctx context.Context, req *pb.ValidateRequest) (resp *pb.ValidateResponse, err error)

Validate validatest this node against the requirements from a manifest.