datav1

package
v0.0.0-...-5df0856 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2024 License: MIT Imports: 28 Imported by: 0

Documentation

Overview

Package datav1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var DataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sift.data.v1.DataService",
	HandlerType: (*DataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetData",
			Handler:    _DataService_GetData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sift/data/v1/data.proto",
}

DataService_ServiceDesc is the grpc.ServiceDesc for DataService 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_sift_data_v1_data_proto protoreflect.FileDescriptor

Functions

func RegisterDataServiceHandler 

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

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

func RegisterDataServiceHandlerClient 

func RegisterDataServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DataServiceClient) error

RegisterDataServiceHandlerClient registers the http handlers for service DataService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DataServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DataServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DataServiceClient" to call the correct interceptors.

func RegisterDataServiceHandlerFromEndpoint 

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

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

func RegisterDataServiceHandlerServer 

func RegisterDataServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DataServiceServer) error

RegisterDataServiceHandlerServer registers the http handlers for service DataService to "mux". UnaryRPC :call DataServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDataServiceHandlerFromEndpoint instead.

func RegisterDataServiceServer 

func RegisterDataServiceServer(s grpc.ServiceRegistrar, srv DataServiceServer)

Types

type BitFieldElementValues 

type BitFieldElementValues struct {
	Name   string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Values []*BitFieldValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*BitFieldElementValues) CloneMessageVT 

func (m *BitFieldElementValues) CloneMessageVT() proto.Message

func (*BitFieldElementValues) CloneVT 

func (m *BitFieldElementValues) CloneVT() *BitFieldElementValues

func (*BitFieldElementValues) Descriptor deprecated 

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

Deprecated: Use BitFieldElementValues.ProtoReflect.Descriptor instead.

func (*BitFieldElementValues) EqualMessageVT 

func (this *BitFieldElementValues) EqualMessageVT(thatMsg proto.Message) bool

func (*BitFieldElementValues) EqualVT 

func (this *BitFieldElementValues) EqualVT(that *BitFieldElementValues) bool

func (*BitFieldElementValues) GetName 

func (x *BitFieldElementValues) GetName() string

func (*BitFieldElementValues) GetValues 

func (x *BitFieldElementValues) GetValues() []*BitFieldValue

func (*BitFieldElementValues) MarshalToSizedBufferVT 

func (m *BitFieldElementValues) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BitFieldElementValues) MarshalToSizedBufferVTStrict 

func (m *BitFieldElementValues) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*BitFieldElementValues) MarshalToVT 

func (m *BitFieldElementValues) MarshalToVT(dAtA []byte) (int, error)

func (*BitFieldElementValues) MarshalToVTStrict 

func (m *BitFieldElementValues) MarshalToVTStrict(dAtA []byte) (int, error)

func (*BitFieldElementValues) MarshalVT 

func (m *BitFieldElementValues) MarshalVT() (dAtA []byte, err error)

func (*BitFieldElementValues) MarshalVTStrict 

func (m *BitFieldElementValues) MarshalVTStrict() (dAtA []byte, err error)

func (*BitFieldElementValues) ProtoMessage 

func (*BitFieldElementValues) ProtoMessage()

func (*BitFieldElementValues) ProtoReflect 

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

func (*BitFieldElementValues) Reset 

func (x *BitFieldElementValues) Reset()

func (*BitFieldElementValues) SizeVT 

func (m *BitFieldElementValues) SizeVT() (n int)

func (*BitFieldElementValues) String 

func (x *BitFieldElementValues) String() string

func (*BitFieldElementValues) UnmarshalVT 

func (m *BitFieldElementValues) UnmarshalVT(dAtA []byte) error

func (*BitFieldElementValues) UnmarshalVTUnsafe 

func (m *BitFieldElementValues) UnmarshalVTUnsafe(dAtA []byte) error

type BitFieldValue 

type BitFieldValue struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     uint32                 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BitFieldValue) CloneMessageVT 

func (m *BitFieldValue) CloneMessageVT() proto.Message

func (*BitFieldValue) CloneVT 

func (m *BitFieldValue) CloneVT() *BitFieldValue

func (*BitFieldValue) Descriptor deprecated 

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

Deprecated: Use BitFieldValue.ProtoReflect.Descriptor instead.

func (*BitFieldValue) EqualMessageVT 

func (this *BitFieldValue) EqualMessageVT(thatMsg proto.Message) bool

func (*BitFieldValue) EqualVT 

func (this *BitFieldValue) EqualVT(that *BitFieldValue) bool

func (*BitFieldValue) GetTimestamp 

func (x *BitFieldValue) GetTimestamp() *timestamppb.Timestamp

func (*BitFieldValue) GetValue 

func (x *BitFieldValue) GetValue() uint32

func (*BitFieldValue) MarshalToSizedBufferVT 

func (m *BitFieldValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BitFieldValue) MarshalToSizedBufferVTStrict 

func (m *BitFieldValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*BitFieldValue) MarshalToVT 

func (m *BitFieldValue) MarshalToVT(dAtA []byte) (int, error)

func (*BitFieldValue) MarshalToVTStrict 

func (m *BitFieldValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*BitFieldValue) MarshalVT 

func (m *BitFieldValue) MarshalVT() (dAtA []byte, err error)

func (*BitFieldValue) MarshalVTStrict 

func (m *BitFieldValue) MarshalVTStrict() (dAtA []byte, err error)

func (*BitFieldValue) ProtoMessage 

func (*BitFieldValue) ProtoMessage()

func (*BitFieldValue) ProtoReflect 

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

func (*BitFieldValue) Reset 

func (x *BitFieldValue) Reset()

func (*BitFieldValue) SizeVT 

func (m *BitFieldValue) SizeVT() (n int)

func (*BitFieldValue) String 

func (x *BitFieldValue) String() string

func (*BitFieldValue) UnmarshalVT 

func (m *BitFieldValue) UnmarshalVT(dAtA []byte) error

func (*BitFieldValue) UnmarshalVTUnsafe 

func (m *BitFieldValue) UnmarshalVTUnsafe(dAtA []byte) error

type BitFieldValues 

type BitFieldValues struct {
	Metadata *Metadata                `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*BitFieldElementValues `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*BitFieldValues) CloneMessageVT 

func (m *BitFieldValues) CloneMessageVT() proto.Message

func (*BitFieldValues) CloneVT 

func (m *BitFieldValues) CloneVT() *BitFieldValues

func (*BitFieldValues) Descriptor deprecated 

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

Deprecated: Use BitFieldValues.ProtoReflect.Descriptor instead.

func (*BitFieldValues) EqualMessageVT 

func (this *BitFieldValues) EqualMessageVT(thatMsg proto.Message) bool

func (*BitFieldValues) EqualVT 

func (this *BitFieldValues) EqualVT(that *BitFieldValues) bool

func (*BitFieldValues) GetMetadata 

func (x *BitFieldValues) GetMetadata() *Metadata

func (*BitFieldValues) GetValues 

func (x *BitFieldValues) GetValues() []*BitFieldElementValues

func (*BitFieldValues) MarshalToSizedBufferVT 

func (m *BitFieldValues) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BitFieldValues) MarshalToSizedBufferVTStrict 

func (m *BitFieldValues) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*BitFieldValues) MarshalToVT 

func (m *BitFieldValues) MarshalToVT(dAtA []byte) (int, error)

func (*BitFieldValues) MarshalToVTStrict 

func (m *BitFieldValues) MarshalToVTStrict(dAtA []byte) (int, error)

func (*BitFieldValues) MarshalVT 

func (m *BitFieldValues) MarshalVT() (dAtA []byte, err error)

func (*BitFieldValues) MarshalVTStrict 

func (m *BitFieldValues) MarshalVTStrict() (dAtA []byte, err error)

func (*BitFieldValues) ProtoMessage 

func (*BitFieldValues) ProtoMessage()

func (*BitFieldValues) ProtoReflect 

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

func (*BitFieldValues) Reset 

func (x *BitFieldValues) Reset()

func (*BitFieldValues) SizeVT 

func (m *BitFieldValues) SizeVT() (n int)

func (*BitFieldValues) String 

func (x *BitFieldValues) String() string

func (*BitFieldValues) UnmarshalVT 

func (m *BitFieldValues) UnmarshalVT(dAtA []byte) error

func (*BitFieldValues) UnmarshalVTUnsafe 

func (m *BitFieldValues) UnmarshalVTUnsafe(dAtA []byte) error

type BoolValue 

type BoolValue struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     bool                   `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolValue) CloneMessageVT 

func (m *BoolValue) CloneMessageVT() proto.Message

func (*BoolValue) CloneVT 

func (m *BoolValue) CloneVT() *BoolValue

func (*BoolValue) Descriptor deprecated 

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

Deprecated: Use BoolValue.ProtoReflect.Descriptor instead.

func (*BoolValue) EqualMessageVT 

func (this *BoolValue) EqualMessageVT(thatMsg proto.Message) bool

func (*BoolValue) EqualVT 

func (this *BoolValue) EqualVT(that *BoolValue) bool

func (*BoolValue) GetTimestamp 

func (x *BoolValue) GetTimestamp() *timestamppb.Timestamp

func (*BoolValue) GetValue 

func (x *BoolValue) GetValue() bool

func (*BoolValue) MarshalToSizedBufferVT 

func (m *BoolValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BoolValue) MarshalToSizedBufferVTStrict 

func (m *BoolValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*BoolValue) MarshalToVT 

func (m *BoolValue) MarshalToVT(dAtA []byte) (int, error)

func (*BoolValue) MarshalToVTStrict 

func (m *BoolValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*BoolValue) MarshalVT 

func (m *BoolValue) MarshalVT() (dAtA []byte, err error)

func (*BoolValue) MarshalVTStrict 

func (m *BoolValue) MarshalVTStrict() (dAtA []byte, err error)

func (*BoolValue) ProtoMessage 

func (*BoolValue) ProtoMessage()

func (*BoolValue) ProtoReflect 

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

func (*BoolValue) Reset 

func (x *BoolValue) Reset()

func (*BoolValue) SizeVT 

func (m *BoolValue) SizeVT() (n int)

func (*BoolValue) String 

func (x *BoolValue) String() string

func (*BoolValue) UnmarshalVT 

func (m *BoolValue) UnmarshalVT(dAtA []byte) error

func (*BoolValue) UnmarshalVTUnsafe 

func (m *BoolValue) UnmarshalVTUnsafe(dAtA []byte) error

type BoolValues 

type BoolValues struct {
	Metadata *Metadata    `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*BoolValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolValues) CloneMessageVT 

