akumuli

package
v0.0.0-...-aec62d2 Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2021 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL