client

package

v0.0.0-...-d59e0d2 Latest Latest Go to latest Published: Nov 13, 2017 License: MIT Imports: 8 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	Requests chan *PinbaRequests
	// contains filtered or unexported fields
}

Client is net.Conn wrapper for reading data from pinba-collector

func New(addr string, connectTimeout, readTimeout time.Duration) (*Client, error)

New validates given address and creates new Client

func (c *Client) Listen(interval int64)

Listen will read all data from socket into buffer, and will flush it to internal channel for processing with given interval

type PinbaRequests struct {
	Timestamp int64
	Requests  []*pinba.Request
}

PinbaRequests struct holds slice of decoded Request's and timestamp, when they were collected

func NewPinbaRequests(timestamp int64, data io.Reader) (*PinbaRequests, error)

NewPinbaRequests will read and decode requests for given timestamp

type ServerMessage struct {
	Timestamp int64
	Data      bytes.Buffer
	// contains filtered or unexported fields
}

ServerMessage is struct to read and "decode" pinba-collector (server) messages

func (message *ServerMessage) ReadFrom(r io.Reader) error

ReadFrom will read message from given io.Reader and "extract" from it timestamp and raw byte data of pinba requests for this timestamp