func (m *BoolValues) CloneMessageVT() proto.Message

func (*BoolValues) CloneVT 

func (m *BoolValues) CloneVT() *BoolValues

func (*BoolValues) Descriptor deprecated 

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

Deprecated: Use BoolValues.ProtoReflect.Descriptor instead.

func (*BoolValues) EqualMessageVT 

func (this *BoolValues) EqualMessageVT(thatMsg proto.Message) bool

func (*BoolValues) EqualVT 

func (this *BoolValues) EqualVT(that *BoolValues) bool

func (*BoolValues) GetMetadata 

func (x *BoolValues) GetMetadata() *Metadata

func (*BoolValues) GetValues 

func (x *BoolValues) GetValues() []*BoolValue

func (*BoolValues) MarshalToSizedBufferVT 

func (m *BoolValues) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BoolValues) MarshalToSizedBufferVTStrict 

func (m *BoolValues) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*BoolValues) MarshalToVT 

func (m *BoolValues) MarshalToVT(dAtA []byte) (int, error)

func (*BoolValues) MarshalToVTStrict 

func (m *BoolValues) MarshalToVTStrict(dAtA []byte) (int, error)

func (*BoolValues) MarshalVT 

func (m *BoolValues) MarshalVT() (dAtA []byte, err error)

func (*BoolValues) MarshalVTStrict 

func (m *BoolValues) MarshalVTStrict() (dAtA []byte, err error)

func (*BoolValues) ProtoMessage 

func (*BoolValues) ProtoMessage()

func (*BoolValues) ProtoReflect 

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

func (*BoolValues) Reset 

func (x *BoolValues) Reset()

func (*BoolValues) SizeVT 

func (m *BoolValues) SizeVT() (n int)

func (*BoolValues) String 

func (x *BoolValues) String() string

func (*BoolValues) UnmarshalVT 

func (m *BoolValues) UnmarshalVT(dAtA []byte) error

func (*BoolValues) UnmarshalVTUnsafe 

func (m *BoolValues) UnmarshalVTUnsafe(dAtA []byte) error

type CalculatedChannelQuery 

type CalculatedChannelQuery struct {
	ChannelKey string                `protobuf:"bytes,1,opt,name=channel_key,json=channelKey,proto3" json:"channel_key,omitempty"`
	Expression *v1.ExpressionRequest `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// Optional.
	// If set, only data for the specified run is returned
	// If set to the empty string, only non-run data is returned.
	// If unset, all run / non-run data is returned.
	RunId *string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3,oneof" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CalculatedChannelQuery) CloneMessageVT 

func (m *CalculatedChannelQuery) CloneMessageVT() proto.Message

func (*CalculatedChannelQuery) CloneVT 

func (m *CalculatedChannelQuery) CloneVT() *CalculatedChannelQuery

func (*CalculatedChannelQuery) Descriptor deprecated 

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

Deprecated: Use CalculatedChannelQuery.ProtoReflect.Descriptor instead.

func (*CalculatedChannelQuery) EqualMessageVT 

func (this *CalculatedChannelQuery) EqualMessageVT(thatMsg proto.Message) bool

func (*CalculatedChannelQuery) EqualVT 

func (this *CalculatedChannelQuery) EqualVT(that *CalculatedChannelQuery) bool

func (*CalculatedChannelQuery) GetChannelKey 

func (x *CalculatedChannelQuery) GetChannelKey() string

func (*CalculatedChannelQuery) GetExpression 

func (x *CalculatedChannelQuery) GetExpression() *v1.ExpressionRequest

func (*CalculatedChannelQuery) GetRunId 

func (x *CalculatedChannelQuery) GetRunId() string

func (*CalculatedChannelQuery) MarshalToSizedBufferVT 

func (m *CalculatedChannelQuery) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CalculatedChannelQuery) MarshalToSizedBufferVTStrict 

func (m *CalculatedChannelQuery) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*CalculatedChannelQuery) MarshalToVT 

func (m *CalculatedChannelQuery) MarshalToVT(dAtA []byte) (int, error)

func (*CalculatedChannelQuery) MarshalToVTStrict 

func (m *CalculatedChannelQuery) MarshalToVTStrict(dAtA []byte) (int, error)

func (*CalculatedChannelQuery) MarshalVT 

func (m *CalculatedChannelQuery) MarshalVT() (dAtA []byte, err error)

func (*CalculatedChannelQuery) MarshalVTStrict 

func (m *CalculatedChannelQuery) MarshalVTStrict() (dAtA []byte, err error)

func (*CalculatedChannelQuery) ProtoMessage 

func (*CalculatedChannelQuery) ProtoMessage()

func (*CalculatedChannelQuery) ProtoReflect 

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

func (*CalculatedChannelQuery) Reset 

func (x *CalculatedChannelQuery) Reset()

func (*CalculatedChannelQuery) SizeVT 

func (m *CalculatedChannelQuery) SizeVT() (n int)

func (*CalculatedChannelQuery) String 

func (x *CalculatedChannelQuery) String() string

func (*CalculatedChannelQuery) UnmarshalVT 

func (m *CalculatedChannelQuery) UnmarshalVT(dAtA []byte) error

func (*CalculatedChannelQuery) UnmarshalVTUnsafe 

func (m *CalculatedChannelQuery) UnmarshalVTUnsafe(dAtA []byte) error

type ChannelQuery 

type ChannelQuery struct {
	ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// Optional.
	// If set, only data associated with the specified run is returned.
	// If set to the empty string, only non-run data is returned.
	// If unset, all run / non-run data is returned.
	RunId *string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3,oneof" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelQuery) CloneMessageVT 

func (m *ChannelQuery) CloneMessageVT() proto.Message

func (*ChannelQuery) CloneVT 

func (m *ChannelQuery) CloneVT() *ChannelQuery

func (*ChannelQuery) Descriptor deprecated 

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

Deprecated: Use ChannelQuery.ProtoReflect.Descriptor instead.

func (*ChannelQuery) EqualMessageVT 

func (this *ChannelQuery) EqualMessageVT(thatMsg proto.Message) bool

func (*ChannelQuery) EqualVT 

func (this *ChannelQuery) EqualVT(that *ChannelQuery) bool

func (*ChannelQuery) GetChannelId 

func (x *ChannelQuery) GetChannelId() string

func (*ChannelQuery) GetRunId 

func (x *ChannelQuery) GetRunId() string

func (*ChannelQuery) MarshalToSizedBufferVT 

func (m *ChannelQuery) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ChannelQuery) MarshalToSizedBufferVTStrict 

func (m *ChannelQuery) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*ChannelQuery) MarshalToVT 

func (m *ChannelQuery) MarshalToVT(dAtA []byte) (int, error)

func (*ChannelQuery) MarshalToVTStrict 

func (m *ChannelQuery) MarshalToVTStrict(dAtA []byte) (int, error)

func (*ChannelQuery) MarshalVT 

func (m *ChannelQuery) MarshalVT() (dAtA []byte, err error)

func (*ChannelQuery) MarshalVTStrict 

func (m *ChannelQuery) MarshalVTStrict() (dAtA []byte, err error)

func (*ChannelQuery) ProtoMessage 

func (*ChannelQuery) ProtoMessage()

func (*ChannelQuery) ProtoReflect 

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

func (*ChannelQuery) Reset 

func (x *ChannelQuery) Reset()

func (*ChannelQuery) SizeVT 

func (m *ChannelQuery) SizeVT() (n int)

func (*ChannelQuery) String 

func (x *ChannelQuery) String() string

func (*ChannelQuery) UnmarshalVT 

func (m *ChannelQuery) UnmarshalVT(dAtA []byte) error

func (*ChannelQuery) UnmarshalVTUnsafe 

func (m *ChannelQuery) UnmarshalVTUnsafe(dAtA []byte) error

type DataServiceClient 

type DataServiceClient interface {
	GetData(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (*GetDataResponse, error)
}

DataServiceClient is the client API for DataService 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 NewDataServiceClient 

func NewDataServiceClient(cc grpc.ClientConnInterface) DataServiceClient

type DataServiceServer 

type DataServiceServer interface {
	GetData(context.Context, *GetDataRequest) (*GetDataResponse, error)
	// contains filtered or unexported methods
}

DataServiceServer is the server API for DataService service. All implementations must embed UnimplementedDataServiceServer for forward compatibility

type DoubleValue 

type DoubleValue struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     float64                `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*DoubleValue) CloneMessageVT 

func (m *DoubleValue) CloneMessageVT() proto.Message

func (*DoubleValue) CloneVT 

func (m *DoubleValue) CloneVT() *DoubleValue

func (*DoubleValue) Descriptor deprecated 

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

