timeline

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

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

type Backend struct {
	Host string
	Port int
}

type DataProcessor interface {

	// Start - starts the data processor
	Start()

	// Stop - stops the data processor
	Stop()

	// GetName - returns the processor's name
	GetName() string

	// SetTransport - sets the transport
	SetTransport(transport Transport)

	// ProcessMapEntry - process a map entry and return true to delete the entry
	ProcessMapEntry(entry interface{}) (deleteAfter bool)
}

type DataTransformerConf struct {
	CycleDuration    funks.Duration
	HashingAlgorithm hashing.Algorithm
	HashSize         int
	// contains filtered or unexported fields
}

type DefaultTransportConfiguration struct {
	TransportBufferSize  int
	BatchSendInterval    funks.Duration
	RequestTimeout       funks.Duration
	SerializerBufferSize int
	DebugInput           bool
	DebugOutput          bool
	TimeBetweenBatches   funks.Duration
	PrintStackOnError    bool
}

type FlatOperation uint8

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

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

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

type HTTPTransportConfig struct {
	DefaultTransportConfiguration
	ServiceEndpoint        string
	Method                 string
	ExpectedResponseStatus int
	TimestampProperty      string
	ValueProperty          string
}

type Hashable interface {

	// GetHash - return this instance hash
	GetHash() string
}

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

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

type OpenTSDBTransportConfig struct {
	DefaultTransportConfiguration
	ReadBufferSize         int
	MaxReadTimeout         funks.Duration
	ReconnectionTimeout    funks.Duration
	MaxReconnectionRetries int
	DisconnectAfterWrites  bool
}

type Transport interface {

	// Send - send a new point
	DataChannel(item interface{})

	// ConfigureBackend - configures the backend
	ConfigureBackend(backend *Backend) error

	// TransferData - transfers the data using this specific implementation
	TransferData(dataList []interface{}) error

	// Start - starts this transport
	Start() error

	// Close - closes this transport
	Close()

	// MatchType - checks if this transport implementation matches the given type
	MatchType(tt transportType) bool

	// Serialize - renders the text using the configured serializer
	Serialize(item interface{}) (string, error)

	// DataChannelItemToFlattenerPoint - converts the data channel item to the flattened point
	DataChannelItemToFlattenerPoint(configuration *DataTransformerConf, item interface{}, operation FlatOperation) (Hashable, error)

	// FlattenerPointToDataChannelItem - converts the flattened point to the data channel item
	FlattenerPointToDataChannelItem(item *FlattenerPoint) (interface{}, error)

	// DataChannelItemToAccumulatedData - converts the data channel item to the accumulated data
	DataChannelItemToAccumulatedData(configuration *DataTransformerConf, item interface{}, calculateHash bool) (Hashable, error)

	// AccumulatedDataToDataChannelItem - converts the accumulated data to the data channel item
	AccumulatedDataToDataChannelItem(item *AccumulatedData) (interface{}, error)

	// PrintStackOnError - enables the stack print to the log
	PrintStackOnError() bool
}