protocol

Documentation

Index

• Constants
• func MarshalBinary(m encoding.BinaryMarshaler) ([]byte, error)
• func MarshalBinaryFull(opcode uint8, m encoding.BinaryMarshaler) ([]byte, error)
• func UnmarshalBinary(buf []byte, u encoding.BinaryUnmarshaler) error
• type AckResponse
• type AddPointPacket
  • func (a *AddPointPacket) Apply(ts *timeseries.TimeSeries) (encoding.BinaryMarshaler, error)
  • func (a *AddPointPacket) MarshalBinary() ([]byte, error)
  • func (a *AddPointPacket) UnmarshalBinary(buf []byte) error
• type CreatePacket
  • func (c *CreatePacket) MarshalBinary() ([]byte, error)
  • func (c *CreatePacket) UnmarshalBinary(buf []byte) error
• type DeletePacket
  • func (d *DeletePacket) MarshalBinary() ([]byte, error)
  • func (d *DeletePacket) UnmarshalBinary(buf []byte) error
• type Header
  • func (h *Header) Len() uint64
  • func (h Header) MarshalBinary() ([]byte, error)
  • func (h *Header) Opcode() byte
  • func (h *Header) SetOpcode(opcode byte)
  • func (h *Header) SetStatus(status byte)
  • func (h *Header) Status() byte
  • func (header Header) String() string
  • func (h *Header) UnmarshalBinary(buf []byte) error
• type QueryPacket
  • func (q *QueryPacket) Apply(ts *timeseries.TimeSeries) (encoding.BinaryMarshaler, error)
  • func (q *QueryPacket) First() bool
  • func (q *QueryPacket) Last() bool
  • func (q *QueryPacket) MarshalBinary() ([]byte, error)
  • func (q *QueryPacket) Max() bool
  • func (q *QueryPacket) Min() bool
  • func (q *QueryPacket) UnmarshalBinary(buf []byte) error
• type QueryResponsePacket
  • func (qr *QueryResponsePacket) MarshalBinary() ([]byte, error)
  • func (qr *QueryResponsePacket) String() string
  • func (qr *QueryResponsePacket) UnmarshalBinary(buf []byte) error
• type Response
  • func (r *Response) MarshalBinary() ([]byte, error)

Constants

const (
	CREATE = iota
	DELETE
	ADDPOINT
	MADDPOINT
	QUERY
	QUERYRESPONSE
	ACK
)

const (
	OK = iota
	ACCEPTED
	TSNOTFOUND
	TSEXISTS
	UNKNOWNCMD
)

const (
	MIN   = 1
	MAX   = 2
	FIRST = 3
	LAST  = 4
)

Functions

func MarshalBinary

func MarshalBinary(m encoding.BinaryMarshaler) ([]byte, error)

func MarshalBinaryFull

func MarshalBinaryFull(opcode uint8, m encoding.BinaryMarshaler) ([]byte, error)

func UnmarshalBinary

func UnmarshalBinary(buf []byte, u encoding.BinaryUnmarshaler) error

Types

type AckResponse

type AckResponse = Header

type AddPointPacket

type AddPointPacket struct {
	Name          string
	HaveTimestamp bool
	Value         float64
	Timestamp     int64
}

func (*AddPointPacket) Apply

func (a *AddPointPacket) Apply(ts *timeseries.TimeSeries) (encoding.BinaryMarshaler, error)

func (*AddPointPacket) MarshalBinary

func (a *AddPointPacket) MarshalBinary() ([]byte, error)

func (*AddPointPacket) UnmarshalBinary

func (a *AddPointPacket) UnmarshalBinary(buf []byte) error

type CreatePacket

type CreatePacket struct {
	Name      string
	Retention int64
}

func (*CreatePacket) MarshalBinary

func (c *CreatePacket) MarshalBinary() ([]byte, error)

func (*CreatePacket) UnmarshalBinary

func (c *CreatePacket) UnmarshalBinary(buf []byte) error

type DeletePacket

type DeletePacket struct {
	Name string
}

func (*DeletePacket) MarshalBinary

func (d *DeletePacket) MarshalBinary() ([]byte, error)

func (*DeletePacket) UnmarshalBinary

func (d *DeletePacket) UnmarshalBinary(buf []byte) error

type Header

type Header struct {
	Value byte
	Size  uint64
}

func (*Header) Len

func (h *Header) Len() uint64

func (Header) MarshalBinary

func (h Header) MarshalBinary() ([]byte, error)

func (*Header) Opcode

func (h *Header) Opcode() byte

func (*Header) SetOpcode

func (h *Header) SetOpcode(opcode byte)

func (*Header) SetStatus

func (h *Header) SetStatus(status byte)

func (*Header) Status

func (h *Header) Status() byte

func (Header) String

func (header Header) String() string

func (*Header) UnmarshalBinary

func (h *Header) UnmarshalBinary(buf []byte) error

type QueryPacket

type QueryPacket struct {
	Name  string
	Flags byte
	Range [2]int64
	Avg   int64
}

func (*QueryPacket) Apply

func (q *QueryPacket) Apply(ts *timeseries.TimeSeries) (encoding.BinaryMarshaler, error)

func (*QueryPacket) First

func (q *QueryPacket) First() bool

func (*QueryPacket) Last

func (q *QueryPacket) Last() bool

func (*QueryPacket) MarshalBinary

func (q *QueryPacket) MarshalBinary() ([]byte, error)

func (*QueryPacket) Max

func (q *QueryPacket) Max() bool

func (*QueryPacket) Min

func (q *QueryPacket) Min() bool

func (*QueryPacket) UnmarshalBinary

func (q *QueryPacket) UnmarshalBinary(buf []byte) error

type QueryResponsePacket

type QueryResponsePacket struct {
	Records []timeseries.Record
}

func (*QueryResponsePacket) MarshalBinary

func (qr *QueryResponsePacket) MarshalBinary() ([]byte, error)

func (*QueryResponsePacket) String

func (qr *QueryResponsePacket) String() string

func (*QueryResponsePacket) UnmarshalBinary

func (qr *QueryResponsePacket) UnmarshalBinary(buf []byte) error

type Response

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

func (*Response) MarshalBinary

func (r *Response) MarshalBinary() ([]byte, error)