client

package
v0.0.0-...-7037cb6 Latest Latest
Warning

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

 Go to latest Published: May 14, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BoostSeriesIterator 

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

func NewBoostSeriesIterator 

func NewBoostSeriesIterator(
	seriesIterators []encoding.SeriesIterator,
	symTableNameResolver core.SymbolTableStreamNameResolver,
	symTableFetchFn SymTableFetchFunction,
	startTime xtime.UnixNano,
	endTime xtime.UnixNano,
	doCache bool) *BoostSeriesIterator

NewBoostSeriesIterator returns a new series iterator

func (*BoostSeriesIterator) Attributes 

func (bsi *BoostSeriesIterator) Attributes() ident.TagIterator

Attributes returns the attributes of the series

func (*BoostSeriesIterator) Begin 

func (bsi *BoostSeriesIterator) Begin() error

Reset the iterator to the beginning of the series, if the iterator type supports it.

func (*BoostSeriesIterator) Close 

func (bsi *BoostSeriesIterator) Close()

Close closes the iterator

func (*BoostSeriesIterator) Current 

func (bsi *BoostSeriesIterator) Current() (
	ts.Datapoint, xtime.Unit, ts.Annotation)

Returns the current item. Users should not hold onto the returned values as it may get invalidated when the Next is called.

func (*BoostSeriesIterator) Err 

func (bsi *BoostSeriesIterator) Err() error

Err returns any errors encountered

func (*BoostSeriesIterator) ID 

func (bsi *BoostSeriesIterator) ID() ident.ID

ID returns the ID of the series

func (*BoostSeriesIterator) IsDone 

func (bsi *BoostSeriesIterator) IsDone() bool

Return true if the iterator is complete

func (*BoostSeriesIterator) Namespace 

func (bsi *BoostSeriesIterator) Namespace() ident.ID

Namespace returns the namespace of the series

func (*BoostSeriesIterator) Next 

func (bsi *BoostSeriesIterator) Next() bool

Moves to the next item

func (*BoostSeriesIterator) Position 

func (bsi *BoostSeriesIterator) Position() *BoostSeriesIteratorPosition

Return the Series Iterator position

func (*BoostSeriesIterator) Seek 

func (bsi *BoostSeriesIterator) Seek(pos *BoostSeriesIteratorPosition) error

Seek to the specified position

func (*BoostSeriesIterator) Tags 

func (bsi *BoostSeriesIterator) Tags() ident.TagIterator

Tags returns the tags of the series

type BoostSeriesIteratorPosition 

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

type BoostSession 

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

func NewBoostSession 

func NewBoostSession(
	session client.Session,
	maxSymTables int,
	maxConcurrentWrites uint32) *BoostSession

NewBoostSession returns a new session that can be used to write to the database.

func (*BoostSession) Aggregate 

func (bs *BoostSession) Aggregate(
	ctx gocontext.Context,
	namespace ident.ID,
	q index.Query,
	opts index.AggregationOptions,
) (client.AggregatedTagsIterator, client.FetchResponseMetadata, error)

Aggregate aggregates values from the database for the given set of constraints.

func (*BoostSession) Close 

func (bs *BoostSession) Close() error

Close the session

func (*BoostSession) Fetch 

func (bs *BoostSession) Fetch(
	namespace,
	id ident.ID,
	startInclusive,
	endExclusive xtime.UnixNano,
) (encoding.SeriesIterator, error)

Fetch values from the database for an ID.

func (*BoostSession) FetchIDs 

func (bs *BoostSession) FetchIDs(
	namespace ident.ID,
	ids ident.Iterator,
	startInclusive,
	endExclusive xtime.UnixNano,
) (encoding.SeriesIterators, error)

FetchIDs values from the database for a set of IDs.

func (*BoostSession) FetchTagged 

func (bs *BoostSession) FetchTagged(
	ctx gocontext.Context,
	namespace ident.ID,
	q index.Query,
	opts index.QueryOptions,
) (encoding.SeriesIterators, client.FetchResponseMetadata, error)

FetchTagged resolves the provided query to known IDs, and fetches the data for them.

func (*BoostSession) FetchTaggedIDs 

func (bs *BoostSession) FetchTaggedIDs(
	ctx gocontext.Context,
	namespace ident.ID,
	q index.Query,
	opts index.QueryOptions,
) (client.TaggedIDsIterator, client.FetchResponseMetadata, error)

FetchTaggedIDs resolves the provided query to known IDs.

func (*BoostSession) FetchValueWithTaggedAttribute 

func (bs *BoostSession) FetchValueWithTaggedAttribute(
	namespace ident.ID,
	id ident.ID,
	startInclusive xtime.UnixNano,
	endExclusive xtime.UnixNano,
	symTableNameResolver core.SymbolTableStreamNameResolver,
	multiUseIter bool,
) (*BoostSeriesIterator, error)