Deprecated: Use DoubleValue.ProtoReflect.Descriptor instead.

func (*DoubleValue) EqualMessageVT 

func (this *DoubleValue) EqualMessageVT(thatMsg proto.Message) bool

func (*DoubleValue) EqualVT 

func (this *DoubleValue) EqualVT(that *DoubleValue) bool

func (*DoubleValue) GetTimestamp 

func (x *DoubleValue) GetTimestamp() *timestamppb.Timestamp

func (*DoubleValue) GetValue 

func (x *DoubleValue) GetValue() float64

func (*DoubleValue) MarshalToSizedBufferVT 

func (m *DoubleValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DoubleValue) MarshalToSizedBufferVTStrict 

func (m *DoubleValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*DoubleValue) MarshalToVT 

func (m *DoubleValue) MarshalToVT(dAtA []byte) (int, error)

func (*DoubleValue) MarshalToVTStrict 

func (m *DoubleValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*DoubleValue) MarshalVT 

func (m *DoubleValue) MarshalVT() (dAtA []byte, err error)

func (*DoubleValue) MarshalVTStrict 

func (m *DoubleValue) MarshalVTStrict() (dAtA []byte, err error)

func (*DoubleValue) ProtoMessage 

func (*DoubleValue) ProtoMessage()

func (*DoubleValue) ProtoReflect 

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

func (*DoubleValue) Reset 

func (x *DoubleValue) Reset()

func (*DoubleValue) SizeVT 

func (m *DoubleValue) SizeVT() (n int)

func (*DoubleValue) String 

func (x *DoubleValue) String() string

func (*DoubleValue) UnmarshalVT 

func (m *DoubleValue) UnmarshalVT(dAtA []byte) error

func (*DoubleValue) UnmarshalVTUnsafe 

func (m *DoubleValue) UnmarshalVTUnsafe(dAtA []byte) error

type DoubleValues 

type DoubleValues struct {
	Metadata *Metadata      `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*DoubleValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*DoubleValues) CloneMessageVT 

func (m *DoubleValues) CloneMessageVT() proto.Message

func (*DoubleValues) CloneVT 

func (m *DoubleValues) CloneVT() *DoubleValues

func (*DoubleValues) Descriptor deprecated 

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

Deprecated: Use DoubleValues.ProtoReflect.Descriptor instead.

func (*DoubleValues) EqualMessageVT 

func (this *DoubleValues) EqualMessageVT(thatMsg proto.Message) bool

func (*DoubleValues) EqualVT 

func (this *DoubleValues) EqualVT(that *DoubleValues) bool

func (*DoubleValues) GetMetadata 

func (x *DoubleValues) GetMetadata() *Metadata

func (*DoubleValues) GetValues 

func (x *DoubleValues) GetValues() []*DoubleValue

func (*DoubleValues) MarshalToSizedBufferVT 

func (m *DoubleValues) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DoubleValues) MarshalToSizedBufferVTStrict 

func (m *DoubleValues) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*DoubleValues) MarshalToVT 

func (m *DoubleValues) MarshalToVT(dAtA []byte) (int, error)

func (*DoubleValues) MarshalToVTStrict 

func (m *DoubleValues) MarshalToVTStrict(dAtA []byte) (int, error)

func (*DoubleValues) MarshalVT 

func (m *DoubleValues) MarshalVT() (dAtA []byte, err error)

func (*DoubleValues) MarshalVTStrict 

func (m *DoubleValues) MarshalVTStrict() (dAtA []byte, err error)

func (*DoubleValues) ProtoMessage 

func (*DoubleValues) ProtoMessage()

func (*DoubleValues) ProtoReflect 

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

func (*DoubleValues) Reset 

func (x *DoubleValues) Reset()

func (*DoubleValues) SizeVT 

func (m *DoubleValues) SizeVT() (n int)

func (*DoubleValues) String 

func (x *DoubleValues) String() string

func (*DoubleValues) UnmarshalVT 

func (m *DoubleValues) UnmarshalVT(dAtA []byte) error

func (*DoubleValues) UnmarshalVTUnsafe 

func (m *DoubleValues) UnmarshalVTUnsafe(dAtA []byte) error

type EnumValue 

type EnumValue struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     uint32                 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*EnumValue) CloneMessageVT 

func (m *EnumValue) CloneMessageVT() proto.Message

func (*EnumValue) CloneVT 

func (m *EnumValue) CloneVT() *EnumValue

func (*EnumValue) Descriptor deprecated 

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

Deprecated: Use EnumValue.ProtoReflect.Descriptor instead.

func (*EnumValue) EqualMessageVT 

func (this *EnumValue) EqualMessageVT(thatMsg proto.Message) bool

func (*EnumValue) EqualVT 

func (this *EnumValue) EqualVT(that *EnumValue) bool

func (*EnumValue) GetTimestamp 

func (x *EnumValue) GetTimestamp() *timestamppb.Timestamp

func (*EnumValue) GetValue 

func (x *EnumValue) GetValue() uint32

func (*EnumValue) MarshalToSizedBufferVT 

func (m *EnumValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnumValue) MarshalToSizedBufferVTStrict 

func (m *EnumValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*EnumValue) MarshalToVT 

func (m *EnumValue) MarshalToVT(dAtA []byte) (int, error)

func (*EnumValue) MarshalToVTStrict 

func (m *EnumValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*EnumValue) MarshalVT 

func (m *EnumValue) MarshalVT() (dAtA []byte, err error)

func (*EnumValue) MarshalVTStrict 

func (m *EnumValue) MarshalVTStrict() (dAtA []byte, err error)

func (*EnumValue) ProtoMessage 

func (*EnumValue) ProtoMessage()

func (*EnumValue) ProtoReflect 

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

func (*EnumValue) Reset 

func (x *EnumValue) Reset()

func (*EnumValue) SizeVT 

func (m *EnumValue) SizeVT() (n int)

func (*EnumValue) String 

func (x *EnumValue) String() string

func (*EnumValue) UnmarshalVT 

func (m *EnumValue) UnmarshalVT(dAtA []byte) error

func (*EnumValue) UnmarshalVTUnsafe 

func (m *EnumValue) UnmarshalVTUnsafe(dAtA []byte) error

type EnumValues 

type EnumValues struct {
	Metadata *Metadata    `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*EnumValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*EnumValues) CloneMessageVT 

func (m *EnumValues) CloneMessageVT() proto.Message

func (*EnumValues) CloneVT 

func (m *EnumValues) CloneVT() *EnumValues

func (*EnumValues) Descriptor deprecated 

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

Deprecated: Use EnumValues.ProtoReflect.Descriptor instead.

func (*EnumValues) EqualMessageVT 

func (this *EnumValues) EqualMessageVT(thatMsg proto.Message) bool

func (*EnumValues) EqualVT 

func (this *EnumValues) EqualVT(that *EnumValues) bool

func (*EnumValues) GetMetadata 

func (x *EnumValues) GetMetadata() *Metadata

func (*EnumValues) GetValues 

func (x *EnumValues) GetValues() []*EnumValue

func (*EnumValues) MarshalToSizedBufferVT 

func (m *EnumValues) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnumValues) MarshalToSizedBufferVTStrict 

func (m *EnumValues) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*EnumValues) MarshalToVT 

func (m *EnumValues) MarshalToVT(dAtA []byte) (int, error)

func (*EnumValues) MarshalToVTStrict 

func (m *EnumValues) MarshalToVTStrict(dAtA []byte) (int, error)

func (*EnumValues) MarshalVT 

func (m *EnumValues) MarshalVT() (dAtA []byte, err error)

func (*EnumValues) MarshalVTStrict 

func (m *EnumValues) MarshalVTStrict() (dAtA []byte, err error)

func (*EnumValues) ProtoMessage 

func (*EnumValues) ProtoMessage()

func (*EnumValues) ProtoReflect 

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

func (*EnumValues) Reset 

func (x *EnumValues) Reset()

func (*EnumValues) SizeVT 

func (m *EnumValues) SizeVT() (n int)

func (*EnumValues) String 

func (x *EnumValues) String() string

func (*EnumValues) UnmarshalVT 

func (m *EnumValues) UnmarshalVT(dAtA []byte) error

func (*EnumValues) UnmarshalVTUnsafe 

func (m *EnumValues) UnmarshalVTUnsafe(dAtA []byte) error

type FloatValue 

type FloatValue struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     float32                `protobuf:"fixed32,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*FloatValue) CloneMessageVT 

func (m *FloatValue) CloneMessageVT() proto.Message

func (*FloatValue) CloneVT 

func (m *FloatValue) CloneVT() *FloatValue

func (*FloatValue) Descriptor deprecated 

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

Deprecated: Use FloatValue.ProtoReflect.Descriptor instead.

func (*FloatValue) EqualMessageVT 

func (this *FloatValue) EqualMessageVT(thatMsg proto.Message) bool

func (*FloatValue) EqualVT 

func (this *FloatValue) EqualVT(that *FloatValue) bool

func (*FloatValue) GetTimestamp 

func (x *FloatValue) GetTimestamp() *timestamppb.Timestamp

func (*FloatValue) GetValue 

func (x *FloatValue) GetValue() float32

func (*FloatValue) MarshalToSizedBufferVT 

func (m *FloatValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FloatValue) MarshalToSizedBufferVTStrict 

func (m *FloatValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FloatValue) MarshalToVT 

func (m *FloatValue) MarshalToVT(dAtA []byte) (int, error)

func (*FloatValue) MarshalToVTStrict 

func (m *FloatValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FloatValue) MarshalVT 

func (m *FloatValue) MarshalVT() (dAtA []byte, err error)

func (*FloatValue) MarshalVTStrict 

func (m *FloatValue) MarshalVTStrict() (dAtA []byte, err error)

func (*FloatValue) ProtoMessage 

func (*FloatValue) ProtoMessage()

func (*FloatValue) ProtoReflect 

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

func (*FloatValue) Reset 

func (x *FloatValue) Reset()

func (*FloatValue) SizeVT 

func (m *FloatValue) SizeVT() (n int)

func (*FloatValue) String 

func (x *FloatValue) String() string

func (*FloatValue) UnmarshalVT 

func (m *FloatValue) UnmarshalVT(dAtA []byte) error

func (*FloatValue) UnmarshalVTUnsafe 

func (m *FloatValue) UnmarshalVTUnsafe(dAtA []byte) error

type FloatValues 

type FloatValues struct {
	Metadata *Metadata     `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*FloatValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*FloatValues) CloneMessageVT 

