tspb

package
v1.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 21, 2017 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview 

Package tspb is a generated protocol buffer package.

It is generated from these files:
	cockroach/pkg/ts/tspb/timeseries.proto

It has these top-level messages:
	TimeSeriesDatapoint
	TimeSeriesData
	Query
	TimeSeriesQueryRequest
	TimeSeriesQueryResponse

Package tspb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTimeseries = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTimeseries   = fmt.Errorf("proto: integer overflow")
)
View Source 
var TimeSeriesQueryAggregator_name = map[int32]string{
	1: "AVG",
	2: "SUM",
	3: "MAX",
	4: "MIN",
}
View Source 
var TimeSeriesQueryAggregator_value = map[string]int32{
	"AVG": 1,
	"SUM": 2,
	"MAX": 3,
	"MIN": 4,
}
View Source 
var TimeSeriesQueryDerivative_name = map[int32]string{
	0: "NONE",
	1: "DERIVATIVE",
	2: "NON_NEGATIVE_DERIVATIVE",
}
View Source 
var TimeSeriesQueryDerivative_value = map[string]int32{
	"NONE":                    0,
	"DERIVATIVE":              1,
	"NON_NEGATIVE_DERIVATIVE": 2,
}

Functions

func RegisterTimeSeriesHandler 

func RegisterTimeSeriesHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterTimeSeriesHandler registers the http handlers for service TimeSeries to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterTimeSeriesHandlerFromEndpoint 

func RegisterTimeSeriesHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterTimeSeriesHandlerFromEndpoint is same as RegisterTimeSeriesHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterTimeSeriesServer 

func RegisterTimeSeriesServer(s *grpc.Server, srv TimeSeriesServer)

Types

type Query 

type Query struct {
	// The name of the time series to query.
	Name string `protobuf:"bytes,1,opt,name=name" json:"name"`
	// A downsampling aggregation function to apply to datapoints within the
	// same sample period.
	Downsampler *TimeSeriesQueryAggregator `protobuf:"varint,2,opt,name=downsampler,enum=cockroach.ts.tspb.TimeSeriesQueryAggregator,def=1" json:"downsampler,omitempty"`
	// An aggregation function used to combine timelike datapoints from the
	// different sources being queried.
	SourceAggregator *TimeSeriesQueryAggregator `` /* 158-byte string literal not displayed */
	// If set to a value other than 'NONE', query will return a derivative
	// (rate of change) of the aggregated datapoints.
	Derivative *TimeSeriesQueryDerivative `protobuf:"varint,4,opt,name=derivative,enum=cockroach.ts.tspb.TimeSeriesQueryDerivative,def=0" json:"derivative,omitempty"`
	// An optional list of sources to restrict the time series query. If no
	// sources are provided, all available sources will be queried.
	Sources []string `protobuf:"bytes,5,rep,name=sources" json:"sources,omitempty"`
}

Each Query defines a specific metric to query over the time span of this request.

func (*Query) Descriptor 

func (*Query) Descriptor() ([]byte, []int)

func (*Query) GetDerivative 

func (m *Query) GetDerivative() TimeSeriesQueryDerivative

func (*Query) GetDownsampler 

func (m *Query) GetDownsampler() TimeSeriesQueryAggregator

func (*Query) GetName 

func (m *Query) GetName() string

func (*Query) GetSourceAggregator 

func (m *Query) GetSourceAggregator() TimeSeriesQueryAggregator

func (*Query) GetSources 

func (m *Query) GetSources() []string

func (*Query) Marshal 

func (m *Query) Marshal() (dAtA []byte, err error)

func (*Query) MarshalTo 

func (m *Query) MarshalTo(dAtA []byte) (int, error)

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) Size 

func (m *Query) Size() (n int)

func (*Query) String 

func (m *Query) String() string

func (*Query) Unmarshal 

func (m *Query) Unmarshal(dAtA []byte) error

type TimeSeriesClient 

type TimeSeriesClient interface {
	// URL: /ts/query
	Query(ctx context.Context, in *TimeSeriesQueryRequest, opts ...grpc.CallOption) (*TimeSeriesQueryResponse, error)
}

func NewTimeSeriesClient 

func NewTimeSeriesClient(cc *grpc.ClientConn) TimeSeriesClient

type TimeSeriesData 