Fetch values from the database for an ID.

func (*BoostSession) IteratorPools 

func (bs *BoostSession) IteratorPools() (encoding.IteratorPools, error)

IteratorPools exposes the internal iterator pools used by the session to clients.

func (*BoostSession) ReadClusterAvailability 

func (bs *BoostSession) ReadClusterAvailability() (bool, error)

ReadClusterAvailability returns whether cluster is available for reads.

func (*BoostSession) ShardID 

func (bs *BoostSession) ShardID(id ident.ID) (uint32, error)

ShardID returns the given shard for an ID for callers to easily discern what shard is failing when operations for given IDs begin failing.

func (*BoostSession) Wait 

func (bs *BoostSession) Wait(timeout time.Duration) error

Wait waits for all pending writes to complete or the timeout to occur. If timeout is 0, wait indefinitely until all pending writes are completed. Returns an error if timeout occurs.

func (*BoostSession) Write 

func (bs *BoostSession) Write(
	namespace,
	id ident.ID,
	t xtime.UnixNano,
	value float64,
	unit xtime.Unit,
	annotation []byte,
) error

Write value to the database for an ID.

func (*BoostSession) WriteClusterAvailability 

func (bs *BoostSession) WriteClusterAvailability() (bool, error)

WriteClusterAvailability returns whether cluster is available for writes.

func (*BoostSession) WriteTagged 

func (bs *BoostSession) WriteTagged(
	namespace,
	id ident.ID,
	tags ident.TagIterator,
	t xtime.UnixNano,
	value float64,
	unit xtime.Unit,
	annotation []byte,
) error

WriteTagged value to the database for an ID and given tags.

func (*BoostSession) WriteValueWithTaggedAttributes 

func (bs *BoostSession) WriteValueWithTaggedAttributes(
	namespace,
	id ident.ID,
	tags ident.TagIterator,
	attributes ident.TagIterator,
	t xtime.UnixNano,
	value float64,
	unit xtime.Unit,
	symTableNameResolver core.SymbolTableStreamNameResolver,
	completionFn core.WriteCompletionFn,
) error

Write tagged value that has attributes.

type CacheDpData 

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

type M3DBSeriesFamily 

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

Implements the SeriesFamily interface

func NewM3DBSeriesFamily 

func NewM3DBSeriesFamily(
	name string,
	domainName string,
	namespace ident.ID,
	version uint16,
	session *BoostSession,
	distributionFactor uint16,
	dictionaryLimit uint32,
	maxConcurrentWrites uint32) *M3DBSeriesFamily

NewM3DBSeriesFamily creates a new M3DBTAPTable

func (*M3DBSeriesFamily) Fetch 

func (sf *M3DBSeriesFamily) Fetch(
	id ident.ID,
	startInclusive xtime.UnixNano,
	endExclusive xtime.UnixNano,
	multiUseIter bool,
) (*BoostSeriesIterator, error)

Fetch values from the database for an ID.

func (*M3DBSeriesFamily) Name 

func (sf *M3DBSeriesFamily) Name() string

Name returns the name of the table

func (*M3DBSeriesFamily) Namespace 

func (sf *M3DBSeriesFamily) Namespace() ident.ID

Namespace returns the namespace of the table

func (*M3DBSeriesFamily) Wait 

func (sf *M3DBSeriesFamily) Wait(timeout time.Duration) error

Wait waits for all pending writes to complete or the timeout to occur. If timeout is 0, wait indefinitely until all pending writes are completed. Returns an error if timeout occurs.

func (*M3DBSeriesFamily) Write 

func (sf *M3DBSeriesFamily) Write(
	id ident.ID,
	attributes ident.TagIterator,
	timestamp xtime.UnixNano,
	value float64,
	unit xtime.Unit,
	completionFn core.WriteCompletionFn) error

WriteTagged writes a float64 value into the table having the specified attributes and timestamp.

func (*M3DBSeriesFamily) WriteTagged 

func (sf *M3DBSeriesFamily) WriteTagged(
	id ident.ID,
	tags ident.TagIterator,
	attributes ident.TagIterator,
	timestamp xtime.UnixNano,
	value float64,
	unit xtime.Unit,
	completionFn core.WriteCompletionFn) error

Write a float64 value into the table having the specified tags and attributes.

type SeriesShardIterator 

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

type ShardIterPosState 

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

type SymTableFetchFunction 

type SymTableFetchFunction func(
	namespaceId ident.ID,
	symTableName string,
	version uint16,
	timeBegin xtime.UnixNano,
	timeEnd xtime.UnixNano) (*core.SymTable, error)

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.