v3

type Aggregate struct {

	// The aggregate's timestamp in agnostic local time or UTC
	Ts    *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Count uint32                 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// A scalar value set
	V *AggregateValue `protobuf:"bytes,6,opt,name=v,proto3,oneof" json:"v,omitempty"`
	// The scalar value set converted to a unit of measure
	Uv *AggregateValue `protobuf:"bytes,8,opt,name=uv,proto3,oneof" json:"uv,omitempty"`
	// Data quality information
	Q *DataQuality `protobuf:"bytes,12,opt,name=q,proto3" json:"q,omitempty"`
	// contains filtered or unexported fields
}

type AggregateValue struct {
	Minimum   float64 `protobuf:"fixed64,1,opt,name=minimum,proto3" json:"minimum,omitempty"`
	Maximum   float64 `protobuf:"fixed64,2,opt,name=maximum,proto3" json:"maximum,omitempty"`
	Summation float64 `protobuf:"fixed64,3,opt,name=summation,proto3" json:"summation,omitempty"`
	// contains filtered or unexported fields
}

type AnnotationActions struct {
	Attrib   *structpb.Struct `protobuf:"bytes,1,opt,name=attrib,proto3" json:"attrib,omitempty"`
	Evaluate string           `protobuf:"bytes,2,opt,name=evaluate,proto3" json:"evaluate,omitempty"`
	Exclude  bool             `protobuf:"varint,3,opt,name=exclude,proto3" json:"exclude,omitempty"`
	Flag     []string         `protobuf:"bytes,4,rep,name=flag,proto3" json:"flag,omitempty"`
	// contains filtered or unexported fields
}

type ConvertAggregatesRequest struct {
	Convert    *ConvertArgs `protobuf:"bytes,1,opt,name=convert,proto3" json:"convert,omitempty"`
	Aggregates []*Aggregate `protobuf:"bytes,2,rep,name=aggregates,proto3" json:"aggregates,omitempty"`
	// contains filtered or unexported fields
}

type ConvertAggregatesResponse struct {
	Aggregates []*Aggregate `protobuf:"bytes,1,rep,name=aggregates,proto3" json:"aggregates,omitempty"`
	// contains filtered or unexported fields
}

type ConvertArgs struct {
	FromUnit string `protobuf:"bytes,1,opt,name=from_unit,json=fromUnit,proto3" json:"from_unit,omitempty"`
	ToUnit   string `protobuf:"bytes,2,opt,name=to_unit,json=toUnit,proto3" json:"to_unit,omitempty"`
	Library  string `protobuf:"bytes,3,opt,name=library,proto3" json:"library,omitempty"`
	// contains filtered or unexported fields
}

type ConvertDatapointsRequest struct {
	Convert    *ConvertArgs `protobuf:"bytes,1,opt,name=convert,proto3" json:"convert,omitempty"`
	Datapoints []*Datapoint `protobuf:"bytes,2,rep,name=datapoints,proto3" json:"datapoints,omitempty"`
	// contains filtered or unexported fields
}

type ConvertDatapointsResponse struct {
	Datapoints []*Datapoint `protobuf:"bytes,1,rep,name=datapoints,proto3" json:"datapoints,omitempty"`
	// contains filtered or unexported fields
}

type ConverterServiceClient interface {
	ConvertAggregates(ctx context.Context, in *ConvertAggregatesRequest, opts ...grpc.CallOption) (*ConvertAggregatesResponse, error)
	ConvertDatapoints(ctx context.Context, in *ConvertDatapointsRequest, opts ...grpc.CallOption) (*ConvertDatapointsResponse, error)
}

type ConverterServiceServer interface {
	ConvertAggregates(context.Context, *ConvertAggregatesRequest) (*ConvertAggregatesResponse, error)
	ConvertDatapoints(context.Context, *ConvertDatapointsRequest) (*ConvertDatapointsResponse, error)
	// contains filtered or unexported methods
}

type DataQuality struct {
	Attrib        *structpb.Struct `protobuf:"bytes,1,opt,name=attrib,proto3" json:"attrib,omitempty"`
	Flag          []string         `protobuf:"bytes,2,rep,name=flag,proto3" json:"flag,omitempty"`
	AnnotationIds []string         `protobuf:"bytes,3,rep,name=annotation_ids,json=annotationIds,proto3" json:"annotation_ids,omitempty"`
	// contains filtered or unexported fields
}

