timelinemanager

package module

Go to main page

Versions in this module

v1

v1.3.2

Jun 3, 2020

v1.3.1

Jun 3, 2020

v1.3.0

Jun 3, 2020

v1.2.2

Jun 2, 2020

v1.2.1

Jun 2, 2020

Changes in this version

type Configuration

+ HTTPTransport *timeline.HTTPTransportConfig

+ OpenTSDBTransport *timeline.OpenTSDBTransportConfig

+ func (c *Configuration) Validate() error

v1.2.0

May 27, 2020

Changes in this version

+ const HTTP

+ const OpenTSDB

+ const RawHTTP

+ const RawOpenTSDB

+ var ErrStorageNotFound error = fmt.Errorf("storage type not found")

+ var ErrTransportNotSupported error = fmt.Errorf("transport not supported")

type BackendItem

+ Storage StorageType

+ type Instance struct

+ func (tm *Instance) AccumulateCustomHashN(hash string) (bool, error)

+ func (tm *Instance) AccumulateHashedData(stype StorageType, hash string) (bool, error)

+ func (tm *Instance) FlattenAvgN(caller string, value float64, metric string, tags ...interface{})

+ func (tm *Instance) FlattenCountIncA(caller string, metric string, tags ...interface{})

+ func (tm *Instance) FlattenCountIncN(caller string, metric string, tags ...interface{})

+ func (tm *Instance) FlattenCountN(caller string, value float64, metric string, tags ...interface{})

+ func (tm *Instance) FlattenMaxN(caller string, value float64, metric string, tags ...interface{})

+ func (tm *Instance) FlattenMinN(caller string, value float64, metric string, tags ...interface{})

+ func (tm *Instance) GetConfiguredDataTTL() time.Duration

+ func (tm *Instance) Send(caller string, stype StorageType, op timeline.FlatOperation, value float64, ...) error

+ func (tm *Instance) SendText(caller string, stype StorageType, value, metric string, tags ...interface{}) error

+ func (tm *Instance) Shutdown()

+ func (tm *Instance) Start() error

+ func (tm *Instance) StoreCustomHashN(hash string, metric string, tags ...interface{}) error

+ func (tm *Instance) StoreDefaultTTLCustomHash(storage StorageType, hash string, metric string, tags ...interface{}) error

+ func (tm *Instance) StoreHashedData(stype StorageType, hash string, ttl time.Duration, metric string, ...) error

+ func (tm *Instance) StoreNoTTLCustomHashN(hash string, metric string, tags ...interface{}) error

+ type TransportType string

v1.1.1

May 20, 2020

Changes in this version

type TimelineManager

+ func (tm *TimelineManager) GetConfiguredDataTTL() time.Duration

+ func (tm *TimelineManager) StoreDefaultTTLCustomHash(storage StorageType, hash string, metric string, tags ...interface{}) error

v1.1.0

May 20, 2020

v1.0.0

May 18, 2020

Changes in this version

+ type BackendItem struct

+ AddHostTag bool

+ CommonTags map[string]string

+ CycleDuration funks.Duration

+ Type StorageType

+ type Configuration struct

+ Backends []BackendItem

+ BatchSendInterval funks.Duration

+ DataTTL funks.Duration

+ DebugInput bool

+ DebugOutput bool

+ HashSize int

+ HashingAlgorithm hashing.Algorithm

+ MaxReadTimeout funks.Duration

+ ReadBufferSize int

+ ReconnectionTimeout funks.Duration

+ RequestTimeout funks.Duration

+ SerializerBufferSize int

+ TransportBufferSize int

+ type StorageType string

+ const Archive

+ const Normal

+ type TimelineManager struct

+ func New(configuration *Configuration) (*TimelineManager, error)

+ func (tm *TimelineManager) AccumulateCustomHashN(hash string) (bool, error)

+ func (tm *TimelineManager) AccumulateHashedData(stype StorageType, hash string) (bool, error)

+ func (tm *TimelineManager) Flatten(caller string, stype StorageType, op timeline.FlatOperation, value float64, ...)

+ func (tm *TimelineManager) FlattenAvgN(caller string, value float64, metric string, tags ...interface{})

+ func (tm *TimelineManager) FlattenCountIncA(caller string, metric string, tags ...interface{})

+ func (tm *TimelineManager) FlattenCountIncN(caller string, metric string, tags ...interface{})

+ func (tm *TimelineManager) FlattenCountN(caller string, value float64, metric string, tags ...interface{})

+ func (tm *TimelineManager) FlattenMaxN(caller string, value float64, metric string, tags ...interface{})

+ func (tm *TimelineManager) FlattenMinN(caller string, value float64, metric string, tags ...interface{})

+ func (tm *TimelineManager) Shutdown()

+ func (tm *TimelineManager) Start() error

+ func (tm *TimelineManager) StoreCustomHashN(hash string, metric string, tags ...interface{}) error

+ func (tm *TimelineManager) StoreHashedData(stype StorageType, hash string, ttl time.Duration, metric string, ...) error

+ func (tm *TimelineManager) StoreNoTTLCustomHashN(hash string, metric string, tags ...interface{}) error

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