protocol

package

v0.0.0-...-31edc5d Latest Latest Go to latest Published: Feb 27, 2023 License: BSD-2-Clause Imports: 5 Imported by: 0

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

Repository

github.com/codepr/timepipe

Links

Open Source Insights

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
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
type QueryPacket
type QueryResponsePacket
type Response
- func (r *Response) MarshalBinary() ([]byte, error)

Constants ¶

View Source

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

View Source

const (
	OK = iota
	ACCEPTED
	TSNOTFOUND
	TSEXISTS
	UNKNOWNCMD
)

View Source

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

Variables ¶

This section is empty.

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 (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 ¶

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func MarshalBinary ¶

func MarshalBinaryFull ¶

func UnmarshalBinary ¶

Types ¶

type AckResponse ¶

type AddPointPacket ¶

func (*AddPointPacket) Apply ¶

func (*AddPointPacket) MarshalBinary ¶

func (*AddPointPacket) UnmarshalBinary ¶

type CreatePacket ¶

func (*CreatePacket) MarshalBinary ¶

func (*CreatePacket) UnmarshalBinary ¶

type DeletePacket ¶

func (*DeletePacket) MarshalBinary ¶

func (*DeletePacket) UnmarshalBinary ¶

type Header ¶

func (*Header) Len ¶

func (Header) MarshalBinary ¶

func (*Header) Opcode ¶

func (*Header) SetOpcode ¶

func (*Header) SetStatus ¶

func (*Header) Status ¶

func (Header) String ¶

func (*Header) UnmarshalBinary ¶

type QueryPacket ¶

func (*QueryPacket) Apply ¶

func (*QueryPacket) First ¶

func (*QueryPacket) Last ¶

func (*QueryPacket) MarshalBinary ¶

func (*QueryPacket) Max ¶

func (*QueryPacket) Min ¶

func (*QueryPacket) UnmarshalBinary ¶

type QueryResponsePacket ¶

func (*QueryResponsePacket) MarshalBinary ¶

func (*QueryResponsePacket) String ¶

func (*QueryResponsePacket) UnmarshalBinary ¶

type Response ¶

func (*Response) MarshalBinary ¶

Source Files ¶