v3

package
v0.0.0-...-2464bcb Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2023 License: BSD-3-Clause Imports: 13 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ConverterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v3.ConverterService",
	HandlerType: (*ConverterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ConvertAggregates",
			Handler:    _ConverterService_ConvertAggregates_Handler,
		},
		{
			MethodName: "ConvertDatapoints",
			Handler:    _ConverterService_ConvertDatapoints_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v3/converter.proto",
}

ConverterService_ServiceDesc is the grpc.ServiceDesc for ConverterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DatapointsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v3.DatapointsService",
	HandlerType: (*DatapointsServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamAggregates",
			Handler:       _DatapointsService_StreamAggregates_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamDatapoints",
			Handler:       _DatapointsService_StreamDatapoints_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "v3/datapoints.proto",
}

DatapointsService_ServiceDesc is the grpc.ServiceDesc for DatapointsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_v3_converter_proto protoreflect.FileDescriptor
View Source 
var File_v3_datapoints_proto protoreflect.FileDescriptor
View Source 
var File_v3_metadata_proto protoreflect.FileDescriptor
View Source 
var File_v3_provider_proto protoreflect.FileDescriptor
View Source 
var File_v3_transformer_proto protoreflect.FileDescriptor
View Source 
var File_v3_types_proto protoreflect.FileDescriptor
View Source 
var MetadataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v3.MetadataService",
	HandlerType: (*MetadataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDatastream",
			Handler:    _MetadataService_GetDatastream_Handler,
		},
		{
			MethodName: "ListUoms",
			Handler:    _MetadataService_ListUoms_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v3/metadata.proto",
}

MetadataService_ServiceDesc is the grpc.ServiceDesc for MetadataService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ProviderService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v3.ProviderService",
	HandlerType: (*ProviderServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamDatapoints",
			Handler:       _ProviderService_StreamDatapoints_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "v3/provider.proto",
}

ProviderService_ServiceDesc is the grpc.ServiceDesc for ProviderService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TransformerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v3.TransformerService",
	HandlerType: (*TransformerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TransformMany",
			Handler:    _TransformerService_TransformMany_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v3/transformer.proto",
}

TransformerService_ServiceDesc is the grpc.ServiceDesc for TransformerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterConverterServiceServer 

func RegisterConverterServiceServer(s grpc.ServiceRegistrar, srv ConverterServiceServer)

func RegisterDatapointsServiceServer 

func RegisterDatapointsServiceServer(s grpc.ServiceRegistrar, srv DatapointsServiceServer)

func RegisterMetadataServiceServer 

func RegisterMetadataServiceServer(s grpc.ServiceRegistrar, srv MetadataServiceServer)

func RegisterProviderServiceServer 

func RegisterProviderServiceServer(s grpc.ServiceRegistrar, srv ProviderServiceServer)

func RegisterTransformerServiceServer 

func RegisterTransformerServiceServer(s grpc.ServiceRegistrar, srv TransformerServiceServer)

Types

type Aggregate 

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
}

An individual time series aggregation in a datastream

func (*Aggregate) Descriptor deprecated 

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

Deprecated: Use Aggregate.ProtoReflect.Descriptor instead.

func (*Aggregate) GetCount 

func (x *Aggregate) GetCount() uint32

func (*Aggregate) GetQ 

func (x *Aggregate) GetQ() *DataQuality

func (*Aggregate) GetTs 

func (x *Aggregate) GetTs() *timestamppb.Timestamp

func (*Aggregate) GetUv 

func (x *Aggregate) GetUv() *AggregateValue

func (*Aggregate) GetV 

func (x *Aggregate) GetV() *AggregateValue

func (*Aggregate) ProtoMessage 

func (*Aggregate) ProtoMessage()

func (*Aggregate) ProtoReflect 

func (x *Aggregate) ProtoReflect() protoreflect.Message

func (*Aggregate) Reset 

func (x *Aggregate) Reset()

func (*Aggregate) String 

func (x *Aggregate) String() string

type AggregateValue 

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
}

func (*AggregateValue) Descriptor deprecated 

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

Deprecated: Use AggregateValue.ProtoReflect.Descriptor instead.

func (*AggregateValue) GetMaximum 

func (x *AggregateValue) GetMaximum() float64

func (*AggregateValue) GetMinimum 

func (x *AggregateValue) GetMinimum() float64

func (*AggregateValue) GetSummation 

func (x *AggregateValue) GetSummation() float64

func (*AggregateValue) ProtoMessage 

func (*AggregateValue) ProtoMessage()

func (*AggregateValue) ProtoReflect 

