marshaler

type AbstractMarshaler ¶

type AbstractMarshaler interface {
	// SplitPayload breaks the payload into times number of pieces
	SplitPayload(int) ([]AbstractMarshaler, error)
}

AbstractMarshaler is an abstract marshaler.

type BufferContext ¶

type BufferContext struct {
	CompressorInput   *bytes.Buffer
	CompressorOutput  *bytes.Buffer
	PrecompressionBuf *bytes.Buffer
}

BufferContext contains the buffers used for MarshalSplitCompress so they can be shared between invocations

func NewBufferContext() *BufferContext

type DummyMarshaller ¶

type DummyMarshaller struct {
	Items  []string
	Header string
	Footer string
}

DummyMarshaller implements StreamJSONMarshaler for unit tests.

func (d *DummyMarshaller) DescribeItem(i int) string

func (d *DummyMarshaller) Len() int

func (d *DummyMarshaller) Marshal() ([]byte, error)

func (d *DummyMarshaller) MarshalJSON() ([]byte, error)

func (d *DummyMarshaller) SplitPayload(int) ([]AbstractMarshaler, error)

func (d *DummyMarshaller) WriteFooter(stream *jsoniter.Stream) error

func (d *DummyMarshaller) WriteHeader(stream *jsoniter.Stream) error

func (d *DummyMarshaller) WriteItem(stream *jsoniter.Stream, i int) error

type IterableStreamJSONMarshaler ¶

type IterableStreamJSONMarshaler interface {
	WriteHeader(*jsoniter.Stream) error
	WriteFooter(*jsoniter.Stream) error
	WriteCurrentItem(*jsoniter.Stream) error
	DescribeCurrentItem() string
	MoveNext() bool
	GetCurrentItemPointCount() int
}

IterableStreamJSONMarshaler is an interface for iterable metrics that are able to serialize themselves in a stream. Expected usage:

	m.WriteHeader(stream)
	for m.MoveNext() {
		m.WriteCurrentItem(stream)
 }
	m.WriteFooter(stream)

type IterableStreamJSONMarshalerAdapter ¶

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

IterableStreamJSONMarshalerAdapter adapts an object implementing `StreamJSONMarshaler` into an object implementing `IterableStreamJSONMarshaler`

func NewIterableStreamJSONMarshalerAdapter(marshaler StreamJSONMarshaler) *IterableStreamJSONMarshalerAdapter

func (a *IterableStreamJSONMarshalerAdapter) DescribeCurrentItem() string

func (a *IterableStreamJSONMarshalerAdapter) GetCurrentItemPointCount() int

func (a *IterableStreamJSONMarshalerAdapter) MoveNext() bool

func (a *IterableStreamJSONMarshalerAdapter) WriteCurrentItem(j *jsoniter.Stream) error

func (a *IterableStreamJSONMarshalerAdapter) WriteFooter(j *jsoniter.Stream) error

func (a *IterableStreamJSONMarshalerAdapter) WriteHeader(j *jsoniter.Stream) error

type JSONMarshaler ¶

type JSONMarshaler interface {
	AbstractMarshaler

	// MarshalJSON serialization a Payload to JSON
	MarshalJSON() ([]byte, error)
}

JSONMarshaler is a AbstractMarshaler that implement JSON marshaling.

type ProtoMarshaler ¶

type ProtoMarshaler interface {
	AbstractMarshaler

	// Marshal serialize objects using agent-payload definition.
	Marshal() ([]byte, error)
}

ProtoMarshaler is a AbstractMarshaler that implement proto marshaling.

type StreamJSONMarshaler ¶

type StreamJSONMarshaler interface {
	WriteHeader(*jsoniter.Stream) error
	WriteFooter(*jsoniter.Stream) error
	WriteItem(*jsoniter.Stream, int) error
	Len() int
	DescribeItem(i int) string
}

StreamJSONMarshaler is an interface for metrics that are able to serialize themselves in a stream