Documentation ¶
Index ¶
- func RegisterClientHandler(stream protos.ControlPlane_ClientConnServer) error
- func RegisterSamplerHandler(stream protos.ControlPlane_SamplerConnServer) error
- type ClientHandler
- type ControlPlaneServer
- func (s *ControlPlaneServer) Addr() string
- func (s *ControlPlaneServer) ClientConn(stream protos.ControlPlane_ClientConnServer) error
- func (s *ControlPlaneServer) SamplerConn(stream protos.ControlPlane_SamplerConnServer) error
- func (s *ControlPlaneServer) SetClientHandlers(handlers ...ClientHandler)
- func (s *ControlPlaneServer) SetSamplerHandlers(handlers ...SamplerHandler)
- func (s *ControlPlaneServer) Start(t TestingT)
- func (s *ControlPlaneServer) Stop()
- type SamplerHandler
- type TestingT
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterClientHandler ¶
func RegisterClientHandler(stream protos.ControlPlane_ClientConnServer) error
func RegisterSamplerHandler ¶
func RegisterSamplerHandler(stream protos.ControlPlane_SamplerConnServer) error
Types ¶
type ClientHandler ¶
type ClientHandler func(stream protos.ControlPlane_ClientConnServer) error
type ControlPlaneServer ¶
type ControlPlaneServer struct { protos.UnimplementedControlPlaneServer // contains filtered or unexported fields }
func NewControlPlaneServer ¶
func NewControlPlaneServer(_ TestingT) *ControlPlaneServer
func (*ControlPlaneServer) Addr ¶
func (s *ControlPlaneServer) Addr() string
func (*ControlPlaneServer) ClientConn ¶
func (s *ControlPlaneServer) ClientConn(stream protos.ControlPlane_ClientConnServer) error
func (*ControlPlaneServer) SamplerConn ¶
func (s *ControlPlaneServer) SamplerConn(stream protos.ControlPlane_SamplerConnServer) error
func (*ControlPlaneServer) SetClientHandlers ¶
func (s *ControlPlaneServer) SetClientHandlers(handlers ...ClientHandler)
func (*ControlPlaneServer) SetSamplerHandlers ¶
func (s *ControlPlaneServer) SetSamplerHandlers(handlers ...SamplerHandler)
func (*ControlPlaneServer) Start ¶
func (s *ControlPlaneServer) Start(t TestingT)
func (*ControlPlaneServer) Stop ¶
func (s *ControlPlaneServer) Stop()
type SamplerHandler ¶
type SamplerHandler func(stream protos.ControlPlane_SamplerConnServer) error
Click to show internal directories.
Click to hide internal directories.