func (x *AggregateValue) ProtoReflect() protoreflect.Message

func (*AggregateValue) Reset 

func (x *AggregateValue) Reset()

func (*AggregateValue) String 

func (x *AggregateValue) String() string

type AnnotationActions 

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
}

func (*AnnotationActions) Descriptor deprecated 

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

Deprecated: Use AnnotationActions.ProtoReflect.Descriptor instead.

func (*AnnotationActions) GetAttrib 

func (x *AnnotationActions) GetAttrib() *structpb.Struct

func (*AnnotationActions) GetEvaluate 

func (x *AnnotationActions) GetEvaluate() string

func (*AnnotationActions) GetExclude 

func (x *AnnotationActions) GetExclude() bool

func (*AnnotationActions) GetFlag 

func (x *AnnotationActions) GetFlag() []string

func (*AnnotationActions) ProtoMessage 

func (*AnnotationActions) ProtoMessage()

func (*AnnotationActions) ProtoReflect 

func (x *AnnotationActions) ProtoReflect() protoreflect.Message

func (*AnnotationActions) Reset 

func (x *AnnotationActions) Reset()

func (*AnnotationActions) String 

func (x *AnnotationActions) String() string

type ConvertAggregatesRequest 

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
}

func (*ConvertAggregatesRequest) Descriptor deprecated 

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

Deprecated: Use ConvertAggregatesRequest.ProtoReflect.Descriptor instead.

func (*ConvertAggregatesRequest) GetAggregates 

func (x *ConvertAggregatesRequest) GetAggregates() []*Aggregate

func (*ConvertAggregatesRequest) GetConvert 

func (x *ConvertAggregatesRequest) GetConvert() *ConvertArgs

func (*ConvertAggregatesRequest) ProtoMessage 

func (*ConvertAggregatesRequest) ProtoMessage()

func (*ConvertAggregatesRequest) ProtoReflect 

func (x *ConvertAggregatesRequest) ProtoReflect() protoreflect.Message

func (*ConvertAggregatesRequest) Reset 

func (x *ConvertAggregatesRequest) Reset()

func (*ConvertAggregatesRequest) String 

func (x *ConvertAggregatesRequest) String() string

type ConvertAggregatesResponse 

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

func (*ConvertAggregatesResponse) Descriptor deprecated 

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

Deprecated: Use ConvertAggregatesResponse.ProtoReflect.Descriptor instead.

func (*ConvertAggregatesResponse) GetAggregates 

func (x *ConvertAggregatesResponse) GetAggregates() []*Aggregate

func (*ConvertAggregatesResponse) ProtoMessage 

func (*ConvertAggregatesResponse) ProtoMessage()

func (*ConvertAggregatesResponse) ProtoReflect 

func (x *ConvertAggregatesResponse) ProtoReflect() protoreflect.Message

func (*ConvertAggregatesResponse) Reset 

func (x *ConvertAggregatesResponse) Reset()

func (*ConvertAggregatesResponse) String 

func (x *ConvertAggregatesResponse) String() string

type ConvertArgs 

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
}

func (*ConvertArgs) Descriptor deprecated 

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

Deprecated: Use ConvertArgs.ProtoReflect.Descriptor instead.

func (*ConvertArgs) GetFromUnit 

func (x *ConvertArgs) GetFromUnit() string

func (*ConvertArgs) GetLibrary 

func (x *ConvertArgs) GetLibrary() string

func (*ConvertArgs) GetToUnit 

func (x *ConvertArgs) GetToUnit() string

func (*ConvertArgs) ProtoMessage 

func (*ConvertArgs) ProtoMessage()

func (*ConvertArgs) ProtoReflect 

func (x *ConvertArgs) ProtoReflect() protoreflect.Message

func (*ConvertArgs) Reset 

func (x *ConvertArgs) Reset()

func (*ConvertArgs) String 

func (x *ConvertArgs) String() string

type ConvertDatapointsRequest 

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
}

func (*ConvertDatapointsRequest) Descriptor deprecated 

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

Deprecated: Use ConvertDatapointsRequest.ProtoReflect.Descriptor instead.

func (*ConvertDatapointsRequest) GetConvert 

func (x *ConvertDatapointsRequest) GetConvert() *ConvertArgs

func (*ConvertDatapointsRequest) GetDatapoints 

func (x *ConvertDatapointsRequest) GetDatapoints() []*Datapoint

func (*ConvertDatapointsRequest) ProtoMessage 

func (*ConvertDatapointsRequest) ProtoMessage()

func (*ConvertDatapointsRequest) ProtoReflect 

