serialize

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2020 License: Apache-2.0 Imports: 13 Imported by: 32

Documentation

Overview

Package serialize is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func TagValueFromEncodedTagsFast added in v1.0.0 

func TagValueFromEncodedTagsFast(
	encodedTags []byte,
	tagName []byte,
) ([]byte, bool, error)

TagValueFromEncodedTagsFast returns a tag from a set of encoded tags without any pooling required.

Types

type MetricTagsIterator 

type MetricTagsIterator interface {
	id.ID
	id.SortedTagIterator
	NumTags() int
}

MetricTagsIterator iterates over a set of tags.

func NewMetricTagsIterator 

func NewMetricTagsIterator(
	tagDecoder TagDecoder,
	pool MetricTagsIteratorPool,
) MetricTagsIterator

NewMetricTagsIterator creates a MetricTagsIterator.

type MetricTagsIteratorPool 

type MetricTagsIteratorPool interface {
	Init()
	Get() MetricTagsIterator
	Put(iter MetricTagsIterator)
}

MetricTagsIteratorPool pools MetricTagsIterator.

func NewMetricTagsIteratorPool 

func NewMetricTagsIteratorPool(
	tagDecoderPool TagDecoderPool,
	opts pool.ObjectPoolOptions,
) MetricTagsIteratorPool

NewMetricTagsIteratorPool creates a MetricTagsIteratorPool.

type MockMetricTagsIterator 

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

MockMetricTagsIterator is a mock of MetricTagsIterator interface

func NewMockMetricTagsIterator 

func NewMockMetricTagsIterator(ctrl *gomock.Controller) *MockMetricTagsIterator

NewMockMetricTagsIterator creates a new mock instance

func (*MockMetricTagsIterator) Bytes 

func (m *MockMetricTagsIterator) Bytes() []byte

Bytes mocks base method

func (*MockMetricTagsIterator) Close 

func (m *MockMetricTagsIterator) Close()

Close mocks base method

func (*MockMetricTagsIterator) Current 

func (m *MockMetricTagsIterator) Current() ([]byte, []byte)

Current mocks base method

func (*MockMetricTagsIterator) EXPECT 

func (m *MockMetricTagsIterator) EXPECT() *MockMetricTagsIteratorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockMetricTagsIterator) Err 

func (m *MockMetricTagsIterator) Err() error

Err mocks base method

func (*MockMetricTagsIterator) Next 

func (m *MockMetricTagsIterator) Next() bool

Next mocks base method

func (*MockMetricTagsIterator) NumTags 

func (m *MockMetricTagsIterator) NumTags() int

NumTags mocks base method

func (*MockMetricTagsIterator) Reset 

func (m *MockMetricTagsIterator) Reset(arg0 []byte)

Reset mocks base method

func (*MockMetricTagsIterator) TagValue 

func (m *MockMetricTagsIterator) TagValue(arg0 []byte) ([]byte, bool)

TagValue mocks base method

type MockMetricTagsIteratorMockRecorder 

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

MockMetricTagsIteratorMockRecorder is the mock recorder for MockMetricTagsIterator

func (*MockMetricTagsIteratorMockRecorder) Bytes 

func (mr *MockMetricTagsIteratorMockRecorder) Bytes() *gomock.Call

Bytes indicates an expected call of Bytes

func (*MockMetricTagsIteratorMockRecorder) Close 

func (mr *MockMetricTagsIteratorMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockMetricTagsIteratorMockRecorder) Current 

func (mr *MockMetricTagsIteratorMockRecorder) Current() *gomock.Call

Current indicates an expected call of Current

func (*MockMetricTagsIteratorMockRecorder) Err 

func (mr *MockMetricTagsIteratorMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err

func (*MockMetricTagsIteratorMockRecorder) Next 

func (mr *MockMetricTagsIteratorMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next

func (*MockMetricTagsIteratorMockRecorder) NumTags 

func (mr *MockMetricTagsIteratorMockRecorder) NumTags() *gomock.Call

NumTags indicates an expected call of NumTags

func (*MockMetricTagsIteratorMockRecorder) Reset 

func (mr *MockMetricTagsIteratorMockRecorder) Reset(arg0 interface{}) *gomock.Call

Reset indicates an expected call of Reset

func (*MockMetricTagsIteratorMockRecorder) TagValue 

func (mr *MockMetricTagsIteratorMockRecorder) TagValue(arg0 interface{}) *gomock.Call

TagValue indicates an expected call of TagValue

type MockMetricTagsIteratorPool 

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

MockMetricTagsIteratorPool is a mock of MetricTagsIteratorPool interface

func NewMockMetricTagsIteratorPool 

func NewMockMetricTagsIteratorPool(ctrl *gomock.Controller) *MockMetricTagsIteratorPool

NewMockMetricTagsIteratorPool creates a new mock instance

func (*MockMetricTagsIteratorPool) EXPECT 

func (m *MockMetricTagsIteratorPool) EXPECT() *MockMetricTagsIteratorPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockMetricTagsIteratorPool) Get 

func (m *MockMetricTagsIteratorPool) Get() MetricTagsIterator

Get mocks base method

func (*MockMetricTagsIteratorPool) Init 

func (m *MockMetricTagsIteratorPool) Init()

Init mocks base method

func (*MockMetricTagsIteratorPool) Put 

func (m *MockMetricTagsIteratorPool) Put(arg0 MetricTagsIterator)

Put mocks base method

type MockMetricTagsIteratorPoolMockRecorder 

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

MockMetricTagsIteratorPoolMockRecorder is the mock recorder for MockMetricTagsIteratorPool

func (*MockMetricTagsIteratorPoolMockRecorder) Get 

func (mr *MockMetricTagsIteratorPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get

func (*MockMetricTagsIteratorPoolMockRecorder) Init 

func (mr *MockMetricTagsIteratorPoolMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init

func (*MockMetricTagsIteratorPoolMockRecorder) Put 

func (mr *MockMetricTagsIteratorPoolMockRecorder) Put(arg0 interface{}) *gomock.Call

Put indicates an expected call of Put

type MockTagDecoder 

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

MockTagDecoder is a mock of TagDecoder interface

func NewMockTagDecoder 

func NewMockTagDecoder(ctrl *gomock.Controller) *MockTagDecoder

NewMockTagDecoder creates a new mock instance

func (*MockTagDecoder) Close 

func (m *MockTagDecoder) Close()

Close mocks base method

func (*MockTagDecoder) Current 

func (m *MockTagDecoder) Current() ident.Tag

Current mocks base method

func (*MockTagDecoder) CurrentIndex 

func (m *MockTagDecoder) CurrentIndex() int

CurrentIndex mocks base method

func (*MockTagDecoder) Duplicate 

func (m *MockTagDecoder) Duplicate() ident.TagIterator

Duplicate mocks base method

func (*MockTagDecoder) EXPECT 

func (m *MockTagDecoder) EXPECT() *MockTagDecoderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTagDecoder) Err 

func (m *MockTagDecoder) Err() error

Err mocks base method

func (*MockTagDecoder) Len 

func (m *MockTagDecoder) Len() int

Len mocks base method

func (*MockTagDecoder) Next 

func (m *MockTagDecoder) Next() bool

Next mocks base method

func (*MockTagDecoder) Remaining 

func (m *MockTagDecoder) Remaining() int

Remaining mocks base method

func (*MockTagDecoder) Reset 

func (m *MockTagDecoder) Reset(arg0 checked.Bytes)

Reset mocks base method

func (*MockTagDecoder) Rewind added in v0.15.2 

func (m *MockTagDecoder) Rewind()

Rewind mocks base method

type MockTagDecoderMockRecorder 

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

MockTagDecoderMockRecorder is the mock recorder for MockTagDecoder

func (*MockTagDecoderMockRecorder) Close 

func (mr *MockTagDecoderMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockTagDecoderMockRecorder) Current 

func (mr *MockTagDecoderMockRecorder) Current() *gomock.Call

Current indicates an expected call of Current

func (*MockTagDecoderMockRecorder) CurrentIndex 

func (mr *MockTagDecoderMockRecorder) CurrentIndex() *gomock.Call

CurrentIndex indicates an expected call of CurrentIndex

func (*MockTagDecoderMockRecorder) Duplicate 

func (mr *MockTagDecoderMockRecorder) Duplicate() *gomock.Call

Duplicate indicates an expected call of Duplicate

func (*MockTagDecoderMockRecorder) Err 

func (mr *MockTagDecoderMockRecorder) Err() *gomock.Call

Err indicates an expected call of Err

func (*MockTagDecoderMockRecorder) Len 

func (mr *MockTagDecoderMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len

func (*MockTagDecoderMockRecorder) Next 

func (mr *MockTagDecoderMockRecorder) Next() *gomock.Call

Next indicates an expected call of Next

func (*MockTagDecoderMockRecorder) Remaining 

func (mr *MockTagDecoderMockRecorder) Remaining() *gomock.Call

Remaining indicates an expected call of Remaining

func (*MockTagDecoderMockRecorder) Reset 

func (mr *MockTagDecoderMockRecorder) Reset(arg0 interface{}) *gomock.Call

Reset indicates an expected call of Reset

func (*MockTagDecoderMockRecorder) Rewind added in v0.15.2 

func (mr *MockTagDecoderMockRecorder) Rewind() *gomock.Call

Rewind indicates an expected call of Rewind

type MockTagDecoderPool 

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

MockTagDecoderPool is a mock of TagDecoderPool interface

func NewMockTagDecoderPool 

func NewMockTagDecoderPool(ctrl *gomock.Controller) *MockTagDecoderPool

NewMockTagDecoderPool creates a new mock instance

func (*MockTagDecoderPool) EXPECT 

func (m *MockTagDecoderPool) EXPECT() *MockTagDecoderPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTagDecoderPool) Get 

func (m *MockTagDecoderPool) Get() TagDecoder

Get mocks base method

func (*MockTagDecoderPool) Init 

func (m *MockTagDecoderPool) Init()

Init mocks base method

func (*MockTagDecoderPool) Put 

func (m *MockTagDecoderPool) Put(arg0 TagDecoder)

Put mocks base method

type MockTagDecoderPoolMockRecorder 

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

MockTagDecoderPoolMockRecorder is the mock recorder for MockTagDecoderPool

func (*MockTagDecoderPoolMockRecorder) Get 

func (mr *MockTagDecoderPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get

func (*MockTagDecoderPoolMockRecorder) Init 

func (mr *MockTagDecoderPoolMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init

func (*MockTagDecoderPoolMockRecorder) Put 

func (mr *MockTagDecoderPoolMockRecorder) Put(arg0 interface{}) *gomock.Call

Put indicates an expected call of Put

type MockTagEncoder 

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

MockTagEncoder is a mock of TagEncoder interface

func NewMockTagEncoder 

func NewMockTagEncoder(ctrl *gomock.Controller) *MockTagEncoder

NewMockTagEncoder creates a new mock instance

func (*MockTagEncoder) Data 

func (m *MockTagEncoder) Data() (checked.Bytes, bool)

Data mocks base method

func (*MockTagEncoder) EXPECT 

func (m *MockTagEncoder) EXPECT() *MockTagEncoderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTagEncoder) Encode 

func (m *MockTagEncoder) Encode(arg0 ident.TagIterator) error

Encode mocks base method

func (*MockTagEncoder) Finalize 

func (m *MockTagEncoder) Finalize()

Finalize mocks base method

func (*MockTagEncoder) Reset 

func (m *MockTagEncoder) Reset()

Reset mocks base method

type MockTagEncoderMockRecorder 

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

MockTagEncoderMockRecorder is the mock recorder for MockTagEncoder

func (*MockTagEncoderMockRecorder) Data 

func (mr *MockTagEncoderMockRecorder) Data() *gomock.Call

Data indicates an expected call of Data

func (*MockTagEncoderMockRecorder) Encode 

func (mr *MockTagEncoderMockRecorder) Encode(arg0 interface{}) *gomock.Call

Encode indicates an expected call of Encode

func (*MockTagEncoderMockRecorder) Finalize 

func (mr *MockTagEncoderMockRecorder) Finalize() *gomock.Call

Finalize indicates an expected call of Finalize

func (*MockTagEncoderMockRecorder) Reset 

func (mr *MockTagEncoderMockRecorder) Reset() *gomock.Call

Reset indicates an expected call of Reset

type MockTagEncoderPool 

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

MockTagEncoderPool is a mock of TagEncoderPool interface

func NewMockTagEncoderPool 

func NewMockTagEncoderPool(ctrl *gomock.Controller) *MockTagEncoderPool

NewMockTagEncoderPool creates a new mock instance

func (*MockTagEncoderPool) EXPECT 

func (m *MockTagEncoderPool) EXPECT() *MockTagEncoderPoolMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTagEncoderPool) Get 

func (m *MockTagEncoderPool) Get() TagEncoder

Get mocks base method

func (*MockTagEncoderPool) Init 

func (m *MockTagEncoderPool) Init()

Init mocks base method

func (*MockTagEncoderPool) Put 

func (m *MockTagEncoderPool) Put(arg0 TagEncoder)

Put mocks base method

type MockTagEncoderPoolMockRecorder 

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

MockTagEncoderPoolMockRecorder is the mock recorder for MockTagEncoderPool

func (*MockTagEncoderPoolMockRecorder) Get 

func (mr *MockTagEncoderPoolMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get

func (*MockTagEncoderPoolMockRecorder) Init 

func (mr *MockTagEncoderPoolMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init

func (*MockTagEncoderPoolMockRecorder) Put 

func (mr *MockTagEncoderPoolMockRecorder) Put(arg0 interface{}) *gomock.Call

Put indicates an expected call of Put

type TagDecoder 

type TagDecoder interface {
	ident.TagIterator

	// Reset resets internal state to iterate over the provided bytes.
	// NB: the TagDecoder takes ownership of the provided checked.Bytes.
	Reset(checked.Bytes)
}

TagDecoder decodes an encoded byte stream to a TagIterator.

type TagDecoderOptions 

type TagDecoderOptions interface {
	// SetCheckedBytesWrapperPool sets the checked.Bytes wrapper pool.
	SetCheckedBytesWrapperPool(v xpool.CheckedBytesWrapperPool) TagDecoderOptions

	// CheckedBytesWrapperPool returns the checked.Bytes wrapper pool.
	CheckedBytesWrapperPool() xpool.CheckedBytesWrapperPool

	// SetTagSerializationLimits sets the TagSerializationLimits.
	SetTagSerializationLimits(v TagSerializationLimits) TagDecoderOptions

	// TagSerializationLimits returns the TagSerializationLimits.
	TagSerializationLimits() TagSerializationLimits
}

TagDecoderOptions sets the knobs for TagDecoders.

func NewTagDecoderOptions 

func NewTagDecoderOptions(cfg TagDecoderOptionsConfig) TagDecoderOptions

NewTagDecoderOptions returns a new TagDecoderOptions.

type TagDecoderOptionsConfig added in v0.15.0 

type TagDecoderOptionsConfig struct {
	CheckBytesWrapperPoolSize          *int     `yaml:"checkBytesWrapperPoolSize"`
	CheckBytesWrapperPoolLowWatermark  *float64 `yaml:"checkBytesWrapperPoolLowWatermark"`
	CheckBytesWrapperPoolHighWatermark *float64 `yaml:"checkBytesWrapperPoolHighWatermark"`
}

TagDecoderOptionsConfig allows for defaults to be set at initialization.

func (TagDecoderOptionsConfig) CheckBytesWrapperPoolHighWatermarkOrDefault added in v0.15.0 

func (c TagDecoderOptionsConfig) CheckBytesWrapperPoolHighWatermarkOrDefault() float64

CheckBytesWrapperPoolHighWatermarkOrDefault returns config value or default.

func (TagDecoderOptionsConfig) CheckBytesWrapperPoolLowWatermarkOrDefault added in v0.15.0 

func (c TagDecoderOptionsConfig) CheckBytesWrapperPoolLowWatermarkOrDefault() float64

CheckBytesWrapperPoolLowWatermarkOrDefault returns config value or default.

func (TagDecoderOptionsConfig) CheckBytesWrapperPoolSizeOrDefault added in v0.15.0 

func (c TagDecoderOptionsConfig) CheckBytesWrapperPoolSizeOrDefault() int

CheckBytesWrapperPoolSizeOrDefault returns config value or default.

type TagDecoderPool 

type TagDecoderPool interface {
	// Init initializes the pool.
	Init()

	// Get returns a decoder. NB: calling Finalize() on the
	// returned TagDecoder puts it back in the pool.
	Get() TagDecoder

	// Put puts the decoder back in the pool.
	Put(TagDecoder)
}

TagDecoderPool pools TagDecoders.

func NewTagDecoderPool 

func NewTagDecoderPool(
	dopts TagDecoderOptions,
	opts pool.ObjectPoolOptions,
) TagDecoderPool

NewTagDecoderPool returns a new TagDecoderPool.

type TagEncoder 

type TagEncoder interface {
	// Encode encodes the provided iterator into its internal byte stream.
	// NB: leaves the original iterator un-modified.
	Encode(ident.TagIterator) error

	// Data returns the encoded bytes.
	// NB: The bytes returned as still owned by the TagEncoder. i.e. They are
	// only safe for use until Reset/Finalize is called upon the original
	// TagEncoder.
	Data() (checked.Bytes, bool)

	// Reset resets the internal state to allow reuse of the encoder.
	Reset()

	// Finalize releases any held resources.
	Finalize()
}

TagEncoder encodes provided Tag iterators.

type TagEncoderOptions 

type TagEncoderOptions interface {
	// SetInitialCapacity sets the initial capacity of the bytes underlying
	// the TagEncoder.
	SetInitialCapacity(v int) TagEncoderOptions

	// InitialCapacity returns the initial capacity of the bytes underlying
	// the TagEncoder.
	InitialCapacity() int

	// SetTagSerializationLimits sets the TagSerializationLimits.
	SetTagSerializationLimits(v TagSerializationLimits) TagEncoderOptions

	// TagSerializationLimits returns the TagSerializationLimits.
	TagSerializationLimits() TagSerializationLimits
}

TagEncoderOptions sets the knobs for TagEncoder limits.

func NewTagEncoderOptions 

func NewTagEncoderOptions() TagEncoderOptions

NewTagEncoderOptions returns a new TagEncoderOptions.

type TagEncoderPool 

type TagEncoderPool interface {
	// Init initializes the pool.
	Init()

	// Get returns an encoder. NB: calling Finalize() on the
	// returned TagEncoder puts it back in the pool.
	Get() TagEncoder

	// Put puts the encoder back in the pool.
	Put(TagEncoder)
}

TagEncoderPool pools TagEncoders.

func NewTagEncoderPool 

func NewTagEncoderPool(topts TagEncoderOptions, opts pool.ObjectPoolOptions) TagEncoderPool

NewTagEncoderPool returns a new TagEncoderPool.

type TagSerializationLimits 

type TagSerializationLimits interface {
	// SetMaxNumberTags sets the maximum number of tags allowed.
	SetMaxNumberTags(uint16) TagSerializationLimits

	// MaxNumberTags returns the maximum number of tags allowed.
	MaxNumberTags() uint16

	// SetMaxTagLiteralLength sets the maximum length of a tag Name/Value.
	SetMaxTagLiteralLength(uint16) TagSerializationLimits

	// MaxTagLiteralLength returns the maximum length of a tag Name/Value.
	MaxTagLiteralLength() uint16
}

TagSerializationLimits sets the limits around tag serialization.

func NewTagSerializationLimits 

func NewTagSerializationLimits() TagSerializationLimits

NewTagSerializationLimits returns a new TagSerializationLimits object.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.