Documentation
¶
Index ¶
- type ArchiveRequest
- func (z *ArchiveRequest) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *ArchiveRequest) EncodeMsg(en *msgp.Writer) (err error)
- func (a *ArchiveRequest) MarshalCompressed() (*bytes.Buffer, error)
- func (z *ArchiveRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ArchiveRequest) Msgsize() (s int)
- func (a *ArchiveRequest) UnmarshalCompressed(b io.Reader) error
- func (z *ArchiveRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
- type ChunkWriteRequest
- func (z *ChunkWriteRequest) DecodeMsg(dc *msgp.Reader) (err error)
- func (z *ChunkWriteRequest) EncodeMsg(en *msgp.Writer) (err error)
- func (c *ChunkWriteRequest) GetChunkWriteRequest(callback mdata.ChunkSaveCallback, key schema.MKey) mdata.ChunkWriteRequest
- func (z *ChunkWriteRequest) MarshalMsg(b []byte) (o []byte, err error)
- func (z *ChunkWriteRequest) Msgsize() (s int)
- func (z *ChunkWriteRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArchiveRequest ¶
type ArchiveRequest struct {
MetricData schema.MetricData
ChunkWriteRequests []ChunkWriteRequest
}
ArchiveRequest is a complete representation of a Metric together with some chunk write requests containing data that shall be written into this metric
func NewArchiveRequest ¶
func (*ArchiveRequest) DecodeMsg ¶
func (z *ArchiveRequest) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*ArchiveRequest) EncodeMsg ¶
func (z *ArchiveRequest) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*ArchiveRequest) MarshalCompressed ¶
func (a *ArchiveRequest) MarshalCompressed() (*bytes.Buffer, error)
func (*ArchiveRequest) MarshalMsg ¶
func (z *ArchiveRequest) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ArchiveRequest) Msgsize ¶
func (z *ArchiveRequest) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ArchiveRequest) UnmarshalCompressed ¶
func (a *ArchiveRequest) UnmarshalCompressed(b io.Reader) error
func (*ArchiveRequest) UnmarshalMsg ¶
func (z *ArchiveRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
type ChunkWriteRequest ¶
type ChunkWriteRequest struct {
mdata.ChunkWriteRequestPayload
Archive schema.Archive
}
ChunkWriteRequest is used by the importer utility to send cwrs over the network It does not contain the org id because this is assumed to be defined by the auth mechanism
func NewChunkWriteRequest ¶
func (*ChunkWriteRequest) DecodeMsg ¶
func (z *ChunkWriteRequest) DecodeMsg(dc *msgp.Reader) (err error)
DecodeMsg implements msgp.Decodable
func (*ChunkWriteRequest) EncodeMsg ¶
func (z *ChunkWriteRequest) EncodeMsg(en *msgp.Writer) (err error)
EncodeMsg implements msgp.Encodable
func (*ChunkWriteRequest) GetChunkWriteRequest ¶
func (c *ChunkWriteRequest) GetChunkWriteRequest(callback mdata.ChunkSaveCallback, key schema.MKey) mdata.ChunkWriteRequest
func (*ChunkWriteRequest) MarshalMsg ¶
func (z *ChunkWriteRequest) MarshalMsg(b []byte) (o []byte, err error)
MarshalMsg implements msgp.Marshaler
func (*ChunkWriteRequest) Msgsize ¶
func (z *ChunkWriteRequest) Msgsize() (s int)
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (*ChunkWriteRequest) UnmarshalMsg ¶
func (z *ChunkWriteRequest) UnmarshalMsg(bts []byte) (o []byte, err error)
UnmarshalMsg implements msgp.Unmarshaler
Source Files