Documentation
¶
Overview ¶
Package test provides functionality used to test the remote sink.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct {
// MsgType indicates what is the type of Msg.
MsgType pb.MessageType
// Msg is the payload to the message that can be decoded using MsgType.
Msg []byte
}
Message corresponds to a single message sent from sinks.Remote.
type Server ¶
type Server struct {
server.CommonServer
// contains filtered or unexported fields
}
Server is the counterpart to the sinks.Remote. It receives connections remote sink and stores all points that it receives.
func NewServer ¶
NewServer creates a new server that listens to a UDS that it creates under os.TempDir.
func (*Server) NewClient ¶
func (s *Server) NewClient() (server.MessageHandler, error)
NewClient returns a new MessageHandler to process messages.
func (*Server) Reset ¶
Reset throws aways all points received so far and returns the number of points discarded.
func (*Server) SetVersion ¶
SetVersion sets the version to be used in handshake.
func (*Server) WaitForCount ¶
WaitForCount waits for the number of points to reach the desired number.
Source Files
Click to show internal directories.
Click to hide internal directories.