func (x *ConvertDatapointsRequest) ProtoReflect() protoreflect.Message

func (*ConvertDatapointsRequest) Reset 

func (x *ConvertDatapointsRequest) Reset()

func (*ConvertDatapointsRequest) String 

func (x *ConvertDatapointsRequest) String() string

type ConvertDatapointsResponse 

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

func (*ConvertDatapointsResponse) Descriptor deprecated 

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

Deprecated: Use ConvertDatapointsResponse.ProtoReflect.Descriptor instead.

func (*ConvertDatapointsResponse) GetDatapoints 

func (x *ConvertDatapointsResponse) GetDatapoints() []*Datapoint

func (*ConvertDatapointsResponse) ProtoMessage 

func (*ConvertDatapointsResponse) ProtoMessage()

func (*ConvertDatapointsResponse) ProtoReflect 

func (x *ConvertDatapointsResponse) ProtoReflect() protoreflect.Message

func (*ConvertDatapointsResponse) Reset 

func (x *ConvertDatapointsResponse) Reset()

func (*ConvertDatapointsResponse) String 

func (x *ConvertDatapointsResponse) String() string

type ConverterServiceClient 

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

ConverterServiceClient is the client API for ConverterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewConverterServiceClient 

func NewConverterServiceClient(cc grpc.ClientConnInterface) ConverterServiceClient

type ConverterServiceServer 

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

ConverterServiceServer is the server API for ConverterService service. All implementations must embed UnimplementedConverterServiceServer for forward compatibility

type DataQuality 

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
}

func (*DataQuality) Descriptor deprecated 

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

Deprecated: Use DataQuality.ProtoReflect.Descriptor instead.

func (*DataQuality) GetAnnotationIds 

func (x *DataQuality) GetAnnotationIds() []string

func (*DataQuality) GetAttrib 

func (x *DataQuality) GetAttrib() *structpb.Struct

func (*DataQuality) GetFlag 

func (x *DataQuality) GetFlag() []string

func (*DataQuality) ProtoMessage 

func (*DataQuality) ProtoMessage()

func (*DataQuality) ProtoReflect 

func (x *DataQuality) ProtoReflect() protoreflect.Message

func (*DataQuality) Reset 

func (x *DataQuality) Reset()

func (*DataQuality) String 

func (x *DataQuality) String() string

type Datapoint 

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
}

An individual time series observation in a datastream

func (*Datapoint) Descriptor deprecated 

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

Deprecated: Use Datapoint.ProtoReflect.Descriptor instead.

func (*Datapoint) GetD 

func (x *Datapoint) GetD() *structpb.Struct

func (*Datapoint) GetDa 

func (x *Datapoint) GetDa() []*structpb.Struct

func (*Datapoint) GetEt 

func (x *Datapoint) GetEt() *EndTime

func (*Datapoint) GetG 

func (x *Datapoint) GetG() *structpb.Struct

func (*Datapoint) GetGc 

func (x *Datapoint) GetGc() []float64

func (*Datapoint) GetLt 

func (x *Datapoint) GetLt() *timestamppb.Timestamp

func (*Datapoint) GetO 

func (x *Datapoint) GetO() int32

func (*Datapoint) GetQ 

func (x *Datapoint) GetQ() *DataQuality

func (*Datapoint) GetT 

func (x *Datapoint) GetT() *timestamppb.Timestamp

func (*Datapoint) GetTi 

func (x *Datapoint) GetTi() *structpb.Struct

func (*Datapoint) GetUv 

func (x *Datapoint) GetUv() float64

func (*Datapoint) GetV 

func (x *Datapoint) GetV() float64

func (*Datapoint) GetVa 

func (x *Datapoint) GetVa() []float64

func (*Datapoint) ProtoMessage 

func (*Datapoint) ProtoMessage()

func (*Datapoint) ProtoReflect 

func (x *Datapoint) ProtoReflect() protoreflect.Message

func (*Datapoint) Reset 

func (x *Datapoint) Reset()

func (*Datapoint) String 

func (x *Datapoint) String() string

type DatapointsConfigInstance 

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
}

User-defined service configuration for fetching datapoints

func (*DatapointsConfigInstance) Descriptor deprecated 

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

Deprecated: Use DatapointsConfigInstance.ProtoReflect.Descriptor instead.

func (*DatapointsConfigInstance) GetActions 

func (x *DatapointsConfigInstance) GetActions() *AnnotationActions

func (*DatapointsConfigInstance) GetAnnotationIds 

func (x *DatapointsConfigInstance) GetAnnotationIds() []string

func (*DatapointsConfigInstance) GetBeginsAt 