type Datapoint struct {

	// The datapoint's timestamp in UTC
	T *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=t,proto3" json:"t,omitempty"`
	// An offset in seconds between the time zone and UTC
	O int32 `protobuf:"zigzag32,2,opt,name=o,proto3" json:"o,omitempty"`
	// The timestamp in agnostic local time (offset applied)
	Lt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=lt,proto3" json:"lt,omitempty"`
	// A custom data object
	D *structpb.Struct `protobuf:"bytes,4,opt,name=d,proto3" json:"d,omitempty"`
	// An array of custom data objects
	Da []*structpb.Struct `protobuf:"bytes,5,rep,name=da,proto3" json:"da,omitempty"`
	// A scalar value
	V *float64 `protobuf:"fixed64,6,opt,name=v,proto3,oneof" json:"v,omitempty"`
	// An array of scalar values
	Va []float64 `protobuf:"fixed64,7,rep,packed,name=va,proto3" json:"va,omitempty"`
	// The scalar value converted to a unit of measure
	Uv *float64 `protobuf:"fixed64,8,opt,name=uv,proto3,oneof" json:"uv,omitempty"`
	// A GeoJSON point, polygon or multi-polygon
	// TODO: Define message type for this
	G *structpb.Struct `protobuf:"bytes,10,opt,name=g,proto3" json:"g,omitempty"`
	// A GeoJSON position (i.e. longitude, latitude, altitude)
	Gc []float64 `protobuf:"fixed64,11,rep,packed,name=gc,proto3" json:"gc,omitempty"`
	// Data quality information
	Q *DataQuality `protobuf:"bytes,12,opt,name=q,proto3" json:"q,omitempty"`
	// Extended information about the time
	Ti *structpb.Struct `protobuf:"bytes,16,opt,name=ti,proto3" json:"ti,omitempty"`
	// An end time object for observations that span a period of time
	Et *EndTime `protobuf:"bytes,17,opt,name=et,proto3" json:"et,omitempty"`
	// contains filtered or unexported fields
}

type DatapointsConfigInstance struct {
	BeginsAt      *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=begins_at,json=beginsAt,proto3,oneof" json:"begins_at,omitempty"`
	EndsBefore    *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=ends_before,json=endsBefore,proto3,oneof" json:"ends_before,omitempty"`
	Params        *structpb.Struct       `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	Connection    string                 `protobuf:"bytes,4,opt,name=connection,proto3" json:"connection,omitempty"`
	Path          string                 `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
	Ref           *uint32                `protobuf:"varint,6,opt,name=ref,proto3,oneof" json:"ref,omitempty"`
	Actions       *AnnotationActions     `protobuf:"bytes,10,opt,name=actions,proto3" json:"actions,omitempty"`
	AnnotationIds []string               `protobuf:"bytes,11,rep,name=annotation_ids,json=annotationIds,proto3" json:"annotation_ids,omitempty"`
	// contains filtered or unexported fields
}

type DatapointsQuery struct {
	SortAsc bool                   `protobuf:"varint,1,opt,name=sort_asc,json=sortAsc,proto3" json:"sort_asc,omitempty"`
	Limit   *uint32                `protobuf:"varint,2,opt,name=limit,proto3,oneof" json:"limit,omitempty"`
	LtTime  *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=lt_time,json=ltTime,proto3,oneof" json:"lt_time,omitempty"`
	GtTime  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=gt_time,json=gtTime,proto3,oneof" json:"gt_time,omitempty"`
	LtEqual bool                   `protobuf:"varint,5,opt,name=lt_equal,json=ltEqual,proto3" json:"lt_equal,omitempty"`
	GtEqual bool                   `protobuf:"varint,6,opt,name=gt_equal,json=gtEqual,proto3" json:"gt_equal,omitempty"`
	IsLocal bool                   `protobuf:"varint,7,opt,name=is_local,json=isLocal,proto3" json:"is_local,omitempty"`
	Lat     *float64               `protobuf:"fixed64,8,opt,name=lat,proto3,oneof" json:"lat,omitempty"`
	Lon     *float64               `protobuf:"fixed64,9,opt,name=lon,proto3,oneof" json:"lon,omitempty"`
	// contains filtered or unexported fields
}

type DatapointsServiceClient interface {
	StreamAggregates(ctx context.Context, in *StreamAggregatesRequest, opts ...grpc.CallOption) (DatapointsService_StreamAggregatesClient, error)
	StreamDatapoints(ctx context.Context, in *StreamDatapointsRequest, opts ...grpc.CallOption) (DatapointsService_StreamDatapointsClient, error)
}

type DatapointsServiceServer interface {
	StreamAggregates(*StreamAggregatesRequest, DatapointsService_StreamAggregatesServer) error
	StreamDatapoints(*StreamDatapointsRequest, DatapointsService_StreamDatapointsServer) error
	// contains filtered or unexported methods
}