type TimeSeriesData struct {
	// A string which uniquely identifies the variable from which this data was
	// measured.
	Name string `protobuf:"bytes,1,opt,name=name" json:"name"`
	// A string which identifies the unique source from which the variable was measured.
	Source string `protobuf:"bytes,2,opt,name=source" json:"source"`
	// Datapoints representing one or more measurements taken from the variable.
	Datapoints []TimeSeriesDatapoint `protobuf:"bytes,3,rep,name=datapoints" json:"datapoints"`
}

TimeSeriesData is a set of measurements of a single named variable at multiple points in time. This message contains a name and a source which, in combination, uniquely identify the time series being measured. Measurement data is represented as a repeated set of TimeSeriesDatapoint messages.

func (*TimeSeriesData) Descriptor 

func (*TimeSeriesData) Descriptor() ([]byte, []int)

func (*TimeSeriesData) Marshal 

func (m *TimeSeriesData) Marshal() (dAtA []byte, err error)

func (*TimeSeriesData) MarshalTo 

func (m *TimeSeriesData) MarshalTo(dAtA []byte) (int, error)

func (*TimeSeriesData) ProtoMessage 

func (*TimeSeriesData) ProtoMessage()

func (*TimeSeriesData) Reset 

func (m *TimeSeriesData) Reset()

func (*TimeSeriesData) Size 

func (m *TimeSeriesData) Size() (n int)

func (*TimeSeriesData) String 

func (m *TimeSeriesData) String() string

func (TimeSeriesData) ToInternal 

func (ts TimeSeriesData) ToInternal(
	keyDuration, sampleDuration int64,
) ([]roachpb.InternalTimeSeriesData, error)

ToInternal places the datapoints in a TimeSeriesData message into one or more InternalTimeSeriesData messages. The structure and number of messages returned depends on two variables: a key duration, and a sample duration.

The key duration is an interval length in nanoseconds used to determine how many intervals are grouped into a single InternalTimeSeriesData message.

The sample duration is also an interval length in nanoseconds; it must be less than or equal to the key duration, and must also evenly divide the key duration. Datapoints which fall into the same sample interval will be aggregated together into a single Sample.

Example: Assume the desired result is to aggregate individual datapoints into the same sample if they occurred within the same second; additionally, all samples which occur within the same hour should be stored at the same key location within the same InternalTimeSeriesValue. The sample duration should be 10^9 nanoseconds (value of time.Second), and the key duration should be (3600*10^9) nanoseconds (value of time.Hour).

Note that this method does not accumulate data into individual samples in the case where multiple datapoints fall into the same sample period. Internal data should be merged into the cockroach data store before being read; the engine is responsible for accumulating samples.

The returned slice of InternalTimeSeriesData objects will not be sorted.

For more information on how time series data is stored, see InternalTimeSeriesData and its related structures.

func (*TimeSeriesData) Unmarshal 

func (m *TimeSeriesData) Unmarshal(dAtA []byte) error

type TimeSeriesDatapoint 

type TimeSeriesDatapoint struct {
	// The timestamp when this datapoint is located, expressed in nanoseconds
	// since the unix epoch.
	TimestampNanos int64 `protobuf:"varint,1,opt,name=timestamp_nanos,json=timestampNanos" json:"timestamp_nanos"`
	// A floating point representation of the value of this datapoint.
	Value float64 `protobuf:"fixed64,2,opt,name=value" json:"value"`
}

TimeSeriesDatapoint is a single point of time series data; a value associated with a timestamp.

func (*TimeSeriesDatapoint) Descriptor 

func (*TimeSeriesDatapoint) Descriptor() ([]byte, []int)

func (*TimeSeriesDatapoint) Marshal 

func (m *TimeSeriesDatapoint) Marshal() (dAtA []byte, err error)

func (*TimeSeriesDatapoint) MarshalTo 

func (m *TimeSeriesDatapoint) MarshalTo(dAtA []byte) (int, error)

func (*TimeSeriesDatapoint) ProtoMessage 

func (*TimeSeriesDatapoint) ProtoMessage()

func (*TimeSeriesDatapoint) Reset 

func (m *TimeSeriesDatapoint) Reset()

func (*TimeSeriesDatapoint) Size 

func (m *TimeSeriesDatapoint) Size() (n int)

func (*TimeSeriesDatapoint) String 

func (m *TimeSeriesDatapoint) String() string

func (*TimeSeriesDatapoint) Unmarshal 

