sqp

Documentation

Index

• Constants
• func NewUnsupportedSQPVersionError(version uint16) error
• type QueryResponder
  • func NewQueryResponder(state *proto.QueryState) (*QueryResponder, error)
  • func (q *QueryResponder) Respond(clientAddress string, buf []byte) ([]byte, error)
• type UnsupportedSQPVersionError
  • func (e *UnsupportedSQPVersionError) Error() string

Constants

const MaxMetrics = 10

MaxMetrics represents the maximum number of metrics one SQP packet supports.

Functions

func NewUnsupportedSQPVersionError

func NewUnsupportedSQPVersionError(version uint16) error

NewUnsupportedSQPVersionError returns a new instance of UnsupportedSQPVersionError.

Types

type QueryResponder

type QueryResponder struct {
	*proto.QueryBase
	// contains filtered or unexported fields
}

QueryResponder represents a responder capable of responding to SQP-formatted queries.

func NewQueryResponder

func NewQueryResponder(state *proto.QueryState) (*QueryResponder, error)

NewQueryResponder returns creates a new responder capable of responding to SQP-formatted queries.

func (*QueryResponder) Respond

func (q *QueryResponder) Respond(clientAddress string, buf []byte) ([]byte, error)

Respond writes a query response to the requester in the SQP wire protocol.

type UnsupportedSQPVersionError

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

UnsupportedSQPVersionError is an error which represents an invalid SQP version provided to the reader.

func (*UnsupportedSQPVersionError) Error

func (e *UnsupportedSQPVersionError) Error() string

Error returns the error string.