metrictank: github.com/grafana/metrictank/mdata/importer Index | Files

package importer

import "github.com/grafana/metrictank/mdata/importer"

Index

Package Files

archive_request.go archive_request_gen.go chunk_encoder.go converter.go cwr.go cwr_gen.go

type ArchiveRequest Uses

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 Uses

func NewArchiveRequest(w *whisper.Whisper, schemas conf.Schemas, file, name string, from, until uint32, writeUnfinishedChunks bool) (*ArchiveRequest, error)

func (*ArchiveRequest) DecodeMsg Uses

func (z *ArchiveRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*ArchiveRequest) EncodeMsg Uses

func (z *ArchiveRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*ArchiveRequest) MarshalCompressed Uses

func (a *ArchiveRequest) MarshalCompressed() (*bytes.Buffer, error)

func (*ArchiveRequest) MarshalMsg Uses

func (z *ArchiveRequest) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*ArchiveRequest) Msgsize Uses

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 Uses

func (a *ArchiveRequest) UnmarshalCompressed(b io.Reader) error

func (*ArchiveRequest) UnmarshalMsg Uses

func (z *ArchiveRequest) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type ChunkWriteRequest Uses

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 Uses

func NewChunkWriteRequest(archive schema.Archive, ttl, t0 uint32, data []byte, ts time.Time) ChunkWriteRequest

func (*ChunkWriteRequest) DecodeMsg Uses

func (z *ChunkWriteRequest) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*ChunkWriteRequest) EncodeMsg Uses

func (z *ChunkWriteRequest) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*ChunkWriteRequest) GetChunkWriteRequest Uses

func (c *ChunkWriteRequest) GetChunkWriteRequest(callback mdata.ChunkSaveCallback, key schema.MKey) mdata.ChunkWriteRequest

func (*ChunkWriteRequest) MarshalMsg Uses

func (z *ChunkWriteRequest) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*ChunkWriteRequest) Msgsize Uses

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 Uses

func (z *ChunkWriteRequest) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

Package importer imports 13 packages (graph). Updated 2020-04-09. Refresh now. Tools for package owners.