func (x *DatapointsConfigInstance) GetBeginsAt() *timestamppb.Timestamp

func (*DatapointsConfigInstance) GetConnection 

func (x *DatapointsConfigInstance) GetConnection() string

func (*DatapointsConfigInstance) GetEndsBefore 

func (x *DatapointsConfigInstance) GetEndsBefore() *timestamppb.Timestamp

func (*DatapointsConfigInstance) GetParams 

func (x *DatapointsConfigInstance) GetParams() *structpb.Struct

func (*DatapointsConfigInstance) GetPath 

func (x *DatapointsConfigInstance) GetPath() string

func (*DatapointsConfigInstance) GetRef 

func (x *DatapointsConfigInstance) GetRef() uint32

func (*DatapointsConfigInstance) ProtoMessage 

func (*DatapointsConfigInstance) ProtoMessage()

func (*DatapointsConfigInstance) ProtoReflect 

func (x *DatapointsConfigInstance) ProtoReflect() protoreflect.Message

func (*DatapointsConfigInstance) Reset 

func (x *DatapointsConfigInstance) Reset()

func (*DatapointsConfigInstance) String 

func (x *DatapointsConfigInstance) String() string

type DatapointsQuery 

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
}

func (*DatapointsQuery) Descriptor deprecated 

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

Deprecated: Use DatapointsQuery.ProtoReflect.Descriptor instead.

func (*DatapointsQuery) GetGtEqual 

func (x *DatapointsQuery) GetGtEqual() bool

func (*DatapointsQuery) GetGtTime 

func (x *DatapointsQuery) GetGtTime() *timestamppb.Timestamp

func (*DatapointsQuery) GetIsLocal 

func (x *DatapointsQuery) GetIsLocal() bool

func (*DatapointsQuery) GetLat 

func (x *DatapointsQuery) GetLat() float64

func (*DatapointsQuery) GetLimit 

func (x *DatapointsQuery) GetLimit() uint32

func (*DatapointsQuery) GetLon 

func (x *DatapointsQuery) GetLon() float64

func (*DatapointsQuery) GetLtEqual 

func (x *DatapointsQuery) GetLtEqual() bool

func (*DatapointsQuery) GetLtTime 

func (x *DatapointsQuery) GetLtTime() *timestamppb.Timestamp

func (*DatapointsQuery) GetSortAsc 

func (x *DatapointsQuery) GetSortAsc() bool

func (*DatapointsQuery) ProtoMessage 

func (*DatapointsQuery) ProtoMessage()

func (*DatapointsQuery) ProtoReflect 

func (x *DatapointsQuery) ProtoReflect() protoreflect.Message

func (*DatapointsQuery) Reset 

func (x *DatapointsQuery) Reset()

func (*DatapointsQuery) String 

func (x *DatapointsQuery) String() string

type DatapointsServiceClient 

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

DatapointsServiceClient is the client API for DatapointsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDatapointsServiceClient 

func NewDatapointsServiceClient(cc grpc.ClientConnInterface) DatapointsServiceClient

type DatapointsServiceServer 

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

DatapointsServiceServer is the server API for DatapointsService service. All implementations must embed UnimplementedDatapointsServiceServer for forward compatibility

type DatapointsService_StreamAggregatesClient 

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

type DatapointsService_StreamAggregatesServer 

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

type DatapointsService_StreamDatapointsClient 

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

type DatapointsService_StreamDatapointsServer 

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

type Datastream 

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
}

A continuous series of datapoints indexed in time order.

func (*Datastream) Descriptor deprecated 

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

Deprecated: Use Datastream.ProtoReflect.Descriptor instead.

func (*Datastream) GetDatapointsConfig 

func (x *Datastream) GetDatapointsConfig() []*DatapointsConfigInstance

func (*Datastream) GetDatapointsConfigBuilt 

func (x *Datastream) GetDatapointsConfigBuilt() []*DatapointsConfigInstance

func (*Datastream) GetDatapointsConfigRefd 

func (x *Datastream) GetDatapointsConfigRefd() []*DatapointsConfigInstance

func (*Datastream) GetDerivationMethod 

func (x *Datastream) GetDerivationMethod() string

func (*Datastream) GetDerivedFromDatastreamIds 

func (x *Datastream) GetDerivedFromDatastreamIds() []string

func (*Datastream) GetName 

func (x *Datastream) GetName() string

func (*Datastream) GetStationLookup 

func (x *Datastream) GetStationLookup() *StationLookup

func (*Datastream) GetTerms 

func (x *Datastream) GetTerms() *structpb.Struct

