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    time.Duration
	HashingAlgorithm hashing.Algorithm
	HashSize         int
	// contains filtered or unexported fields
}

type DefaultTransportConfiguration struct {
	TransportBufferSize  int
	BatchSendInterval    time.Duration
	RequestTimeout       time.Duration
	SerializerBufferSize int
}

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 NumberPoint struct {
	Point
	Value float64 `json:"value"`
}

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

type OpenTSDBTransportConfig struct {
	DefaultTransportConfiguration
	MaxReadTimeout      time.Duration
	ReconnectionTimeout time.Duration
}

type Point struct {
	Metric    string            `json:"metric"`
	Tags      map[string]string `json:"tags"`
	Timestamp int64             `json:"timestamp"`
}

type TextPoint struct {
	Point
	Text string `json:"text"`
}

type Transport interface {

	// Send - send a new point
	DataChannel() chan<- 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)
}