server

Documentation

Index

• type AuthService
• type QueueService
• type Server
  • func New(authService AuthService, queueService QueueService, storeService StoreService) *Server
  • func (s *Server) Run()
  • func (s *Server) Wait()
• type StoreService

Types

type AuthService

type AuthService interface {
	Authenticate(Username string, Password string) (session string, err error)
	SetConnection(host string) error
}

AuthService is an interface to meet the authentication needs

type QueueService

type QueueService interface {
	Submit(ctx context.Context, session string, url string, depth int, job string) error
	Get(ctx context.Context, session string) (url string, depth int, job string, err error)
	SetConnection(host string) error
}

QueueService is an interface to meet the queue needs

type Server

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

Server performs the retrieval from Queue and gets the URL contents

func New

func New(authService AuthService, queueService QueueService, storeService StoreService) *Server

New creates a gRPC server instance for Retriever

func (*Server) Run

func (s *Server) Run()

Run loops and processes the queue

func (*Server) Wait

func (s *Server) Wait()

Wait waits until the waitgroup is complete

type StoreService

type StoreService interface {
	Submit(ctx context.Context, session string, url string, urls []string) error
	SetConnection(host string) error
}

StoreService is an interface to meet the store needs