func (*Datastream) GetTermsInfo 

func (x *Datastream) GetTermsInfo() *TermsInfo

func (*Datastream) GetVersionId 

func (x *Datastream) GetVersionId() string

func (*Datastream) GetXId 

func (x *Datastream) GetXId() string

func (*Datastream) ProtoMessage 

func (*Datastream) ProtoMessage()

func (*Datastream) ProtoReflect 

func (x *Datastream) ProtoReflect() protoreflect.Message

func (*Datastream) Reset 

func (x *Datastream) Reset()

func (*Datastream) String 

func (x *Datastream) String() string

type EndTime 

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
}

An end time object for observations that span a period of time

func (*EndTime) Descriptor deprecated 

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

Deprecated: Use EndTime.ProtoReflect.Descriptor instead.

func (*EndTime) GetO 

func (x *EndTime) GetO() int32

func (*EndTime) GetT 

func (x *EndTime) GetT() *timestamppb.Timestamp

func (*EndTime) ProtoMessage 

func (*EndTime) ProtoMessage()

func (*EndTime) ProtoReflect 

func (x *EndTime) ProtoReflect() protoreflect.Message

func (*EndTime) Reset 

func (x *EndTime) Reset()

func (*EndTime) String 

func (x *EndTime) String() string

type GetDatastreamRequest 

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

func (*GetDatastreamRequest) Descriptor deprecated 

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

Deprecated: Use GetDatastreamRequest.ProtoReflect.Descriptor instead.

func (*GetDatastreamRequest) GetDatastreamId 

func (x *GetDatastreamRequest) GetDatastreamId() string

func (*GetDatastreamRequest) ProtoMessage 

func (*GetDatastreamRequest) ProtoMessage()

func (*GetDatastreamRequest) ProtoReflect 

func (x *GetDatastreamRequest) ProtoReflect() protoreflect.Message

func (*GetDatastreamRequest) Reset 

func (x *GetDatastreamRequest) Reset()

func (*GetDatastreamRequest) String 

func (x *GetDatastreamRequest) String() string

type GetDatastreamResponse 

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

func (*GetDatastreamResponse) Descriptor deprecated 

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

Deprecated: Use GetDatastreamResponse.ProtoReflect.Descriptor instead.

func (*GetDatastreamResponse) GetDatastream 

func (x *GetDatastreamResponse) GetDatastream() *Datastream

func (*GetDatastreamResponse) ProtoMessage 

func (*GetDatastreamResponse) ProtoMessage()

func (*GetDatastreamResponse) ProtoReflect 

func (x *GetDatastreamResponse) ProtoReflect() protoreflect.Message

func (*GetDatastreamResponse) Reset 

func (x *GetDatastreamResponse) Reset()

func (*GetDatastreamResponse) String 

func (x *GetDatastreamResponse) String() string

type ListUomsResponse 

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

func (*ListUomsResponse) Descriptor deprecated 

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

Deprecated: Use ListUomsResponse.ProtoReflect.Descriptor instead.

func (*ListUomsResponse) GetUoms 

func (x *ListUomsResponse) GetUoms() []*Uom

func (*ListUomsResponse) ProtoMessage 

func (*ListUomsResponse) ProtoMessage()

func (*ListUomsResponse) ProtoReflect 

func (x *ListUomsResponse) ProtoReflect() protoreflect.Message

func (*ListUomsResponse) Reset 

func (x *ListUomsResponse) Reset()

func (*ListUomsResponse) String 

func (x *ListUomsResponse) String() string

type MetadataServiceClient 

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

MetadataServiceClient is the client API for MetadataService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMetadataServiceClient 

func NewMetadataServiceClient(cc grpc.ClientConnInterface) MetadataServiceClient

type MetadataServiceServer 

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

MetadataServiceServer is the server API for MetadataService service. All implementations must embed UnimplementedMetadataServiceServer for forward compatibility

type ProviderServiceClient 

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

ProviderServiceClient is the client API for ProviderService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewProviderServiceClient 

func NewProviderServiceClient(cc grpc.ClientConnInterface) ProviderServiceClient

type ProviderServiceServer 

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

ProviderServiceServer is the server API for ProviderService service. All implementations must embed UnimplementedProviderServiceServer for forward compatibility

type ProviderService_StreamDatapointsClient 

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

type ProviderService_StreamDatapointsServer 

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

type ProviderStreamDatapointsRequest 

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
}

func (*ProviderStreamDatapointsRequest) Descriptor deprecated 

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

Deprecated: Use ProviderStreamDatapointsRequest.ProtoReflect.Descriptor instead.