func (m *TimeSeriesDatapoint) Unmarshal(dAtA []byte) error

type TimeSeriesQueryAggregator 

type TimeSeriesQueryAggregator int32

TimeSeriesQueryAggregator describes a set of aggregation functions which can be used to combine multiple datapoints into a single datapoint.

Aggregators are used to "downsample" series by combining datapoints from the same series at different times. They are also used to "aggregate" values from different series, combining data points from different series at the same time. 

const (
	// AVG returns the average value of datapoints.
	TimeSeriesQueryAggregator_AVG TimeSeriesQueryAggregator = 1
	// SUM returns the sum value of datapoints.
	TimeSeriesQueryAggregator_SUM TimeSeriesQueryAggregator = 2
	// MAX returns the maximum value of datapoints.
	TimeSeriesQueryAggregator_MAX TimeSeriesQueryAggregator = 3
	// MIN returns the minimum value of datapoints.
	TimeSeriesQueryAggregator_MIN TimeSeriesQueryAggregator = 4
)
const Default_Query_Downsampler TimeSeriesQueryAggregator = TimeSeriesQueryAggregator_AVG
const Default_Query_SourceAggregator TimeSeriesQueryAggregator = TimeSeriesQueryAggregator_SUM

func (TimeSeriesQueryAggregator) Enum 

func (x TimeSeriesQueryAggregator) Enum() *TimeSeriesQueryAggregator

func (TimeSeriesQueryAggregator) EnumDescriptor 

func (TimeSeriesQueryAggregator) EnumDescriptor() ([]byte, []int)

func (TimeSeriesQueryAggregator) String 

func (x TimeSeriesQueryAggregator) String() string

func (*TimeSeriesQueryAggregator) UnmarshalJSON 

func (x *TimeSeriesQueryAggregator) UnmarshalJSON(data []byte) error

type TimeSeriesQueryDerivative 

type TimeSeriesQueryDerivative int32

TimeSeriesQueryDerivative describes a derivative function used to convert returned datapoints into a rate-of-change. 

const (
	// NONE is the default value, and does not apply a derivative function.
	TimeSeriesQueryDerivative_NONE TimeSeriesQueryDerivative = 0
	// DERIVATIVE returns the first-order derivative of values in the time series.
	TimeSeriesQueryDerivative_DERIVATIVE TimeSeriesQueryDerivative = 1
	// NON_NEGATIVE_DERIVATIVE returns only non-negative values of the first-order
	// derivative; negative values are returned as zero. This should be used for
	// counters that monotonically increase, but might wrap or reset.
	TimeSeriesQueryDerivative_NON_NEGATIVE_DERIVATIVE TimeSeriesQueryDerivative = 2
)
const Default_Query_Derivative TimeSeriesQueryDerivative = TimeSeriesQueryDerivative_NONE

func (TimeSeriesQueryDerivative) Enum 

func (x TimeSeriesQueryDerivative) Enum() *TimeSeriesQueryDerivative

func (TimeSeriesQueryDerivative) EnumDescriptor 

func (TimeSeriesQueryDerivative) EnumDescriptor() ([]byte, []int)

func (TimeSeriesQueryDerivative) String 

func (x TimeSeriesQueryDerivative) String() string

func (*TimeSeriesQueryDerivative) UnmarshalJSON 

func (x *TimeSeriesQueryDerivative) UnmarshalJSON(data []byte) error

type TimeSeriesQueryRequest 

type TimeSeriesQueryRequest struct {
	// A timestamp in nanoseconds which defines the early bound of the time span
	// for this query.
	StartNanos int64 `protobuf:"varint,1,opt,name=start_nanos,json=startNanos" json:"start_nanos"`
	// A timestamp in nanoseconds which defines the late bound of the time span
	// for this query. Must be greater than start_nanos.
	EndNanos int64 `protobuf:"varint,2,opt,name=end_nanos,json=endNanos" json:"end_nanos"`
	// A set of Queries for this request. A request must have at least one
	// Query.
	Queries []Query `protobuf:"bytes,3,rep,name=queries" json:"queries"`
	// Duration of requested sample period in nanoseconds. Returned data for each
	// query will be downsampled into periods of the supplied length. The
	// supplied duration must be a multiple of ten seconds.
	SampleNanos int64 `protobuf:"varint,4,opt,name=sample_nanos,json=sampleNanos" json:"sample_nanos"`
}

