conn

Documentation

Index

• func GetPortFromEnvironmentVariable(portEnvVariable string) (int, error)
• func GetResponseForGaugeMessage(message *gauge_messages.Message, conn net.Conn) (*gauge_messages.Message, error)
• func GetResponseForMessageWithTimeout(message *gauge_messages.Message, conn net.Conn, t time.Duration) (*gauge_messages.Message, error)
• func SendProcessKillMessage(connection net.Conn)
• func Write(conn net.Conn, messageBytes []byte) error
• func WriteDataAndGetResponse(conn net.Conn, messageBytes []byte) ([]byte, error)
• func WriteGaugeMessage(message *gauge_messages.Message, conn net.Conn) error
• type GaugeConnectionHandler
  • func NewGaugeConnectionHandler(port int, messageHandler messageHandler) (*GaugeConnectionHandler, error)
  • func (connectionHandler *GaugeConnectionHandler) AcceptConnection(connectionTimeOut time.Duration, errChannel chan error) (net.Conn, error)
  • func (connectionHandler *GaugeConnectionHandler) ConnectionPortNumber() int
  • func (connectionHandler *GaugeConnectionHandler) HandleMultipleConnections()

Functions

func GetPortFromEnvironmentVariable

func GetPortFromEnvironmentVariable(portEnvVariable string) (int, error)

func GetResponseForGaugeMessage

func GetResponseForGaugeMessage(message *gauge_messages.Message, conn net.Conn) (*gauge_messages.Message, error)

func GetResponseForMessageWithTimeout

func GetResponseForMessageWithTimeout(message *gauge_messages.Message, conn net.Conn, t time.Duration) (*gauge_messages.Message, error)

func SendProcessKillMessage

func SendProcessKillMessage(connection net.Conn)

SendProcessKillMessage sends a KillProcessRequest message through the connection.

func Write

func Write(conn net.Conn, messageBytes []byte) error

func WriteDataAndGetResponse

func WriteDataAndGetResponse(conn net.Conn, messageBytes []byte) ([]byte, error)

func WriteGaugeMessage

func WriteGaugeMessage(message *gauge_messages.Message, conn net.Conn) error

Types

type GaugeConnectionHandler

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

func NewGaugeConnectionHandler

func NewGaugeConnectionHandler(port int, messageHandler messageHandler) (*GaugeConnectionHandler, error)

func (*GaugeConnectionHandler) AcceptConnection

func (connectionHandler *GaugeConnectionHandler) AcceptConnection(connectionTimeOut time.Duration, errChannel chan error) (net.Conn, error)

func (*GaugeConnectionHandler) ConnectionPortNumber

func (connectionHandler *GaugeConnectionHandler) ConnectionPortNumber() int

func (*GaugeConnectionHandler) HandleMultipleConnections

func (connectionHandler *GaugeConnectionHandler) HandleMultipleConnections()

accepts multiple connections and Handler responds to incoming messages