func (*ProviderStreamDatapointsRequest) GetConfigInstance 

func (x *ProviderStreamDatapointsRequest) GetConfigInstance() *DatapointsConfigInstance

func (*ProviderStreamDatapointsRequest) GetQuery 

func (x *ProviderStreamDatapointsRequest) GetQuery() *DatapointsQuery

func (*ProviderStreamDatapointsRequest) ProtoMessage 

func (*ProviderStreamDatapointsRequest) ProtoMessage()

func (*ProviderStreamDatapointsRequest) ProtoReflect 

func (x *ProviderStreamDatapointsRequest) ProtoReflect() protoreflect.Message

func (*ProviderStreamDatapointsRequest) Reset 

func (x *ProviderStreamDatapointsRequest) Reset()

func (*ProviderStreamDatapointsRequest) String 

func (x *ProviderStreamDatapointsRequest) String() string

type ProviderStreamDatapointsResponse 

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

func (*ProviderStreamDatapointsResponse) Descriptor deprecated 

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

Deprecated: Use ProviderStreamDatapointsResponse.ProtoReflect.Descriptor instead.

func (*ProviderStreamDatapointsResponse) GetDatapoints 

func (x *ProviderStreamDatapointsResponse) GetDatapoints() []*Datapoint

func (*ProviderStreamDatapointsResponse) ProtoMessage 

func (*ProviderStreamDatapointsResponse) ProtoMessage()

func (*ProviderStreamDatapointsResponse) ProtoReflect 

func (x *ProviderStreamDatapointsResponse) ProtoReflect() protoreflect.Message

func (*ProviderStreamDatapointsResponse) Reset 

func (x *ProviderStreamDatapointsResponse) Reset()

func (*ProviderStreamDatapointsResponse) String 

func (x *ProviderStreamDatapointsResponse) String() string

type StationLookup 

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

func (*StationLookup) Descriptor deprecated 

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

Deprecated: Use StationLookup.ProtoReflect.Descriptor instead.

func (*StationLookup) GetUtcOffset 

func (x *StationLookup) GetUtcOffset() int32

func (*StationLookup) ProtoMessage 

func (*StationLookup) ProtoMessage()

func (*StationLookup) ProtoReflect 

func (x *StationLookup) ProtoReflect() protoreflect.Message

func (*StationLookup) Reset 

func (x *StationLookup) Reset()

func (*StationLookup) String 

func (x *StationLookup) String() string

type StreamAggregatesRequest 

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
}

func (*StreamAggregatesRequest) Descriptor deprecated 

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

Deprecated: Use StreamAggregatesRequest.ProtoReflect.Descriptor instead.

func (*StreamAggregatesRequest) GetBucketWidth 

func (x *StreamAggregatesRequest) GetBucketWidth() string

func (*StreamAggregatesRequest) GetConvert 

func (x *StreamAggregatesRequest) GetConvert() *ConvertArgs

func (*StreamAggregatesRequest) GetCountOnly 

func (x *StreamAggregatesRequest) GetCountOnly() bool

func (*StreamAggregatesRequest) GetDatastreamId 

func (x *StreamAggregatesRequest) GetDatastreamId() string

func (*StreamAggregatesRequest) GetQuery 

func (x *StreamAggregatesRequest) GetQuery() *DatapointsQuery

func (*StreamAggregatesRequest) ProtoMessage 

func (*StreamAggregatesRequest) ProtoMessage()

func (*StreamAggregatesRequest) ProtoReflect 

func (x *StreamAggregatesRequest) ProtoReflect() protoreflect.Message

func (*StreamAggregatesRequest) Reset 

func (x *StreamAggregatesRequest) Reset()

func (*StreamAggregatesRequest) String 

func (x *StreamAggregatesRequest) String() string

type StreamAggregatesResponse 

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

func (*StreamAggregatesResponse) Descriptor deprecated 

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

Deprecated: Use StreamAggregatesResponse.ProtoReflect.Descriptor instead.

func (*StreamAggregatesResponse) GetAggregates 

func (x *StreamAggregatesResponse) GetAggregates() []*Aggregate

func (*StreamAggregatesResponse) ProtoMessage 

func (*StreamAggregatesResponse) ProtoMessage()

func (*StreamAggregatesResponse) ProtoReflect 

func (x *StreamAggregatesResponse) ProtoReflect() protoreflect.Message

func (*StreamAggregatesResponse) Reset 

func (x *StreamAggregatesResponse) Reset()

func (*StreamAggregatesResponse) String 

func (x *StreamAggregatesResponse) String() string