type DatapointsService_StreamAggregatesClient interface {
	Recv() (*StreamAggregatesResponse, error)
	grpc.ClientStream
}

type DatapointsService_StreamAggregatesServer interface {
	Send(*StreamAggregatesResponse) error
	grpc.ServerStream
}

type DatapointsService_StreamDatapointsClient interface {
	Recv() (*StreamDatapointsResponse, error)
	grpc.ClientStream
}

type DatapointsService_StreamDatapointsServer interface {
	Send(*StreamDatapointsResponse) error
	grpc.ServerStream
}

type Datastream struct {
	XId                      string                      `protobuf:"bytes,1,opt,name=_id,json=Id,proto3" json:"_id,omitempty"`
	VersionId                string                      `protobuf:"bytes,2,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	Name                     string                      `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	DerivationMethod         string                      `protobuf:"bytes,4,opt,name=derivation_method,json=derivationMethod,proto3" json:"derivation_method,omitempty"`
	DerivedFromDatastreamIds []string                    `` /* 137-byte string literal not displayed */
	DatapointsConfig         []*DatapointsConfigInstance `protobuf:"bytes,10,rep,name=datapoints_config,json=datapointsConfig,proto3" json:"datapoints_config,omitempty"`
	DatapointsConfigBuilt    []*DatapointsConfigInstance `` /* 127-byte string literal not displayed */
	DatapointsConfigRefd     []*DatapointsConfigInstance `protobuf:"bytes,12,rep,name=datapoints_config_refd,json=datapointsConfigRefd,proto3" json:"datapoints_config_refd,omitempty"`
	StationLookup            *StationLookup              `protobuf:"bytes,13,opt,name=station_lookup,json=stationLookup,proto3" json:"station_lookup,omitempty"`
	Terms                    *structpb.Struct            `protobuf:"bytes,14,opt,name=terms,proto3" json:"terms,omitempty"`
	TermsInfo                *TermsInfo                  `protobuf:"bytes,15,opt,name=terms_info,json=termsInfo,proto3" json:"terms_info,omitempty"`
	// contains filtered or unexported fields
}

type EndTime struct {

	// The datapoint's timestamp in UTC
	T *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=t,proto3" json:"t,omitempty"`
	// An offset in seconds between the time zone and UTC
	O int32 `protobuf:"zigzag32,2,opt,name=o,proto3" json:"o,omitempty"`
	// contains filtered or unexported fields
}

type GetDatastreamRequest struct {
	DatastreamId string `protobuf:"bytes,1,opt,name=datastream_id,json=datastreamId,proto3" json:"datastream_id,omitempty"`
	// contains filtered or unexported fields
}

type GetDatastreamResponse struct {
	Datastream *Datastream `protobuf:"bytes,1,opt,name=datastream,proto3" json:"datastream,omitempty"`
	// contains filtered or unexported fields
}

type ListUomsResponse struct {
	Uoms []*Uom `protobuf:"bytes,1,rep,name=uoms,json=data,proto3" json:"uoms,omitempty"`
	// contains filtered or unexported fields
}

type MetadataServiceClient interface {
	GetDatastream(ctx context.Context, in *GetDatastreamRequest, opts ...grpc.CallOption) (*GetDatastreamResponse, error)
	ListUoms(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListUomsResponse, error)
}

type MetadataServiceServer interface {
	GetDatastream(context.Context, *GetDatastreamRequest) (*GetDatastreamResponse, error)
	ListUoms(context.Context, *emptypb.Empty) (*ListUomsResponse, error)
	// contains filtered or unexported methods
}

type ProviderServiceClient interface {
	StreamDatapoints(ctx context.Context, in *ProviderStreamDatapointsRequest, opts ...grpc.CallOption) (ProviderService_StreamDatapointsClient, error)
}

type ProviderServiceServer interface {
	StreamDatapoints(*ProviderStreamDatapointsRequest, ProviderService_StreamDatapointsServer) error
	// contains filtered or unexported methods
}

type ProviderService_StreamDatapointsClient interface {
	Recv() (*ProviderStreamDatapointsResponse, error)
	grpc.ClientStream
}

type ProviderService_StreamDatapointsServer interface {
	Send(*ProviderStreamDatapointsResponse) error
	grpc.ServerStream
}