func (m *FloatValues) CloneMessageVT() proto.Message

func (*FloatValues) CloneVT 

func (m *FloatValues) CloneVT() *FloatValues

func (*FloatValues) Descriptor deprecated 

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

Deprecated: Use FloatValues.ProtoReflect.Descriptor instead.

func (*FloatValues) EqualMessageVT 

func (this *FloatValues) EqualMessageVT(thatMsg proto.Message) bool

func (*FloatValues) EqualVT 

func (this *FloatValues) EqualVT(that *FloatValues) bool

func (*FloatValues) GetMetadata 

func (x *FloatValues) GetMetadata() *Metadata

func (*FloatValues) GetValues 

func (x *FloatValues) GetValues() []*FloatValue

func (*FloatValues) MarshalToSizedBufferVT 

func (m *FloatValues) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FloatValues) MarshalToSizedBufferVTStrict 

func (m *FloatValues) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*FloatValues) MarshalToVT 

func (m *FloatValues) MarshalToVT(dAtA []byte) (int, error)

func (*FloatValues) MarshalToVTStrict 

func (m *FloatValues) MarshalToVTStrict(dAtA []byte) (int, error)

func (*FloatValues) MarshalVT 

func (m *FloatValues) MarshalVT() (dAtA []byte, err error)

func (*FloatValues) MarshalVTStrict 

func (m *FloatValues) MarshalVTStrict() (dAtA []byte, err error)

func (*FloatValues) ProtoMessage 

func (*FloatValues) ProtoMessage()

func (*FloatValues) ProtoReflect 

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

func (*FloatValues) Reset 

func (x *FloatValues) Reset()

func (*FloatValues) SizeVT 

func (m *FloatValues) SizeVT() (n int)

func (*FloatValues) String 

func (x *FloatValues) String() string

func (*FloatValues) UnmarshalVT 

func (m *FloatValues) UnmarshalVT(dAtA []byte) error

func (*FloatValues) UnmarshalVTUnsafe 

func (m *FloatValues) UnmarshalVTUnsafe(dAtA []byte) error

type GetDataRequest 

type GetDataRequest struct {
	Queries []*Query `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	// Required. The starting timestamp of the data to retrieve. This is an inclusive bound.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Required. The end timestamp of the data to retrieve. This is an exclusive bound.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// The rate to sample the returned data at. The data is sampled using LTTB (https://github.com/sveinn-steinarsson/flot-downsample)
	// which will return one point approximately every sample_ms milliseconds that retains the shape of the raw data.
	//
	// Sampling is only supported for numeric data types, if sample_ms is provided for non-numeric data, it will be
	// ignored and the full-fidelity data will be returned.
	SampleMs uint32 `protobuf:"varint,4,opt,name=sample_ms,json=sampleMs,proto3" json:"sample_ms,omitempty"`
	// The maximum number of channel values to return.
	// The service may return fewer than this value.
	// If unspecified, at most 10,000 values will be returned.
	// The maximum value is 100,000; values above 100,000 will be coerced to 100,000.
	//
	// For variable data types (i.e. string channels), at most page_size elements
	// will be read, or 1MB, whichever occurs first.
	PageSize uint32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `GetData` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `GetData` must match
	// the call that provided the page token.
	PageToken string `protobuf:"bytes,6,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataRequest) CloneMessageVT 

func (m *GetDataRequest) CloneMessageVT() proto.Message

func (*GetDataRequest) CloneVT 

func (m *GetDataRequest) CloneVT() *GetDataRequest

func (*GetDataRequest) Descriptor deprecated 

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

Deprecated: Use GetDataRequest.ProtoReflect.Descriptor instead.

func (*GetDataRequest) EqualMessageVT 

func (this *GetDataRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*GetDataRequest) EqualVT 

func (this *GetDataRequest) EqualVT(that *GetDataRequest) bool

func (*GetDataRequest) GetEndTime 

func (x *GetDataRequest) GetEndTime() *timestamppb.Timestamp

func (*GetDataRequest) GetPageSize 

func (x *GetDataRequest) GetPageSize() uint32

func (*GetDataRequest) GetPageToken 

func (x *GetDataRequest) GetPageToken() string

func (*GetDataRequest) GetQueries 

func (x *GetDataRequest) GetQueries() []*Query

func (*GetDataRequest) GetSampleMs 

func (x *GetDataRequest) GetSampleMs() uint32

func (*GetDataRequest) GetStartTime 

func (x *GetDataRequest) GetStartTime() *timestamppb.Timestamp

func (*GetDataRequest) MarshalToSizedBufferVT 

func (m *GetDataRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetDataRequest) MarshalToSizedBufferVTStrict 

func (m *GetDataRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*GetDataRequest) MarshalToVT 

func (m *GetDataRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetDataRequest) MarshalToVTStrict 

func (m *GetDataRequest) MarshalToVTStrict(dAtA []byte) (int, error)

func (*GetDataRequest) MarshalVT 

func (m *GetDataRequest) MarshalVT() (dAtA []byte, err error)

func (*GetDataRequest) MarshalVTStrict 

func (m *GetDataRequest) MarshalVTStrict() (dAtA []byte, err error)

func (*GetDataRequest) ProtoMessage 

func (*GetDataRequest) ProtoMessage()

func (*GetDataRequest) ProtoReflect 

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

func (*GetDataRequest) Reset 

func (x *GetDataRequest) Reset()

func (*GetDataRequest) SizeVT 

func (m *GetDataRequest) SizeVT() (n int)

func (*GetDataRequest) String 

func (x *GetDataRequest) String() string

func (*GetDataRequest) UnmarshalVT 

func (m *GetDataRequest) UnmarshalVT(dAtA []byte) error

func (*GetDataRequest) UnmarshalVTUnsafe 

func (m *GetDataRequest) UnmarshalVTUnsafe(dAtA []byte) error

type GetDataResponse 

type GetDataResponse struct {
	NextPageToken string `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// data contains the result of the supplied queries.
	// Be aware that each query can generate multiple data responses.
	// For example, if run_id is omitted from a ChannelQuery, the query returns
	// data for all runs containing that channel. Channel data for each run is
	// returned in a separate data object.
	//
	// Possible message types:
	//
	//	sift.data.v1.DoubleValues
	//	sift.data.v1.FloatValues
	//	sift.data.v1.StringValues
	//	sift.data.v1.EnumValues
	//	sift.data.v1.BitFieldValues
	//	sift.data.v1.BoolValues
	//	sift.data.v1.Int32Values
	//	sift.data.v1.Int64Values
	//	sift.data.v1.Uint32Values
	//	sift.data.v1.Uint64Values
	Data []*anypb.Any `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataResponse) CloneMessageVT 

func (m *GetDataResponse) CloneMessageVT() proto.Message

func (*GetDataResponse) CloneVT 

func (m *GetDataResponse) CloneVT() *GetDataResponse

func (*GetDataResponse) Descriptor deprecated 

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

Deprecated: Use GetDataResponse.ProtoReflect.Descriptor instead.

func (*GetDataResponse) EqualMessageVT 

func (this *GetDataResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*GetDataResponse) EqualVT 

func (this *GetDataResponse) EqualVT(that *GetDataResponse) bool

func (*GetDataResponse) GetData 

func (x *GetDataResponse) GetData() []*anypb.Any

func (*GetDataResponse) GetNextPageToken 

func (x *GetDataResponse) GetNextPageToken() string

func (*GetDataResponse) MarshalToSizedBufferVT 

func (m *GetDataResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetDataResponse) MarshalToSizedBufferVTStrict 

func (m *GetDataResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*GetDataResponse) MarshalToVT 

func (m *GetDataResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetDataResponse) MarshalToVTStrict 

func (m *GetDataResponse) MarshalToVTStrict(dAtA []byte) (int, error)

func (*GetDataResponse) MarshalVT 

func (m *GetDataResponse) MarshalVT() (dAtA []byte, err error)

func (*GetDataResponse) MarshalVTStrict 

func (m *GetDataResponse) MarshalVTStrict() (dAtA []byte, err error)

func (*GetDataResponse) ProtoMessage 

func (*GetDataResponse) ProtoMessage()

func (*GetDataResponse) ProtoReflect 

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

func (*GetDataResponse) Reset 

func (x *GetDataResponse) Reset()

func (*GetDataResponse) SizeVT 

func (m *GetDataResponse) SizeVT() (n int)

func (*GetDataResponse) String 

func (x *GetDataResponse) String() string

func (*GetDataResponse) UnmarshalVT 

func (m *GetDataResponse) UnmarshalVT(dAtA []byte) error

func (*GetDataResponse) UnmarshalVTUnsafe 

func (m *GetDataResponse) UnmarshalVTUnsafe(dAtA []byte) error

type Int32Value 

type Int32Value struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     int32                  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Int32Value) CloneMessageVT 

