akumuli

Documentation

Index

• func NewBenchmark(loadFileName, endpoint string, bufPool *sync.Pool) targets.Benchmark
• func NewTarget() targets.ImplementedTarget
• type Serializer
  • func NewAkumuliSerializer() *Serializer
  • func (s *Serializer) Serialize(p *data.Point, w io.Writer) (err error)

Functions

func NewBenchmark

func NewBenchmark(loadFileName, endpoint string, bufPool *sync.Pool) targets.Benchmark

func NewTarget

func NewTarget() targets.ImplementedTarget

Types

type Serializer

type Serializer struct {
	// contains filtered or unexported fields
}

Serializer writes a series of Point elements into RESP encoded buffer.

func NewAkumuliSerializer

func NewAkumuliSerializer() *Serializer

NewAkumuliSerializer initializes AkumuliSerializer instance.

func (*Serializer) Serialize

func (s *Serializer) Serialize(p *data.Point, w io.Writer) (err error)

Serialize writes Point data to the given writer, conforming to the AKUMULI RESP protocol. Serializer adds extra data to guide data loader. This function writes output that contains binary and text data in RESP format.