TimeSeriesQueryRequest is the standard incoming time series query request accepted from cockroach clients.

func (*TimeSeriesQueryRequest) Descriptor 

func (*TimeSeriesQueryRequest) Descriptor() ([]byte, []int)

func (*TimeSeriesQueryRequest) Marshal 

func (m *TimeSeriesQueryRequest) Marshal() (dAtA []byte, err error)

func (*TimeSeriesQueryRequest) MarshalTo 

func (m *TimeSeriesQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*TimeSeriesQueryRequest) ProtoMessage 

func (*TimeSeriesQueryRequest) ProtoMessage()

func (*TimeSeriesQueryRequest) Reset 

func (m *TimeSeriesQueryRequest) Reset()

func (*TimeSeriesQueryRequest) Size 

func (m *TimeSeriesQueryRequest) Size() (n int)

func (*TimeSeriesQueryRequest) String 

func (m *TimeSeriesQueryRequest) String() string

func (*TimeSeriesQueryRequest) Unmarshal 

func (m *TimeSeriesQueryRequest) Unmarshal(dAtA []byte) error

type TimeSeriesQueryResponse 

type TimeSeriesQueryResponse struct {
	// A set of Results; there will be one result for each Query in the matching
	// TimeSeriesQueryRequest, in the same order. A Result will be present for
	// each Query even if there are zero datapoints to return.
	Results []TimeSeriesQueryResponse_Result `protobuf:"bytes,1,rep,name=results" json:"results"`
}

TimeSeriesQueryResponse is the standard response for time series queries returned to cockroach clients.

func (*TimeSeriesQueryResponse) Descriptor 

func (*TimeSeriesQueryResponse) Descriptor() ([]byte, []int)

func (*TimeSeriesQueryResponse) Marshal 

func (m *TimeSeriesQueryResponse) Marshal() (dAtA []byte, err error)

func (*TimeSeriesQueryResponse) MarshalTo 

func (m *TimeSeriesQueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*TimeSeriesQueryResponse) ProtoMessage 

func (*TimeSeriesQueryResponse) ProtoMessage()

func (*TimeSeriesQueryResponse) Reset 

func (m *TimeSeriesQueryResponse) Reset()

func (*TimeSeriesQueryResponse) Size 

func (m *TimeSeriesQueryResponse) Size() (n int)

func (*TimeSeriesQueryResponse) String 

func (m *TimeSeriesQueryResponse) String() string

func (*TimeSeriesQueryResponse) Unmarshal 

func (m *TimeSeriesQueryResponse) Unmarshal(dAtA []byte) error

type TimeSeriesQueryResponse_Result 

type TimeSeriesQueryResponse_Result struct {
	Query      `protobuf:"bytes,1,opt,name=query,embedded=query" json:"query"`
	Datapoints []TimeSeriesDatapoint `protobuf:"bytes,2,rep,name=datapoints" json:"datapoints"`
}

Result is the data returned from a single metric query over a time span.

func (*TimeSeriesQueryResponse_Result) Descriptor 

func (*TimeSeriesQueryResponse_Result) Descriptor() ([]byte, []int)

func (*TimeSeriesQueryResponse_Result) Marshal 

func (m *TimeSeriesQueryResponse_Result) Marshal() (dAtA []byte, err error)

func (*TimeSeriesQueryResponse_Result) MarshalTo 

func (m *TimeSeriesQueryResponse_Result) MarshalTo(dAtA []byte) (int, error)

func (*TimeSeriesQueryResponse_Result) ProtoMessage 

func (*TimeSeriesQueryResponse_Result) ProtoMessage()

func (*TimeSeriesQueryResponse_Result) Reset 

func (m *TimeSeriesQueryResponse_Result) Reset()

func (*TimeSeriesQueryResponse_Result) Size 

func (m *TimeSeriesQueryResponse_Result) Size() (n int)

func (*TimeSeriesQueryResponse_Result) String 

func (m *TimeSeriesQueryResponse_Result) String() string

func (*TimeSeriesQueryResponse_Result) Unmarshal 

func (m *TimeSeriesQueryResponse_Result) Unmarshal(dAtA []byte) error

type TimeSeriesServer 

type TimeSeriesServer interface {
	// URL: /ts/query
	Query(context.Context, *TimeSeriesQueryRequest) (*TimeSeriesQueryResponse, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.