func (m *Int32Value) CloneMessageVT() proto.Message

func (*Int32Value) CloneVT 

func (m *Int32Value) CloneVT() *Int32Value

func (*Int32Value) Descriptor deprecated 

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

Deprecated: Use Int32Value.ProtoReflect.Descriptor instead.

func (*Int32Value) EqualMessageVT 

func (this *Int32Value) EqualMessageVT(thatMsg proto.Message) bool

func (*Int32Value) EqualVT 

func (this *Int32Value) EqualVT(that *Int32Value) bool

func (*Int32Value) GetTimestamp 

func (x *Int32Value) GetTimestamp() *timestamppb.Timestamp

func (*Int32Value) GetValue 

func (x *Int32Value) GetValue() int32

func (*Int32Value) MarshalToSizedBufferVT 

func (m *Int32Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Int32Value) MarshalToSizedBufferVTStrict 

func (m *Int32Value) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Int32Value) MarshalToVT 

func (m *Int32Value) MarshalToVT(dAtA []byte) (int, error)

func (*Int32Value) MarshalToVTStrict 

func (m *Int32Value) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Int32Value) MarshalVT 

func (m *Int32Value) MarshalVT() (dAtA []byte, err error)

func (*Int32Value) MarshalVTStrict 

func (m *Int32Value) MarshalVTStrict() (dAtA []byte, err error)

func (*Int32Value) ProtoMessage 

func (*Int32Value) ProtoMessage()

func (*Int32Value) ProtoReflect 

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

func (*Int32Value) Reset 

func (x *Int32Value) Reset()

func (*Int32Value) SizeVT 

func (m *Int32Value) SizeVT() (n int)

func (*Int32Value) String 

func (x *Int32Value) String() string

func (*Int32Value) UnmarshalVT 

func (m *Int32Value) UnmarshalVT(dAtA []byte) error

func (*Int32Value) UnmarshalVTUnsafe 

func (m *Int32Value) UnmarshalVTUnsafe(dAtA []byte) error

type Int32Values 

type Int32Values struct {
	Metadata *Metadata     `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*Int32Value `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Int32Values) CloneMessageVT 

func (m *Int32Values) CloneMessageVT() proto.Message

func (*Int32Values) CloneVT 

func (m *Int32Values) CloneVT() *Int32Values

func (*Int32Values) Descriptor deprecated 

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

Deprecated: Use Int32Values.ProtoReflect.Descriptor instead.

func (*Int32Values) EqualMessageVT 

func (this *Int32Values) EqualMessageVT(thatMsg proto.Message) bool

func (*Int32Values) EqualVT 

func (this *Int32Values) EqualVT(that *Int32Values) bool

func (*Int32Values) GetMetadata 

func (x *Int32Values) GetMetadata() *Metadata

func (*Int32Values) GetValues 

func (x *Int32Values) GetValues() []*Int32Value

func (*Int32Values) MarshalToSizedBufferVT 

func (m *Int32Values) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Int32Values) MarshalToSizedBufferVTStrict 

func (m *Int32Values) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Int32Values) MarshalToVT 

func (m *Int32Values) MarshalToVT(dAtA []byte) (int, error)

func (*Int32Values) MarshalToVTStrict 

func (m *Int32Values) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Int32Values) MarshalVT 

func (m *Int32Values) MarshalVT() (dAtA []byte, err error)

func (*Int32Values) MarshalVTStrict 

func (m *Int32Values) MarshalVTStrict() (dAtA []byte, err error)

func (*Int32Values) ProtoMessage 

func (*Int32Values) ProtoMessage()

func (*Int32Values) ProtoReflect 

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

func (*Int32Values) Reset 

func (x *Int32Values) Reset()

func (*Int32Values) SizeVT 

func (m *Int32Values) SizeVT() (n int)

func (*Int32Values) String 

func (x *Int32Values) String() string

func (*Int32Values) UnmarshalVT 

func (m *Int32Values) UnmarshalVT(dAtA []byte) error

func (*Int32Values) UnmarshalVTUnsafe 

func (m *Int32Values) UnmarshalVTUnsafe(dAtA []byte) error

type Int64Value 

type Int64Value struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     int64                  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Int64Value) CloneMessageVT 

func (m *Int64Value) CloneMessageVT() proto.Message

func (*Int64Value) CloneVT 

func (m *Int64Value) CloneVT() *Int64Value

func (*Int64Value) Descriptor deprecated 

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

Deprecated: Use Int64Value.ProtoReflect.Descriptor instead.

func (*Int64Value) EqualMessageVT 

func (this *Int64Value) EqualMessageVT(thatMsg proto.Message) bool

func (*Int64Value) EqualVT 

func (this *Int64Value) EqualVT(that *Int64Value) bool

func (*Int64Value) GetTimestamp 

func (x *Int64Value) GetTimestamp() *timestamppb.Timestamp

func (*Int64Value) GetValue 

func (x *Int64Value) GetValue() int64

func (*Int64Value) MarshalToSizedBufferVT 

func (m *Int64Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Int64Value) MarshalToSizedBufferVTStrict 

func (m *Int64Value) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Int64Value) MarshalToVT 

func (m *Int64Value) MarshalToVT(dAtA []byte) (int, error)

func (*Int64Value) MarshalToVTStrict 

func (m *Int64Value) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Int64Value) MarshalVT 

func (m *Int64Value) MarshalVT() (dAtA []byte, err error)

func (*Int64Value) MarshalVTStrict 

func (m *Int64Value) MarshalVTStrict() (dAtA []byte, err error)

func (*Int64Value) ProtoMessage 

func (*Int64Value) ProtoMessage()

func (*Int64Value) ProtoReflect 

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

func (*Int64Value) Reset 

func (x *Int64Value) Reset()

func (*Int64Value) SizeVT 

func (m *Int64Value) SizeVT() (n int)

func (*Int64Value) String 

func (x *Int64Value) String() string

func (*Int64Value) UnmarshalVT 

func (m *Int64Value) UnmarshalVT(dAtA []byte) error

func (*Int64Value) UnmarshalVTUnsafe 

func (m *Int64Value) UnmarshalVTUnsafe(dAtA []byte) error

type Int64Values 

type Int64Values struct {
	Metadata *Metadata     `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*Int64Value `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Int64Values) CloneMessageVT 

func (m *Int64Values) CloneMessageVT() proto.Message

func (*Int64Values) CloneVT 

func (m *Int64Values) CloneVT() *Int64Values

func (*Int64Values) Descriptor deprecated 

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

Deprecated: Use Int64Values.ProtoReflect.Descriptor instead.

func (*Int64Values) EqualMessageVT 

func (this *Int64Values) EqualMessageVT(thatMsg proto.Message) bool

func (*Int64Values) EqualVT 

func (this *Int64Values) EqualVT(that *Int64Values) bool

func (*Int64Values) GetMetadata 

func (x *Int64Values) GetMetadata() *Metadata

func (*Int64Values) GetValues 

func (x *Int64Values) GetValues() []*Int64Value

func (*Int64Values) MarshalToSizedBufferVT 

func (m *Int64Values) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Int64Values) MarshalToSizedBufferVTStrict 

func (m *Int64Values) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Int64Values) MarshalToVT 

func (m *Int64Values) MarshalToVT(dAtA []byte) (int, error)

func (*Int64Values) MarshalToVTStrict 

func (m *Int64Values) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Int64Values) MarshalVT 

func (m *Int64Values) MarshalVT() (dAtA []byte, err error)

func (*Int64Values) MarshalVTStrict 

func (m *Int64Values) MarshalVTStrict() (dAtA []byte, err error)

func (*Int64Values) ProtoMessage 

func (*Int64Values) ProtoMessage()

func (*Int64Values) ProtoReflect 

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

func (*Int64Values) Reset 

func (x *Int64Values) Reset()

func (*Int64Values) SizeVT 

func (m *Int64Values) SizeVT() (n int)

func (*Int64Values) String 

func (x *Int64Values) String() string

func (*Int64Values) UnmarshalVT 

func (m *Int64Values) UnmarshalVT(dAtA []byte) error

func (*Int64Values) UnmarshalVTUnsafe 

func (m *Int64Values) UnmarshalVTUnsafe(dAtA []byte) error

type Metadata 

