timeline

Oct 9, 2020

Changes in this version

type Accumulator

+ func (d *Accumulator) ProcessCycle()

type DataProcessor

+ ProcessCycle func()

type Flattener

+ func (d *Flattener) ProcessCycle()

type HTTPTransport

+ func (t *HTTPTransport) SendData() error

type Manager

+ func (m *Manager) ProcessCycle()

+ func (m *Manager) SendData() error

type OpenTSDBTransport

+ func (t *OpenTSDBTransport) SendData() error

type Transport

+ SendData func() error

type UDPTransport

+ func (t *UDPTransport) SendData() error

Oct 8, 2020

Changes in this version

+ type DataProcessorEntry interface

+ Lock func()

+ Release func()

+ Unlock func()

Oct 2, 2020

Changes in this version

type DataTransformerConfig

+ PointValueBufferSize int

Jul 6, 2020

Changes in this version

+ var ErrInvalidPayloadSize error = errors.New("invalid payload size")

+ type CustomSerializerConfig struct

+ TimestampProperty string

+ ValueProperty string

type DataTransformerConfig

+ PrintStackOnError bool

type HTTPTransport

+ func (t *HTTPTransport) SerializePayload(dataList []interface{}) (payload []string, err error)

type HTTPTransportConfig

+ Headers map[string]string

type Manager

+ func (m *Manager) Flatten(operation FlatOperation, genericItem interface{}) error

+ func (m *Manager) FlattenJSON(operation FlatOperation, name string, parameters ...interface{}) error

+ func (m *Manager) Send(genericItem interface{})

+ func (m *Manager) SendJSON(schemaName string, parameters ...interface{}) error

+ func (m *Manager) Serialize(genericItem interface{}) (string, error)

+ func (m *Manager) SerializeJSON(schemaName string, parameters ...interface{}) (string, error)

+ func (m *Manager) StoreDataToAccumulate(ttl time.Duration, genericItem interface{}) (string, error)

+ func (m *Manager) StoreDataToAccumulateJSON(ttl time.Duration, name string, parameters ...interface{}) (string, error)

+ func (m *Manager) StoreHashedDataToAccumulateJSON(hash string, ttl time.Duration, name string, parameters ...interface{}) error

type OpenTSDBTransport

+ func (t *OpenTSDBTransport) SerializePayload(dataList []interface{}) (payload []string, err error)

+ type TCPUDPTransportConfig struct

+ DisconnectAfterWrites bool

+ MaxReconnectionRetries int

+ ReconnectionTimeout funks.Duration

type Transport

+ SerializePayload func(dataList []interface{}) (payload []string, err error)

+ type UDPTransport struct

+ func NewUDPTransport(configuration *UDPTransportConfig, customSerializer serializer.Serializer) (*UDPTransport, error)

+ func (t *UDPTransport) AccumulatedDataToDataChannelItem(point *AccumulatedData) (interface{}, error)

+ func (t *UDPTransport) BuildContextualLogger(path ...string)

+ func (t *UDPTransport) Close()

+ func (t *UDPTransport) ConfigureBackend(backend *Backend) error

+ func (t *UDPTransport) DataChannel(item interface{})

+ func (t *UDPTransport) DataChannelItemToAccumulatedData(configuration *DataTransformerConfig, instance interface{}, calculateHash bool) (Hashable, error)

+ func (t *UDPTransport) DataChannelItemToFlattenerPoint(configuration *DataTransformerConfig, instance interface{}, ...) (Hashable, error)

+ func (t *UDPTransport) FlattenerPointToDataChannelItem(point *FlattenerPoint) (interface{}, error)

+ func (t *UDPTransport) MatchType(tt transportType) bool

+ func (t *UDPTransport) Serialize(item interface{}) (string, error)

+ func (t *UDPTransport) SerializePayload(dataList []interface{}) (payload []string, err error)

+ func (t *UDPTransport) Start() error

+ func (t *UDPTransport) TransferData(payload []string) error

+ type UDPTransportConfig struct

Jun 12, 2020

Changes in this version

type Accumulator

+ func (a *Accumulator) BuildContextualLogger(path ...string)

type DataProcessor

+ BuildContextualLogger func(path ...string)

+ type DataTransformerConfig struct

+ CycleDuration funks.Duration

+ HashSize int

+ HashingAlgorithm hashing.Algorithm

+ type DefaultTransportConfig struct

+ BatchSendInterval funks.Duration

+ DebugInput bool

+ DebugOutput bool

+ PrintStackOnError bool

+ RequestTimeout funks.Duration

+ SerializerBufferSize int

+ TimeBetweenBatches funks.Duration

+ TransportBufferSize int

+ func (c *DefaultTransportConfig) Validate() error

type Flattener

+ func (f *Flattener) BuildContextualLogger(path ...string)

type HTTPTransport

+ func (t *HTTPTransport) BuildContextualLogger(path ...string)

type OpenTSDBTransport

+ func (t *OpenTSDBTransport) BuildContextualLogger(path ...string)

type Transport

+ BuildContextualLogger func(path ...string)

Jun 3, 2020

Changes in this version

type DataTransformerConf

+ Name string

type DefaultTransportConfiguration

+ Name string

Jun 2, 2020

Changes in this version

type DefaultTransportConfiguration

+ PrintStackOnError bool

type HTTPTransport

+ func (t *HTTPTransport) PrintStackOnError() bool

type OpenTSDBTransport

+ func (t *OpenTSDBTransport) PrintStackOnError() bool

type Transport

+ PrintStackOnError func() bool

Jun 2, 2020

Changes in this version

type DefaultTransportConfiguration

+ TimeBetweenBatches funks.Duration

type OpenTSDBTransportConfig

+ DisconnectAfterWrites bool

May 19, 2020

Changes in this version

type OpenTSDBTransportConfig

+ MaxReconnectionRetries int

Apr 24, 2020

Changes in this version

type DefaultTransportConfiguration

+ DebugInput bool

+ DebugOutput bool

type OpenTSDBTransportConfig

+ ReadBufferSize int

Apr 13, 2020

Changes in this version

type Accumulator

+ func (a *Accumulator) StoreCustomHash(item interface{}, ttl time.Duration, hash string) error

type Manager

+ func (m *Manager) StoreHashedDataToAccumulateHTTP(hash string, ttl time.Duration, name string, parameters ...interface{}) error

+ func (m *Manager) StoreHashedDataToAccumulateOpenTSDB(hash string, ttl time.Duration, value float64, timestamp int64, metric string, ...) error

Mar 4, 2020

Changes in this version

+ const AccumulatorName

+ const FlattenerName

+ var ErrNotStored error = fmt.Errorf("hash is not stored")

+ type AccumulatedData struct

+ func (ad *AccumulatedData) Execute()

+ func (ad *AccumulatedData) GetHash() string

+ type Accumulator struct

+ func NewAccumulator(configuration *AccumulatorConf) *Accumulator

+ func (a *Accumulator) Add(hash string) error

+ func (a *Accumulator) GetName() string

+ func (a *Accumulator) ProcessMapEntry(entry interface{}) bool

+ func (a *Accumulator) Stop()

+ func (a *Accumulator) Store(item interface{}) (string, error)

+ func (d *Accumulator) SetTransport(transport Transport)

+ func (d *Accumulator) Start()

+ type AccumulatorConf struct

+ DataTTL time.Duration

+ type DataProcessor interface

+ GetName func() string

+ ProcessMapEntry func(entry interface{}) (deleteAfter bool)

+ SetTransport func(transport Transport)

+ Start func()

+ Stop func()

+ type DataTransformerConf struct

+ CycleDuration time.Duration

+ HashSize int

+ HashingAlgorithm hashing.Algorithm

type Flattener

+ func (d *Flattener) SetTransport(transport Transport)

+ func (d *Flattener) Stop()

+ func (f *Flattener) GetName() string

+ func (f *Flattener) ProcessMapEntry(entry interface{}) bool

type FlattenerPoint

+ func (fp *FlattenerPoint) GetHash() string

type HTTPTransport

+ func (t *HTTPTransport) AccumulatedDataToDataChannelItem(point *AccumulatedData) (interface{}, error)

+ func (t *HTTPTransport) DataChannelItemToAccumulatedData(configuration *DataTransformerConf, instance interface{}) (Hashable, error)

+ func (t *HTTPTransport) DataChannelItemToFlattenerPoint(configuration *DataTransformerConf, instance interface{}, ...) (Hashable, error)

+ func (t *HTTPTransport) FlattenerPointToDataChannelItem(point *FlattenerPoint) (interface{}, error)

+ type Hashable interface

+ GetHash func() string

type Manager

+ func (m *Manager) IncrementAccumulatedData(hash string) error

+ func (m *Manager) StoreDataToAccumulateHTTP(name string, parameters ...interface{}) (string, error)

+ func (m *Manager) StoreDataToAccumulateOpenTSDB(value float64, timestamp int64, metric string, tags ...interface{}) (string, error)

type OpenTSDBTransport

+ func (t *OpenTSDBTransport) AccumulatedDataToDataChannelItem(point *AccumulatedData) (interface{}, error)

+ func (t *OpenTSDBTransport) DataChannelItemToAccumulatedData(configuration *DataTransformerConf, instance interface{}) (Hashable, error)

+ func (t *OpenTSDBTransport) DataChannelItemToFlattenerPoint(configuration *DataTransformerConf, instance interface{}, ...) (Hashable, error)

+ func (t *OpenTSDBTransport) FlattenerPointToDataChannelItem(point *FlattenerPoint) (interface{}, error)

type Transport

+ AccumulatedDataToDataChannelItem func(item *AccumulatedData) (interface{}, error)

+ DataChannelItemToAccumulatedData func(configuration *DataTransformerConf, item interface{}) (Hashable, error)

+ DataChannelItemToFlattenerPoint func(configuration *DataTransformerConf, item interface{}, operation FlatOperation) (Hashable, error)

