servers

Documentation

Index

• func NewOortAdministratorGrpcServer(service services.AdministrationService) (api.OortAdministratorServer, error)
• func NewOortEvaluatorGrpcServer(service services.EvaluationService) (api.OortEvaluatorServer, error)
• type AdministratorAsyncServer
  • func NewAdministratorAsyncServer(subscriber messaging.Subscriber, publisher messaging.Publisher, ...) (*AdministratorAsyncServer, error)
  • func (s *AdministratorAsyncServer) GracefulStop()
  • func (s *AdministratorAsyncServer) Serve() error

Functions

func NewOortAdministratorGrpcServer

func NewOortAdministratorGrpcServer(service services.AdministrationService) (api.OortAdministratorServer, error)

func NewOortEvaluatorGrpcServer

func NewOortEvaluatorGrpcServer(service services.EvaluationService) (api.OortEvaluatorServer, error)

Types

type AdministratorAsyncServer

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

func NewAdministratorAsyncServer

func NewAdministratorAsyncServer(subscriber messaging.Subscriber, publisher messaging.Publisher, service services.AdministrationService) (*AdministratorAsyncServer, error)

func (*AdministratorAsyncServer) GracefulStop

func (s *AdministratorAsyncServer) GracefulStop()

func (*AdministratorAsyncServer) Serve

func (s *AdministratorAsyncServer) Serve() error