type Metadata struct {
	DataType  v11.ChannelDataType `` /* 127-byte string literal not displayed */
	SampledMs uint32              `protobuf:"varint,2,opt,name=sampled_ms,json=sampledMs,proto3" json:"sampled_ms,omitempty"`
	Asset     *Metadata_Asset     `protobuf:"bytes,3,opt,name=asset,proto3" json:"asset,omitempty"`
	Run       *Metadata_Run       `protobuf:"bytes,4,opt,name=run,proto3,oneof" json:"run,omitempty"`
	Channel   *Metadata_Channel   `protobuf:"bytes,5,opt,name=channel,proto3,oneof" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) CloneMessageVT 

func (m *Metadata) CloneMessageVT() proto.Message

func (*Metadata) CloneVT 

func (m *Metadata) CloneVT() *Metadata

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) EqualMessageVT 

func (this *Metadata) EqualMessageVT(thatMsg proto.Message) bool

func (*Metadata) EqualVT 

func (this *Metadata) EqualVT(that *Metadata) bool

func (*Metadata) GetAsset 

func (x *Metadata) GetAsset() *Metadata_Asset

func (*Metadata) GetChannel 

func (x *Metadata) GetChannel() *Metadata_Channel

func (*Metadata) GetDataType 

func (x *Metadata) GetDataType() v11.ChannelDataType

func (*Metadata) GetRun 

func (x *Metadata) GetRun() *Metadata_Run

func (*Metadata) GetSampledMs 

func (x *Metadata) GetSampledMs() uint32

func (*Metadata) MarshalToSizedBufferVT 

func (m *Metadata) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Metadata) MarshalToSizedBufferVTStrict 

func (m *Metadata) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Metadata) MarshalToVT 

func (m *Metadata) MarshalToVT(dAtA []byte) (int, error)

func (*Metadata) MarshalToVTStrict 

func (m *Metadata) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Metadata) MarshalVT 

func (m *Metadata) MarshalVT() (dAtA []byte, err error)

func (*Metadata) MarshalVTStrict 

func (m *Metadata) MarshalVTStrict() (dAtA []byte, err error)

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) SizeVT 

func (m *Metadata) SizeVT() (n int)

func (*Metadata) String 

func (x *Metadata) String() string

func (*Metadata) UnmarshalVT 

func (m *Metadata) UnmarshalVT(dAtA []byte) error

func (*Metadata) UnmarshalVTUnsafe 

func (m *Metadata) UnmarshalVTUnsafe(dAtA []byte) error

type Metadata_Asset 

type Metadata_Asset struct {
	AssetId string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata_Asset) CloneMessageVT 

func (m *Metadata_Asset) CloneMessageVT() proto.Message

func (*Metadata_Asset) CloneVT 

func (m *Metadata_Asset) CloneVT() *Metadata_Asset

func (*Metadata_Asset) Descriptor deprecated 

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

Deprecated: Use Metadata_Asset.ProtoReflect.Descriptor instead.

func (*Metadata_Asset) EqualMessageVT 

func (this *Metadata_Asset) EqualMessageVT(thatMsg proto.Message) bool

func (*Metadata_Asset) EqualVT 

func (this *Metadata_Asset) EqualVT(that *Metadata_Asset) bool

func (*Metadata_Asset) GetAssetId 

func (x *Metadata_Asset) GetAssetId() string

func (*Metadata_Asset) GetName 

func (x *Metadata_Asset) GetName() string

func (*Metadata_Asset) MarshalToSizedBufferVT 

func (m *Metadata_Asset) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Metadata_Asset) MarshalToSizedBufferVTStrict 

func (m *Metadata_Asset) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Metadata_Asset) MarshalToVT 

func (m *Metadata_Asset) MarshalToVT(dAtA []byte) (int, error)

func (*Metadata_Asset) MarshalToVTStrict 

func (m *Metadata_Asset) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Metadata_Asset) MarshalVT 

func (m *Metadata_Asset) MarshalVT() (dAtA []byte, err error)

func (*Metadata_Asset) MarshalVTStrict 

func (m *Metadata_Asset) MarshalVTStrict() (dAtA []byte, err error)

func (*Metadata_Asset) ProtoMessage 

func (*Metadata_Asset) ProtoMessage()

func (*Metadata_Asset) ProtoReflect 

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

func (*Metadata_Asset) Reset 

func (x *Metadata_Asset) Reset()

func (*Metadata_Asset) SizeVT 

func (m *Metadata_Asset) SizeVT() (n int)

func (*Metadata_Asset) String 

func (x *Metadata_Asset) String() string

func (*Metadata_Asset) UnmarshalVT 

func (m *Metadata_Asset) UnmarshalVT(dAtA []byte) error

func (*Metadata_Asset) UnmarshalVTUnsafe 

func (m *Metadata_Asset) UnmarshalVTUnsafe(dAtA []byte) error

type Metadata_Channel 

type Metadata_Channel struct {

	// For channel queries, this will contain the requested backing channel id.
	// For calculated channel queries, this will contain the requested channel key.
	ChannelId        string                        `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	Component        string                        `protobuf:"bytes,2,opt,name=component,proto3" json:"component,omitempty"`
	Name             string                        `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Unit             *Metadata_Channel_Unit        `protobuf:"bytes,4,opt,name=unit,proto3" json:"unit,omitempty"`
	EnumTypes        []*v11.ChannelEnumType        `protobuf:"bytes,5,rep,name=enum_types,json=enumTypes,proto3" json:"enum_types,omitempty"`
	BitFieldElements []*v11.ChannelBitFieldElement `protobuf:"bytes,6,rep,name=bit_field_elements,json=bitFieldElements,proto3" json:"bit_field_elements,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata_Channel) CloneMessageVT 

func (m *Metadata_Channel) CloneMessageVT() proto.Message

func (*Metadata_Channel) CloneVT 

func (m *Metadata_Channel) CloneVT() *Metadata_Channel

func (*Metadata_Channel) Descriptor deprecated 

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

Deprecated: Use Metadata_Channel.ProtoReflect.Descriptor instead.

func (*Metadata_Channel) EqualMessageVT 

func (this *Metadata_Channel) EqualMessageVT(thatMsg proto.Message) bool

func (*Metadata_Channel) EqualVT 

func (this *Metadata_Channel) EqualVT(that *Metadata_Channel) bool

func (*Metadata_Channel) GetBitFieldElements 

func (x *Metadata_Channel) GetBitFieldElements() []*v11.ChannelBitFieldElement

func (*Metadata_Channel) GetChannelId 

func (x *Metadata_Channel) GetChannelId() string

func (*Metadata_Channel) GetComponent 

func (x *Metadata_Channel) GetComponent() string

func (*Metadata_Channel) GetEnumTypes 

func (x *Metadata_Channel) GetEnumTypes() []*v11.ChannelEnumType

func (*Metadata_Channel) GetName 

func (x *Metadata_Channel) GetName() string

func (*Metadata_Channel) GetUnit 

func (x *Metadata_Channel) GetUnit() *Metadata_Channel_Unit

func (*Metadata_Channel) MarshalToSizedBufferVT 

func (m *Metadata_Channel) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Metadata_Channel) MarshalToSizedBufferVTStrict 

func (m *Metadata_Channel) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Metadata_Channel) MarshalToVT 

func (m *Metadata_Channel) MarshalToVT(dAtA []byte) (int, error)

func (*Metadata_Channel) MarshalToVTStrict 

func (m *Metadata_Channel) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Metadata_Channel) MarshalVT 

func (m *Metadata_Channel) MarshalVT() (dAtA []byte, err error)

func (*Metadata_Channel) MarshalVTStrict 

func (m *Metadata_Channel) MarshalVTStrict() (dAtA []byte, err error)

func (*Metadata_Channel) ProtoMessage 

func (*Metadata_Channel) ProtoMessage()

func (*Metadata_Channel) ProtoReflect 

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

func (*Metadata_Channel) Reset 

func (x *Metadata_Channel) Reset()

func (*Metadata_Channel) SizeVT 

func (m *Metadata_Channel) SizeVT() (n int)

func (*Metadata_Channel) String 

func (x *Metadata_Channel) String() string

func (*Metadata_Channel) UnmarshalVT 

func (m *Metadata_Channel) UnmarshalVT(dAtA []byte) error

func (*Metadata_Channel) UnmarshalVTUnsafe 

func (m *Metadata_Channel) UnmarshalVTUnsafe(dAtA []byte) error

type Metadata_Channel_Unit 