type ProviderStreamDatapointsRequest struct {
	Query          *DatapointsQuery          `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	ConfigInstance *DatapointsConfigInstance `protobuf:"bytes,2,opt,name=config_instance,json=configInstance,proto3" json:"config_instance,omitempty"`
	// contains filtered or unexported fields
}

type ProviderStreamDatapointsResponse struct {
	Datapoints []*Datapoint `protobuf:"bytes,1,rep,name=datapoints,proto3" json:"datapoints,omitempty"`
	// contains filtered or unexported fields
}

type StationLookup struct {
	UtcOffset int32 `protobuf:"zigzag32,1,opt,name=utc_offset,json=utcOffset,proto3" json:"utc_offset,omitempty"`
	// contains filtered or unexported fields
}

type StreamAggregatesRequest struct {
	DatastreamId string           `protobuf:"bytes,1,opt,name=datastream_id,json=datastreamId,proto3" json:"datastream_id,omitempty"`
	Query        *DatapointsQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	Convert      *ConvertArgs     `protobuf:"bytes,3,opt,name=convert,proto3" json:"convert,omitempty"`
	BucketWidth  string           `protobuf:"bytes,4,opt,name=bucket_width,json=bucketWidth,proto3" json:"bucket_width,omitempty"`
	CountOnly    bool             `protobuf:"varint,5,opt,name=count_only,json=countOnly,proto3" json:"count_only,omitempty"`
	// contains filtered or unexported fields
}

type StreamAggregatesResponse struct {
	Aggregates []*Aggregate `protobuf:"bytes,1,rep,name=aggregates,proto3" json:"aggregates,omitempty"`
	// contains filtered or unexported fields
}

type StreamDatapointsRequest struct {
	DatastreamId string           `protobuf:"bytes,1,opt,name=datastream_id,json=datastreamId,proto3" json:"datastream_id,omitempty"`
	Query        *DatapointsQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	Convert      *ConvertArgs     `protobuf:"bytes,3,opt,name=convert,proto3" json:"convert,omitempty"`
	// contains filtered or unexported fields
}

type StreamDatapointsResponse struct {
	Datapoints []*Datapoint `protobuf:"bytes,1,rep,name=datapoints,proto3" json:"datapoints,omitempty"`
	// contains filtered or unexported fields
}

type TermsInfo struct {
	ClassKeys []string `protobuf:"bytes,1,rep,name=class_keys,json=classKeys,proto3" json:"class_keys,omitempty"`
	ClassTags []string `protobuf:"bytes,2,rep,name=class_tags,json=classTags,proto3" json:"class_tags,omitempty"`
	UnitTag   string   `protobuf:"bytes,3,opt,name=unit_tag,json=unitTag,proto3" json:"unit_tag,omitempty"`
	// contains filtered or unexported fields
}

type TransformArgs struct {
	Expression string `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

type TransformManyRequest struct {
	Transform  *TransformArgs `protobuf:"bytes,1,opt,name=transform,proto3" json:"transform,omitempty"`
	Datapoints []*Datapoint   `protobuf:"bytes,2,rep,name=datapoints,proto3" json:"datapoints,omitempty"`
	// contains filtered or unexported fields
}

type TransformManyResponse struct {
	Datapoints []*Datapoint `protobuf:"bytes,1,rep,name=datapoints,proto3" json:"datapoints,omitempty"`
	// contains filtered or unexported fields
}

type TransformerServiceClient interface {
	TransformMany(ctx context.Context, in *TransformManyRequest, opts ...grpc.CallOption) (*TransformManyResponse, error)
}

type TransformerServiceServer interface {
	TransformMany(context.Context, *TransformManyRequest) (*TransformManyResponse, error)
	// contains filtered or unexported methods
}

type UnimplementedConverterServiceServer struct {
}

type UnimplementedDatapointsServiceServer struct {
}

type UnimplementedMetadataServiceServer struct {
}

type UnimplementedProviderServiceServer struct {
}

type UnimplementedTransformerServiceServer struct {
}

type UnsafeConverterServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeDatapointsServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeMetadataServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeProviderServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeTransformerServiceServer interface {
	// contains filtered or unexported methods
}

type Uom struct {
	XId                 string           `protobuf:"bytes,1,opt,name=_id,json=Id,proto3" json:"_id,omitempty"`
	VersionId           string           `protobuf:"bytes,2,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	SomId               string           `protobuf:"bytes,3,opt,name=som_id,json=somId,proto3" json:"som_id,omitempty"`
	ConvertibleToUomIds []string         `protobuf:"bytes,4,rep,name=convertible_to_uom_ids,json=convertibleToUomIds,proto3" json:"convertible_to_uom_ids,omitempty"`
	UnitTags            []string         `protobuf:"bytes,5,rep,name=unit_tags,json=unitTags,proto3" json:"unit_tags,omitempty"`
	LibraryConfig       *structpb.Struct `protobuf:"bytes,6,opt,name=library_config,json=libraryConfig,proto3" json:"library_config,omitempty"`
	// contains filtered or unexported fields
}