loadbalancer

Documentation

Index

• func Accept(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)
• type Server
  • func New(prov provider, amqpAddr, host string, httpPort, wsPort int, external string) (*Server, error)
  • func (r *Server) APISpec() (http.HandlerFunc, error)
  • func (r *Server) Close() error
  • func (r *Server) GetEndpoint(_ context.Context, _ *common.EndpointRequest) (*common.EndpointResponse, error)
  • func (r *Server) RegisterGRPCGateway(_ *runtime.ServeMux, _ string, _ ...grpc.DialOption)
  • func (r *Server) RegisterGRPCHandler(server *grpc.Server)
  • func (r *Server) Start()

Functions

func Accept

func Accept(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)

Types

type Server

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

func New

func New(prov provider, amqpAddr, host string, httpPort, wsPort int, external string) (*Server, error)

TODO: to make this testable, need a "PublisherProvider" that will create the publisher here so we aren't hardcoding to RabbitMQ

func (*Server) APISpec

func (r *Server) APISpec() (http.HandlerFunc, error)

func (*Server) Close

func (r *Server) Close() error

func (*Server) GetEndpoint

func (r *Server) GetEndpoint(_ context.Context, _ *common.EndpointRequest) (*common.EndpointResponse, error)

func (*Server) RegisterGRPCGateway

func (r *Server) RegisterGRPCGateway(_ *runtime.ServeMux, _ string, _ ...grpc.DialOption)

func (*Server) RegisterGRPCHandler

func (r *Server) RegisterGRPCHandler(server *grpc.Server)

func (*Server) Start

func (r *Server) Start()