type Metadata_Channel_Unit struct {
	Name            string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	AbbreviatedName string `protobuf:"bytes,2,opt,name=abbreviated_name,json=abbreviatedName,proto3" json:"abbreviated_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata_Channel_Unit) CloneMessageVT 

func (m *Metadata_Channel_Unit) CloneMessageVT() proto.Message

func (*Metadata_Channel_Unit) CloneVT 

func (m *Metadata_Channel_Unit) CloneVT() *Metadata_Channel_Unit

func (*Metadata_Channel_Unit) Descriptor deprecated 

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

Deprecated: Use Metadata_Channel_Unit.ProtoReflect.Descriptor instead.

func (*Metadata_Channel_Unit) EqualMessageVT 

func (this *Metadata_Channel_Unit) EqualMessageVT(thatMsg proto.Message) bool

func (*Metadata_Channel_Unit) EqualVT 

func (this *Metadata_Channel_Unit) EqualVT(that *Metadata_Channel_Unit) bool

func (*Metadata_Channel_Unit) GetAbbreviatedName 

func (x *Metadata_Channel_Unit) GetAbbreviatedName() string

func (*Metadata_Channel_Unit) GetName 

func (x *Metadata_Channel_Unit) GetName() string

func (*Metadata_Channel_Unit) MarshalToSizedBufferVT 

func (m *Metadata_Channel_Unit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Metadata_Channel_Unit) MarshalToSizedBufferVTStrict 

func (m *Metadata_Channel_Unit) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Metadata_Channel_Unit) MarshalToVT 

func (m *Metadata_Channel_Unit) MarshalToVT(dAtA []byte) (int, error)

func (*Metadata_Channel_Unit) MarshalToVTStrict 

func (m *Metadata_Channel_Unit) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Metadata_Channel_Unit) MarshalVT 

func (m *Metadata_Channel_Unit) MarshalVT() (dAtA []byte, err error)

func (*Metadata_Channel_Unit) MarshalVTStrict 

func (m *Metadata_Channel_Unit) MarshalVTStrict() (dAtA []byte, err error)

func (*Metadata_Channel_Unit) ProtoMessage 

func (*Metadata_Channel_Unit) ProtoMessage()

func (*Metadata_Channel_Unit) ProtoReflect 

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

func (*Metadata_Channel_Unit) Reset 

func (x *Metadata_Channel_Unit) Reset()

func (*Metadata_Channel_Unit) SizeVT 

func (m *Metadata_Channel_Unit) SizeVT() (n int)

func (*Metadata_Channel_Unit) String 

func (x *Metadata_Channel_Unit) String() string

func (*Metadata_Channel_Unit) UnmarshalVT 

func (m *Metadata_Channel_Unit) UnmarshalVT(dAtA []byte) error

func (*Metadata_Channel_Unit) UnmarshalVTUnsafe 

func (m *Metadata_Channel_Unit) UnmarshalVTUnsafe(dAtA []byte) error

type Metadata_Run 

type Metadata_Run struct {

	// The run_id that was sent with the data during ingestion (if any).
	// Note that this may be different from the run_id that was requested in the query.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata_Run) CloneMessageVT 

func (m *Metadata_Run) CloneMessageVT() proto.Message

func (*Metadata_Run) CloneVT 

func (m *Metadata_Run) CloneVT() *Metadata_Run

func (*Metadata_Run) Descriptor deprecated 

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

Deprecated: Use Metadata_Run.ProtoReflect.Descriptor instead.

func (*Metadata_Run) EqualMessageVT 

func (this *Metadata_Run) EqualMessageVT(thatMsg proto.Message) bool

func (*Metadata_Run) EqualVT 

func (this *Metadata_Run) EqualVT(that *Metadata_Run) bool

func (*Metadata_Run) GetName 

func (x *Metadata_Run) GetName() string

func (*Metadata_Run) GetRunId 

func (x *Metadata_Run) GetRunId() string

func (*Metadata_Run) MarshalToSizedBufferVT 

func (m *Metadata_Run) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Metadata_Run) MarshalToSizedBufferVTStrict 

func (m *Metadata_Run) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Metadata_Run) MarshalToVT 

func (m *Metadata_Run) MarshalToVT(dAtA []byte) (int, error)

func (*Metadata_Run) MarshalToVTStrict 

func (m *Metadata_Run) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Metadata_Run) MarshalVT 

func (m *Metadata_Run) MarshalVT() (dAtA []byte, err error)

func (*Metadata_Run) MarshalVTStrict 

func (m *Metadata_Run) MarshalVTStrict() (dAtA []byte, err error)

func (*Metadata_Run) ProtoMessage 

func (*Metadata_Run) ProtoMessage()

func (*Metadata_Run) ProtoReflect 

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

func (*Metadata_Run) Reset 

func (x *Metadata_Run) Reset()

func (*Metadata_Run) SizeVT 

func (m *Metadata_Run) SizeVT() (n int)

func (*Metadata_Run) String 

func (x *Metadata_Run) String() string

func (*Metadata_Run) UnmarshalVT 

func (m *Metadata_Run) UnmarshalVT(dAtA []byte) error

func (*Metadata_Run) UnmarshalVTUnsafe 

func (m *Metadata_Run) UnmarshalVTUnsafe(dAtA []byte) error

type Query 

type Query struct {

	// Types that are assignable to Query:
	//
	//	*Query_Channel
	//	*Query_CalculatedChannel
	Query isQuery_Query `protobuf_oneof:"query"`
	// contains filtered or unexported fields
}

func (*Query) CloneMessageVT 

func (m *Query) CloneMessageVT() proto.Message

func (*Query) CloneVT 

func (m *Query) CloneVT() *Query

func (*Query) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) EqualMessageVT 

func (this *Query) EqualMessageVT(thatMsg proto.Message) bool

func (*Query) EqualVT 

func (this *Query) EqualVT(that *Query) bool

func (*Query) GetCalculatedChannel 

func (x *Query) GetCalculatedChannel() *CalculatedChannelQuery

func (*Query) GetChannel 

func (x *Query) GetChannel() *ChannelQuery

func (*Query) GetQuery 

func (m *Query) GetQuery() isQuery_Query

func (*Query) MarshalToSizedBufferVT 

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

func (*Query) MarshalToSizedBufferVTStrict 

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

func (*Query) MarshalToVT 

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

func (*Query) MarshalToVTStrict 

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

func (*Query) MarshalVT 

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

func (*Query) MarshalVTStrict 

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

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) SizeVT 

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

func (*Query) String 

func (x *Query) String() string

func (*Query) UnmarshalVT 

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

func (*Query) UnmarshalVTUnsafe 

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

type Query_CalculatedChannel 

type Query_CalculatedChannel struct {
	CalculatedChannel *CalculatedChannelQuery `protobuf:"bytes,2,opt,name=calculated_channel,json=calculatedChannel,proto3,oneof"`
}

func (*Query_CalculatedChannel) CloneVT 

func (m *Query_CalculatedChannel) CloneVT() isQuery_Query

func (*Query_CalculatedChannel) EqualVT 

func (this *Query_CalculatedChannel) EqualVT(thatIface isQuery_Query) bool

func (*Query_CalculatedChannel) MarshalToSizedBufferVT 

func (m *Query_CalculatedChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Query_CalculatedChannel) MarshalToSizedBufferVTStrict 

func (m *Query_CalculatedChannel) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Query_CalculatedChannel) MarshalToVT 

func (m *Query_CalculatedChannel) MarshalToVT(dAtA []byte) (int, error)

func (*Query_CalculatedChannel) MarshalToVTStrict 

func (m *Query_CalculatedChannel) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Query_CalculatedChannel) SizeVT 

func (m *Query_CalculatedChannel) SizeVT() (n int)

type Query_Channel 

type Query_Channel struct {
	Channel *ChannelQuery `protobuf:"bytes,1,opt,name=channel,proto3,oneof"`
}

func (*Query_Channel) CloneVT 

func (m *Query_Channel) CloneVT() isQuery_Query

func (*Query_Channel) EqualVT 

func (this *Query_Channel) EqualVT(thatIface isQuery_Query) bool

func (*Query_Channel) MarshalToSizedBufferVT 

func (m *Query_Channel) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Query_Channel) MarshalToSizedBufferVTStrict 

func (m *Query_Channel) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Query_Channel) MarshalToVT 

func (m *Query_Channel) MarshalToVT(dAtA []byte) (int, error)

func (*Query_Channel) MarshalToVTStrict 

func (m *Query_Channel) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Query_Channel) SizeVT 

func (m *Query_Channel) SizeVT() (n int)

type StringValue 

type StringValue struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     string                 `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StringValue) CloneMessageVT 

func (m *StringValue) CloneMessageVT() proto.Message

func (*StringValue) CloneVT 

func (m *StringValue) CloneVT() *StringValue

func (*StringValue) Descriptor deprecated 

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

Deprecated: Use StringValue.ProtoReflect.Descriptor instead.

func (*StringValue) EqualMessageVT 

func (this *StringValue) EqualMessageVT(thatMsg proto.Message) bool

func (*StringValue) EqualVT 

func (this *StringValue) EqualVT(that *StringValue) bool

func (*StringValue) GetTimestamp 

func (x *StringValue) GetTimestamp() *timestamppb.Timestamp

func (*StringValue) GetValue 

func (x *StringValue) GetValue() string

func (*StringValue) MarshalToSizedBufferVT 

func (m *StringValue) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StringValue) MarshalToSizedBufferVTStrict 

func (m *StringValue) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*StringValue) MarshalToVT 

func (m *StringValue) MarshalToVT(dAtA []byte) (int, error)

func (*StringValue) MarshalToVTStrict 

func (m *StringValue) MarshalToVTStrict(dAtA []byte) (int, error)

func (*StringValue) MarshalVT 

func (m *StringValue) MarshalVT() (dAtA []byte, err error)

func (*StringValue) MarshalVTStrict 

func (m *StringValue) MarshalVTStrict() (dAtA []byte, err error)

func (*StringValue) ProtoMessage 

func (*StringValue) ProtoMessage()

func (*StringValue) ProtoReflect 

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

func (*StringValue) Reset 

func (x *StringValue) Reset()

func (*StringValue) SizeVT 

func (m *StringValue) SizeVT() (n int)

func (*StringValue) String 

func (x *StringValue) String() string

func (*StringValue) UnmarshalVT 

func (m *StringValue) UnmarshalVT(dAtA []byte) error

func (*StringValue) UnmarshalVTUnsafe 

func (m *StringValue) UnmarshalVTUnsafe(dAtA []byte) error

type StringValues 

