server

Documentation

Index

• type AdminServer
  • func NewAdminServer(s *Server) *AdminServer
  • func (s *AdminServer) Health(ctx context.Context, req *pb.HealthRequest) (*pb.HealthResponse, error)
  • func (s *AdminServer) Nodes(ctx context.Context, req *pb.NodeRequest) (*pb.NodeResponse, error)
  • func (s *AdminServer) Pools(ctx context.Context, req *pb.PoolRequest) (*pb.PoolResponse, error)
  • func (s *AdminServer) Serve(l net.Listener)
  • func (s *AdminServer) Shutdown(req *pb.ShutdownRequest, stream pb.Admin_ShutdownServer) error
  • func (s *AdminServer) Statistics(context.Context, *pb.StatisticsRequest) (*pb.StatisticsResponse, error)
  • func (s *AdminServer) Version(context.Context, *pb.VersionRequest) (*pb.VersionResponse, error)
• type ProxyServer
  • func NewProxyServer(s *Server) *ProxyServer
  • func (s *ProxyServer) Serve(l net.Listener) error
  • func (s *ProxyServer) Stats() map[string]int32
  • func (s *ProxyServer) Stop()
• type Server
  • func NewServer() *Server
  • func (s *Server) Start()

Types

type AdminServer

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

func NewAdminServer

func NewAdminServer(s *Server) *AdminServer

func (*AdminServer) Health

func (s *AdminServer) Health(ctx context.Context, req *pb.HealthRequest) (*pb.HealthResponse, error)

func (*AdminServer) Nodes

func (s *AdminServer) Nodes(ctx context.Context, req *pb.NodeRequest) (*pb.NodeResponse, error)

func (*AdminServer) Pools

func (s *AdminServer) Pools(ctx context.Context, req *pb.PoolRequest) (*pb.PoolResponse, error)

func (*AdminServer) Serve

func (s *AdminServer) Serve(l net.Listener)

func (*AdminServer) Shutdown

func (s *AdminServer) Shutdown(req *pb.ShutdownRequest, stream pb.Admin_ShutdownServer) error

func (*AdminServer) Statistics

func (s *AdminServer) Statistics(context.Context, *pb.StatisticsRequest) (*pb.StatisticsResponse, error)

func (*AdminServer) Version

func (s *AdminServer) Version(context.Context, *pb.VersionRequest) (*pb.VersionResponse, error)

type ProxyServer

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

func NewProxyServer

func NewProxyServer(s *Server) *ProxyServer

func (*ProxyServer) Serve

func (s *ProxyServer) Serve(l net.Listener) error

func (*ProxyServer) Stats

func (s *ProxyServer) Stats() map[string]int32

func (*ProxyServer) Stop

func (s *ProxyServer) Stop()

type Server

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

func NewServer

func NewServer() *Server

func (*Server) Start

func (s *Server) Start()