backend

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

type AbstractBackendWithMetadata interface {
	IAbstractBackend
	IMetadata
}

type AbstractStrategy interface {
	GetBackend() IAbstractBackend
	SetBackends([]IAbstractBackend)
}

type Context struct {
	// details to determine context (e.g. series / metadata of series for persistence level)
	Series    uint64
	Namespace int
	RequestId RequestId
}

type ContextBackend struct {
	Context
}

type ContextRead struct {
	Context
	From uint64
	To   uint64
}

type ContextWrite struct {
	Context
}

type CreateSeries struct {
	Series map[types.SeriesCreateIdentifier]types.SeriesCreateMetadata
}

type CreateSeriesResult struct {
	Results map[types.SeriesCreateIdentifier]types.SeriesMetadataResponse
	Error   error
}

type DeleteSeries struct {
	Series []types.SeriesIdentifier
}

type DeleteSeriesResult struct {
	Error error
}

type IAbstractBackend interface {
	Type() TypeBackend
	Write(context ContextWrite, timestamps []uint64, values []float64) error
	FlushPendingWrites(requestId RequestId) error
	Read(context ContextRead) ReadResult
	Init() error // should be called before first usage
	SetReverseApi(IReverseApi)
}

type IMetadata interface {
	CreateOrUpdateSeries(*CreateSeries) *CreateSeriesResult // create/update new series (batch)
	SearchSeries(*SearchSeries) *SearchSeriesResult         // search one or multiple series by tags
	DeleteSeries(*DeleteSeries) *DeleteSeriesResult         // remove series (batch)
	Clear() error                                           // clear all data, mainly used for testing
}

type IReverseApi interface {
	DeleteSeries(delete *DeleteSeries) *DeleteSeriesResult
}

type MemoryBackend struct {
	AbstractBackend
	// contains filtered or unexported fields
}

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

type Namespace int

type ReadResult struct {
	Error   error
	Results map[uint64]float64
}

type RedisBackend struct {
	AbstractBackend
	// contains filtered or unexported fields
}

type RedisConnectionDetails struct {
	Type     RedisServerType //sentinel cluster server
	Addr     string
	Port     int
	Password string
	Database int
}

type RedisOpts struct {
	// connection per namespace supported, use RedisDefaultConnectionNamespace for default
	ConnectionDetails map[Namespace]RedisConnectionDetails
}

type RedisServerType string

type RequestId string

type SearchSeries struct {
	SearchSeriesElement
}

type SearchSeriesComparator string

type SearchSeriesElement struct {
	Namespace  int
	Name       string
	Tag        string
	Comparator SearchSeriesComparator
	And        []SearchSeriesElement
	Or         []SearchSeriesElement
}

type SearchSeriesResult struct {
	Series []types.SeriesIdentifier
	Error  error
}

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

type Series uint64

type SeriesMetadata struct {
	Id        Series
	Namespace Namespace
	Name      string
	Tags      []string `json:",omitempty"`
	TtlExpire uint64   `json:",omitempty"` //  0 OR time in the future in seconds
}

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

type StrategyType string

type Timestamp float64

type TypeBackend string