scanner

Documentation

Index

• Constants
• type GRPCData
  • func NewGRPCData(cfg *config.Config) (*GRPCData, error)
  • func (g *GRPCData) CheckAvailability() (bool, error)
  • func (g *GRPCData) Send(ctx context.Context, encoderName, payload string) (body []byte, statusCode int, err error)
  • func (g *GRPCData) SetAvailability(status bool)
  • func (g *GRPCData) UpdateGRPCData(available bool)
• type HTTPClient
  • func NewHTTPClient(cfg *config.Config) (*HTTPClient, error)
  • func (c *HTTPClient) Send(ctx context.Context, targetURL, placeholderName, encoderName, payload string) (body []byte, statusCode int, err error)
• type Scanner
  • func New(db *test.DB, logger *log.Logger, cfg *config.Config, httpClient *HTTPClient, ...) *Scanner
  • func (s *Scanner) BenignPreCheck(url string) (blocked bool, statusCode int, err error)
  • func (s *Scanner) CheckBlocking(body []byte, statusCode int) (bool, error)
  • func (s *Scanner) CheckPass(body []byte, statusCode int) (bool, error)
  • func (s *Scanner) PreCheck(url string) (blocked bool, statusCode int, err error)
  • func (s *Scanner) Run(ctx context.Context, url string, blockConn bool) error
  • func (s *Scanner) WSPreCheck(url string) (available, blocked bool, err error)

Constants

const GRPCServerDetectionTimeout = 3

Types

type GRPCData

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

func NewGRPCData

func NewGRPCData(cfg *config.Config) (*GRPCData, error)

func (*GRPCData) CheckAvailability

func (g *GRPCData) CheckAvailability() (bool, error)

func (*GRPCData) Send

func (g *GRPCData) Send(ctx context.Context, encoderName, payload string) (body []byte, statusCode int, err error)

func (*GRPCData) SetAvailability

func (g *GRPCData) SetAvailability(status bool)

func (*GRPCData) UpdateGRPCData

func (g *GRPCData) UpdateGRPCData(available bool)

type HTTPClient

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

func NewHTTPClient

func NewHTTPClient(cfg *config.Config) (*HTTPClient, error)

func (*HTTPClient) Send

func (c *HTTPClient) Send(
	ctx context.Context, targetURL, placeholderName, encoderName, payload string) (
	body []byte, statusCode int, err error)

type Scanner

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

func New

func New(db *test.DB, logger *log.Logger, cfg *config.Config, httpClient *HTTPClient, grpcData *GRPCData) *Scanner

func (*Scanner) BenignPreCheck

func (s *Scanner) BenignPreCheck(url string) (blocked bool, statusCode int, err error)

func (*Scanner) CheckBlocking

func (s *Scanner) CheckBlocking(body []byte, statusCode int) (bool, error)

func (*Scanner) CheckPass

func (s *Scanner) CheckPass(body []byte, statusCode int) (bool, error)

func (*Scanner) PreCheck

func (s *Scanner) PreCheck(url string) (blocked bool, statusCode int, err error)

func (*Scanner) Run

func (s *Scanner) Run(ctx context.Context, url string, blockConn bool) error

func (*Scanner) WSPreCheck

func (s *Scanner) WSPreCheck(url string) (available, blocked bool, err error)