server

package
v0.0.0-...-41e4524 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 21, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CrawlerAMQP

type CrawlerAMQP = CrawlerRPC

type CrawlerRPC

type CrawlerRPC struct{}

func (*CrawlerRPC) Crawl

func (c *CrawlerRPC) Crawl(request *Request, response *Response) error

type RPCServer

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

func NewRPCServer

func NewRPCServer(addr string) *RPCServer

func (*RPCServer) Start

func (r *RPCServer) Start() (err error)

type RabbitMQ

type RabbitMQ struct {
	Channel  *amqp.Channel
	Request  amqp.Queue
	Response amqp.Queue
	// contains filtered or unexported fields
}

func NewRabbitMQ

func NewRabbitMQ(addr string) *RabbitMQ

func (*RabbitMQ) Close

func (r *RabbitMQ) Close()

func (*RabbitMQ) Serve

func (r *RabbitMQ) Serve()

func (*RabbitMQ) Start

func (r *RabbitMQ) Start() (err error)

type Request

type Request struct {
	Link  string
	Depth int
}

type Response

type Response struct {
	ValidLinks   []string
	InvalidLinks []string
}

type TCPServer

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

func NewTCPServer

func NewTCPServer(addr string) *TCPServer

func (*TCPServer) Close

func (t *TCPServer) Close() (err error)

func (*TCPServer) Start

func (t *TCPServer) Start() (err error)

type UDPServer

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

func NewUDPServer

func NewUDPServer(addr string) *UDPServer

func (*UDPServer) Start

func (s *UDPServer) Start() (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL