importer

Documentation

Index

• type ArchiveRequest
  • func NewArchiveRequest(w *whisper.Whisper, schemas conf.Schemas, file, name string, ...) (*ArchiveRequest, error)
  • 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 NewChunkWriteRequest(archive schema.Archive, ttl, t0 uint32, data []byte, ts time.Time) 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)

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