importer

package
Version: v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2020 License: AGPL-3.0 Imports: 13 Imported by: 6

Documentation

Index

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 NewArchiveRequest(w *whisper.Whisper, schemas conf.Schemas, file, name string, from, until uint32, writeUnfinishedChunks bool) (*ArchiveRequest, error)

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 NewChunkWriteRequest(archive schema.Archive, ttl, t0 uint32, data []byte, ts time.Time) ChunkWriteRequest

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL