server

Documentation

Index

• type AuthService
• type Server
  • func New(authService AuthService) *Server
  • func (s *Server) Get(ctx context.Context, gr *queuepb.QueueGetRequest) (*queuepb.QueueGetReply, error)
  • func (s *Server) Serve(address string) error
  • func (s *Server) Submit(ctx context.Context, sr *queuepb.QueueSubmitRequest) (*queuepb.QueueSubmitReply, error)

Types

type AuthService

type AuthService interface {
	Validate(session string) error
	SetConnection(host string) error
}

AuthService is an interface to meet the authentication needs

type Server

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

Server satisfies gRPC service interface requirements Queue

func New

func New(authService AuthService) *Server

New creates a gRPC server instance for API

func (*Server) Get

func (s *Server) Get(ctx context.Context, gr *queuepb.QueueGetRequest) (*queuepb.QueueGetReply, error)

Get retrieves an available URL and recursion depth for processing

func (*Server) Serve

func (s *Server) Serve(address string) error

Serve handles gRPC requests for service API

func (*Server) Submit

func (s *Server) Submit(ctx context.Context, sr *queuepb.QueueSubmitRequest) (*queuepb.QueueSubmitReply, error)

Submit handles client requests to Submit to the Queue service