type StringValues struct {
	Metadata *Metadata      `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*StringValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StringValues) CloneMessageVT 

func (m *StringValues) CloneMessageVT() proto.Message

func (*StringValues) CloneVT 

func (m *StringValues) CloneVT() *StringValues

func (*StringValues) Descriptor deprecated 

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

Deprecated: Use StringValues.ProtoReflect.Descriptor instead.

func (*StringValues) EqualMessageVT 

func (this *StringValues) EqualMessageVT(thatMsg proto.Message) bool

func (*StringValues) EqualVT 

func (this *StringValues) EqualVT(that *StringValues) bool

func (*StringValues) GetMetadata 

func (x *StringValues) GetMetadata() *Metadata

func (*StringValues) GetValues 

func (x *StringValues) GetValues() []*StringValue

func (*StringValues) MarshalToSizedBufferVT 

func (m *StringValues) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StringValues) MarshalToSizedBufferVTStrict 

func (m *StringValues) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*StringValues) MarshalToVT 

func (m *StringValues) MarshalToVT(dAtA []byte) (int, error)

func (*StringValues) MarshalToVTStrict 

func (m *StringValues) MarshalToVTStrict(dAtA []byte) (int, error)

func (*StringValues) MarshalVT 

func (m *StringValues) MarshalVT() (dAtA []byte, err error)

func (*StringValues) MarshalVTStrict 

func (m *StringValues) MarshalVTStrict() (dAtA []byte, err error)

func (*StringValues) ProtoMessage 

func (*StringValues) ProtoMessage()

func (*StringValues) ProtoReflect 

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

func (*StringValues) Reset 

func (x *StringValues) Reset()

func (*StringValues) SizeVT 

func (m *StringValues) SizeVT() (n int)

func (*StringValues) String 

func (x *StringValues) String() string

func (*StringValues) UnmarshalVT 

func (m *StringValues) UnmarshalVT(dAtA []byte) error

func (*StringValues) UnmarshalVTUnsafe 

func (m *StringValues) UnmarshalVTUnsafe(dAtA []byte) error

type Uint32Value 

type Uint32Value struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     uint32                 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Uint32Value) CloneMessageVT 

func (m *Uint32Value) CloneMessageVT() proto.Message

func (*Uint32Value) CloneVT 

func (m *Uint32Value) CloneVT() *Uint32Value

func (*Uint32Value) Descriptor deprecated 

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

Deprecated: Use Uint32Value.ProtoReflect.Descriptor instead.

func (*Uint32Value) EqualMessageVT 

func (this *Uint32Value) EqualMessageVT(thatMsg proto.Message) bool

func (*Uint32Value) EqualVT 

func (this *Uint32Value) EqualVT(that *Uint32Value) bool

func (*Uint32Value) GetTimestamp 

func (x *Uint32Value) GetTimestamp() *timestamppb.Timestamp

func (*Uint32Value) GetValue 

func (x *Uint32Value) GetValue() uint32

func (*Uint32Value) MarshalToSizedBufferVT 

func (m *Uint32Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Uint32Value) MarshalToSizedBufferVTStrict 

func (m *Uint32Value) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Uint32Value) MarshalToVT 

func (m *Uint32Value) MarshalToVT(dAtA []byte) (int, error)

func (*Uint32Value) MarshalToVTStrict 

func (m *Uint32Value) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Uint32Value) MarshalVT 

func (m *Uint32Value) MarshalVT() (dAtA []byte, err error)

func (*Uint32Value) MarshalVTStrict 

func (m *Uint32Value) MarshalVTStrict() (dAtA []byte, err error)

func (*Uint32Value) ProtoMessage 

func (*Uint32Value) ProtoMessage()

func (*Uint32Value) ProtoReflect 

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

func (*Uint32Value) Reset 

func (x *Uint32Value) Reset()

func (*Uint32Value) SizeVT 

func (m *Uint32Value) SizeVT() (n int)

func (*Uint32Value) String 

func (x *Uint32Value) String() string

func (*Uint32Value) UnmarshalVT 

func (m *Uint32Value) UnmarshalVT(dAtA []byte) error

func (*Uint32Value) UnmarshalVTUnsafe 

func (m *Uint32Value) UnmarshalVTUnsafe(dAtA []byte) error

type Uint32Values 

type Uint32Values struct {
	Metadata *Metadata      `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*Uint32Value `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Uint32Values) CloneMessageVT 

func (m *Uint32Values) CloneMessageVT() proto.Message

func (*Uint32Values) CloneVT 

func (m *Uint32Values) CloneVT() *Uint32Values

func (*Uint32Values) Descriptor deprecated 

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

Deprecated: Use Uint32Values.ProtoReflect.Descriptor instead.

func (*Uint32Values) EqualMessageVT 

func (this *Uint32Values) EqualMessageVT(thatMsg proto.Message) bool

func (*Uint32Values) EqualVT 

func (this *Uint32Values) EqualVT(that *Uint32Values) bool

func (*Uint32Values) GetMetadata 

func (x *Uint32Values) GetMetadata() *Metadata

func (*Uint32Values) GetValues 

func (x *Uint32Values) GetValues() []*Uint32Value

func (*Uint32Values) MarshalToSizedBufferVT 

func (m *Uint32Values) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Uint32Values) MarshalToSizedBufferVTStrict 

func (m *Uint32Values) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Uint32Values) MarshalToVT 

func (m *Uint32Values) MarshalToVT(dAtA []byte) (int, error)

func (*Uint32Values) MarshalToVTStrict 

func (m *Uint32Values) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Uint32Values) MarshalVT 

func (m *Uint32Values) MarshalVT() (dAtA []byte, err error)

func (*Uint32Values) MarshalVTStrict 

func (m *Uint32Values) MarshalVTStrict() (dAtA []byte, err error)

func (*Uint32Values) ProtoMessage 

func (*Uint32Values) ProtoMessage()

func (*Uint32Values) ProtoReflect 

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

func (*Uint32Values) Reset 

func (x *Uint32Values) Reset()

func (*Uint32Values) SizeVT 

func (m *Uint32Values) SizeVT() (n int)

func (*Uint32Values) String 

func (x *Uint32Values) String() string

func (*Uint32Values) UnmarshalVT 

func (m *Uint32Values) UnmarshalVT(dAtA []byte) error

func (*Uint32Values) UnmarshalVTUnsafe 

func (m *Uint32Values) UnmarshalVTUnsafe(dAtA []byte) error

type Uint64Value 

type Uint64Value struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     uint64                 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Uint64Value) CloneMessageVT 

func (m *Uint64Value) CloneMessageVT() proto.Message

func (*Uint64Value) CloneVT 

func (m *Uint64Value) CloneVT() *Uint64Value

func (*Uint64Value) Descriptor deprecated 

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

Deprecated: Use Uint64Value.ProtoReflect.Descriptor instead.

func (*Uint64Value) EqualMessageVT 

func (this *Uint64Value) EqualMessageVT(thatMsg proto.Message) bool

func (*Uint64Value) EqualVT 

func (this *Uint64Value) EqualVT(that *Uint64Value) bool

func (*Uint64Value) GetTimestamp 

func (x *Uint64Value) GetTimestamp() *timestamppb.Timestamp

func (*Uint64Value) GetValue 

func (x *Uint64Value) GetValue() uint64

func (*Uint64Value) MarshalToSizedBufferVT 

func (m *Uint64Value) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Uint64Value) MarshalToSizedBufferVTStrict 

func (m *Uint64Value) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Uint64Value) MarshalToVT 

func (m *Uint64Value) MarshalToVT(dAtA []byte) (int, error)

func (*Uint64Value) MarshalToVTStrict 

func (m *Uint64Value) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Uint64Value) MarshalVT 

func (m *Uint64Value) MarshalVT() (dAtA []byte, err error)

func (*Uint64Value) MarshalVTStrict 

func (m *Uint64Value) MarshalVTStrict() (dAtA []byte, err error)

func (*Uint64Value) ProtoMessage 

func (*Uint64Value) ProtoMessage()

func (*Uint64Value) ProtoReflect 

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

func (*Uint64Value) Reset 

func (x *Uint64Value) Reset()

func (*Uint64Value) SizeVT 

func (m *Uint64Value) SizeVT() (n int)

func (*Uint64Value) String 

func (x *Uint64Value) String() string

func (*Uint64Value) UnmarshalVT 

func (m *Uint64Value) UnmarshalVT(dAtA []byte) error

func (*Uint64Value) UnmarshalVTUnsafe 

func (m *Uint64Value) UnmarshalVTUnsafe(dAtA []byte) error

type Uint64Values 

type Uint64Values struct {
	Metadata *Metadata      `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Values   []*Uint64Value `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Uint64Values) CloneMessageVT 

func (m *Uint64Values) CloneMessageVT() proto.Message

func (*Uint64Values) CloneVT 

func (m *Uint64Values) CloneVT() *Uint64Values

func (*Uint64Values) Descriptor deprecated 

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

Deprecated: Use Uint64Values.ProtoReflect.Descriptor instead.

func (*Uint64Values) EqualMessageVT 

func (this *Uint64Values) EqualMessageVT(thatMsg proto.Message) bool

func (*Uint64Values) EqualVT 

func (this *Uint64Values) EqualVT(that *Uint64Values) bool

func (*Uint64Values) GetMetadata 

func (x *Uint64Values) GetMetadata() *Metadata

func (*Uint64Values) GetValues 

func (x *Uint64Values) GetValues() []*Uint64Value

func (*Uint64Values) MarshalToSizedBufferVT 

func (m *Uint64Values) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Uint64Values) MarshalToSizedBufferVTStrict 

func (m *Uint64Values) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)

func (*Uint64Values) MarshalToVT 

func (m *Uint64Values) MarshalToVT(dAtA []byte) (int, error)

func (*Uint64Values) MarshalToVTStrict 

func (m *Uint64Values) MarshalToVTStrict(dAtA []byte) (int, error)

func (*Uint64Values) MarshalVT 

func (m *Uint64Values) MarshalVT() (dAtA []byte, err error)

func (*Uint64Values) MarshalVTStrict 

func (m *Uint64Values) MarshalVTStrict() (dAtA []byte, err error)

func (*Uint64Values) ProtoMessage 

func (*Uint64Values) ProtoMessage()

func (*Uint64Values) ProtoReflect 

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

func (*Uint64Values) Reset 

func (x *Uint64Values) Reset()

func (*Uint64Values) SizeVT 

func (m *Uint64Values) SizeVT() (n int)

func (*Uint64Values) String 

func (x *Uint64Values) String() string

func (*Uint64Values) UnmarshalVT 

func (m *Uint64Values) UnmarshalVT(dAtA []byte) error

func (*Uint64Values) UnmarshalVTUnsafe 

func (m *Uint64Values) UnmarshalVTUnsafe(dAtA []byte) error

type UnimplementedDataServiceServer 

type UnimplementedDataServiceServer struct {
}

UnimplementedDataServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataServiceServer) GetData 

func (UnimplementedDataServiceServer) GetData(context.Context, *GetDataRequest) (*GetDataResponse, error)

type UnsafeDataServiceServer 

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

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

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.