type StreamDatapointsRequest 

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
}

func (*StreamDatapointsRequest) Descriptor deprecated 

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

Deprecated: Use StreamDatapointsRequest.ProtoReflect.Descriptor instead.

func (*StreamDatapointsRequest) GetConvert 

func (x *StreamDatapointsRequest) GetConvert() *ConvertArgs

func (*StreamDatapointsRequest) GetDatastreamId 

func (x *StreamDatapointsRequest) GetDatastreamId() string

func (*StreamDatapointsRequest) GetQuery 

func (x *StreamDatapointsRequest) GetQuery() *DatapointsQuery

func (*StreamDatapointsRequest) ProtoMessage 

func (*StreamDatapointsRequest) ProtoMessage()

func (*StreamDatapointsRequest) ProtoReflect 

func (x *StreamDatapointsRequest) ProtoReflect() protoreflect.Message

func (*StreamDatapointsRequest) Reset 

func (x *StreamDatapointsRequest) Reset()

func (*StreamDatapointsRequest) String 

func (x *StreamDatapointsRequest) String() string

type StreamDatapointsResponse 

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

func (*StreamDatapointsResponse) Descriptor deprecated 

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

Deprecated: Use StreamDatapointsResponse.ProtoReflect.Descriptor instead.

func (*StreamDatapointsResponse) GetDatapoints 

func (x *StreamDatapointsResponse) GetDatapoints() []*Datapoint

func (*StreamDatapointsResponse) ProtoMessage 

func (*StreamDatapointsResponse) ProtoMessage()

func (*StreamDatapointsResponse) ProtoReflect 

func (x *StreamDatapointsResponse) ProtoReflect() protoreflect.Message

func (*StreamDatapointsResponse) Reset 

func (x *StreamDatapointsResponse) Reset()

func (*StreamDatapointsResponse) String 

func (x *StreamDatapointsResponse) String() string

type TermsInfo 

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
}

func (*TermsInfo) Descriptor deprecated 

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

Deprecated: Use TermsInfo.ProtoReflect.Descriptor instead.

func (*TermsInfo) GetClassKeys 

func (x *TermsInfo) GetClassKeys() []string

func (*TermsInfo) GetClassTags 

func (x *TermsInfo) GetClassTags() []string

func (*TermsInfo) GetUnitTag 

func (x *TermsInfo) GetUnitTag() string

func (*TermsInfo) ProtoMessage 

func (*TermsInfo) ProtoMessage()

func (*TermsInfo) ProtoReflect 

func (x *TermsInfo) ProtoReflect() protoreflect.Message

func (*TermsInfo) Reset 

func (x *TermsInfo) Reset()

func (*TermsInfo) String 

func (x *TermsInfo) String() string

type TransformArgs 

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

func (*TransformArgs) Descriptor deprecated 

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

Deprecated: Use TransformArgs.ProtoReflect.Descriptor instead.

func (*TransformArgs) GetExpression 

func (x *TransformArgs) GetExpression() string

func (*TransformArgs) ProtoMessage 

func (*TransformArgs) ProtoMessage()

func (*TransformArgs) ProtoReflect 

func (x *TransformArgs) ProtoReflect() protoreflect.Message

func (*TransformArgs) Reset 

func (x *TransformArgs) Reset()

func (*TransformArgs) String 

func (x *TransformArgs) String() string

type TransformManyRequest 

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
}

func (*TransformManyRequest) Descriptor deprecated 

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

Deprecated: Use TransformManyRequest.ProtoReflect.Descriptor instead.

func (*TransformManyRequest) GetDatapoints 

func (x *TransformManyRequest) GetDatapoints() []*Datapoint

func (*TransformManyRequest) GetTransform 

func (x *TransformManyRequest) GetTransform() *TransformArgs

func (*TransformManyRequest) ProtoMessage 

func (*TransformManyRequest) ProtoMessage()

func (*TransformManyRequest) ProtoReflect 

func (x *TransformManyRequest) ProtoReflect() protoreflect.Message

func (*TransformManyRequest) Reset 

func (x *TransformManyRequest) Reset()

func (*TransformManyRequest) String 

func (x *TransformManyRequest) String() string

type TransformManyResponse 

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

func (*TransformManyResponse) Descriptor deprecated 

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

Deprecated: Use TransformManyResponse.ProtoReflect.Descriptor instead.

func (*TransformManyResponse) GetDatapoints 

func (x *TransformManyResponse) GetDatapoints() []*Datapoint

func (*TransformManyResponse) ProtoMessage 

func (*TransformManyResponse) ProtoMessage()

