timeline

type Backend struct {
	Host string
	Port int
}

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 FlattenerConfig struct {
	CycleDuration    time.Duration
	HashingAlgorithm hashing.Algorithm
}

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 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

	// DataChannelItemToFlattenedPoint - converts the data channel item to the flattened point one
	DataChannelItemToFlattenedPoint(operation FlatOperation, item interface{}) (*FlattenerPoint, error)

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

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