+ FlattenerPointToDataChannelItem func(item *FlattenerPoint) (interface{}, error)

Jan 27, 2020

Changes in this version

+ type Backend struct

+ Host string

+ Port int

+ type DefaultTransportConfiguration struct

+ BatchSendInterval time.Duration

+ RequestTimeout time.Duration

+ SerializerBufferSize int

+ TransportBufferSize int

+ func (c *DefaultTransportConfiguration) Validate() error

+ type FlatOperation uint8

+ const Avg

+ const Count

+ const Max

+ const Min

+ const Sum

+ type Flattener struct

+ func NewFlattener(transport Transport, configuration *FlattenerConfig) (*Flattener, error)

+ func (f *Flattener) Add(point *FlattenerPoint) error

+ func (f *Flattener) Close()

+ func (f *Flattener) Start() error

+ type FlattenerConfig struct

+ CycleDuration time.Duration

+ HashingAlgorithm hashing.Algorithm

+ type FlattenerPoint struct

+ type HTTPTransport struct

+ func NewHTTPTransport(configuration *HTTPTransportConfig) (*HTTPTransport, error)

+ func (t *HTTPTransport) AddJSONMapping(name string, p interface{}, variables ...string) error

+ func (t *HTTPTransport) Close()

+ func (t *HTTPTransport) ConfigureBackend(backend *Backend) error

+ func (t *HTTPTransport) DataChannel() chan<- interface{}

+ func (t *HTTPTransport) DataChannelItemToFlattenedPoint(operation FlatOperation, instance interface{}) (*FlattenerPoint, error)

+ func (t *HTTPTransport) FlattenedPointToDataChannelItem(point *FlattenerPoint) (interface{}, error)

+ func (t *HTTPTransport) MatchType(tt transportType) bool

+ func (t *HTTPTransport) Serialize(item interface{}) (string, error)

+ func (t *HTTPTransport) Start() error

+ func (t *HTTPTransport) TransferData(dataList []interface{}) error

+ type HTTPTransportConfig struct

+ ExpectedResponseStatus int

+ Method string

+ ServiceEndpoint string

+ TimestampProperty string

+ ValueProperty string

+ type Manager struct

+ func NewManager(transport Transport, backend *Backend) (*Manager, error)

+ func NewManagerF(flattener *Flattener, backend *Backend) (*Manager, error)

+ func (m *Manager) FlattenHTTP(operation FlatOperation, name string, parameters ...interface{}) error

+ func (m *Manager) FlattenOpenTSDB(operation FlatOperation, value float64, timestamp int64, metric string, ...) error

+ func (m *Manager) GetTransport() Transport

+ func (m *Manager) SendHTTP(schemaName string, parameters ...interface{}) error

+ func (m *Manager) SendOpenTSDB(value float64, timestamp int64, metric string, tags ...interface{}) error

+ func (m *Manager) SerializeHTTP(schemaName string, parameters ...interface{}) (string, error)

+ func (m *Manager) SerializeOpenTSDB(value float64, timestamp int64, metric string, tags ...interface{}) (string, error)

+ func (m *Manager) Shutdown()

+ func (m *Manager) Start() error

+ type NumberPoint struct

+ Value float64

+ type OpenTSDBTransport struct

+ func NewOpenTSDBTransport(configuration *OpenTSDBTransportConfig) (*OpenTSDBTransport, error)

+ func (t *OpenTSDBTransport) Close()

+ func (t *OpenTSDBTransport) ConfigureBackend(backend *Backend) error

+ func (t *OpenTSDBTransport) DataChannel() chan<- interface{}

+ func (t *OpenTSDBTransport) DataChannelItemToFlattenedPoint(operation FlatOperation, instance interface{}) (*FlattenerPoint, error)

+ func (t *OpenTSDBTransport) FlattenedPointToDataChannelItem(point *FlattenerPoint) (interface{}, error)

+ func (t *OpenTSDBTransport) MatchType(tt transportType) bool

+ func (t *OpenTSDBTransport) Serialize(item interface{}) (string, error)

+ func (t *OpenTSDBTransport) Start() error

+ func (t *OpenTSDBTransport) TransferData(dataList []interface{}) error

+ type OpenTSDBTransportConfig struct

+ MaxReadTimeout time.Duration

+ ReconnectionTimeout time.Duration

+ type Point struct

+ Metric string

+ Tags map[string]string

+ Timestamp int64

+ type TextPoint struct

+ Text string

+ type Transport interface

+ Close func()

+ ConfigureBackend func(backend *Backend) error

+ DataChannel func() chan<- interface{}

+ DataChannelItemToFlattenedPoint func(operation FlatOperation, item interface{}) (*FlattenerPoint, error)

+ FlattenedPointToDataChannelItem func(point *FlattenerPoint) (interface{}, error)

+ MatchType func(tt transportType) bool

+ Serialize func(item interface{}) (string, error)

+ Start func() error

+ TransferData func(dataList []interface{}) error