func (*TransformManyResponse) ProtoReflect 

func (x *TransformManyResponse) ProtoReflect() protoreflect.Message

func (*TransformManyResponse) Reset 

func (x *TransformManyResponse) Reset()

func (*TransformManyResponse) String 

func (x *TransformManyResponse) String() string

type TransformerServiceClient 

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

TransformerServiceClient is the client API for TransformerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTransformerServiceClient 

func NewTransformerServiceClient(cc grpc.ClientConnInterface) TransformerServiceClient

type TransformerServiceServer 

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

TransformerServiceServer is the server API for TransformerService service. All implementations must embed UnimplementedTransformerServiceServer for forward compatibility

type UnimplementedConverterServiceServer 

type UnimplementedConverterServiceServer struct {
}

UnimplementedConverterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedConverterServiceServer) ConvertAggregates 

func (UnimplementedConverterServiceServer) ConvertAggregates(context.Context, *ConvertAggregatesRequest) (*ConvertAggregatesResponse, error)

func (UnimplementedConverterServiceServer) ConvertDatapoints 

func (UnimplementedConverterServiceServer) ConvertDatapoints(context.Context, *ConvertDatapointsRequest) (*ConvertDatapointsResponse, error)

type UnimplementedDatapointsServiceServer 

type UnimplementedDatapointsServiceServer struct {
}

UnimplementedDatapointsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDatapointsServiceServer) StreamAggregates 

func (UnimplementedDatapointsServiceServer) StreamAggregates(*StreamAggregatesRequest, DatapointsService_StreamAggregatesServer) error

func (UnimplementedDatapointsServiceServer) StreamDatapoints 

func (UnimplementedDatapointsServiceServer) StreamDatapoints(*StreamDatapointsRequest, DatapointsService_StreamDatapointsServer) error

type UnimplementedMetadataServiceServer 

type UnimplementedMetadataServiceServer struct {
}

UnimplementedMetadataServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetadataServiceServer) GetDatastream 

func (UnimplementedMetadataServiceServer) GetDatastream(context.Context, *GetDatastreamRequest) (*GetDatastreamResponse, error)

func (UnimplementedMetadataServiceServer) ListUoms 

func (UnimplementedMetadataServiceServer) ListUoms(context.Context, *emptypb.Empty) (*ListUomsResponse, error)

type UnimplementedProviderServiceServer 

type UnimplementedProviderServiceServer struct {
}

UnimplementedProviderServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProviderServiceServer) StreamDatapoints 

func (UnimplementedProviderServiceServer) StreamDatapoints(*ProviderStreamDatapointsRequest, ProviderService_StreamDatapointsServer) error

type UnimplementedTransformerServiceServer 

type UnimplementedTransformerServiceServer struct {
}

UnimplementedTransformerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTransformerServiceServer) TransformMany 

func (UnimplementedTransformerServiceServer) TransformMany(context.Context, *TransformManyRequest) (*TransformManyResponse, error)

type UnsafeConverterServiceServer 

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

UnsafeConverterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConverterServiceServer will result in compilation errors.

type UnsafeDatapointsServiceServer 

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

UnsafeDatapointsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatapointsServiceServer will result in compilation errors.

type UnsafeMetadataServiceServer 

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

UnsafeMetadataServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetadataServiceServer will result in compilation errors.

type UnsafeProviderServiceServer 

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

UnsafeProviderServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProviderServiceServer will result in compilation errors.

type UnsafeTransformerServiceServer 

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

UnsafeTransformerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TransformerServiceServer will result in compilation errors.

type Uom 

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
}

A quantity used as a standard of measurement.

func (*Uom) Descriptor deprecated 

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

Deprecated: Use Uom.ProtoReflect.Descriptor instead.

func (*Uom) GetConvertibleToUomIds 

func (x *Uom) GetConvertibleToUomIds() []string

func (*Uom) GetLibraryConfig 

func (x *Uom) GetLibraryConfig() *structpb.Struct

func (*Uom) GetSomId 

func (x *Uom) GetSomId() string

func (*Uom) GetUnitTags 

func (x *Uom) GetUnitTags() []string

func (*Uom) GetVersionId 

func (x *Uom) GetVersionId() string

func (*Uom) GetXId 

func (x *Uom) GetXId() string

func (*Uom) ProtoMessage 

func (*Uom) ProtoMessage()

func (*Uom) ProtoReflect 

func (x *Uom) ProtoReflect() protoreflect.Message

func (*Uom) Reset 

func (x *Uom) Reset()

func (*Uom) String 

func (x *Uom) String() string

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.