gen

Documentation

Index

• Variables
• func RegisterTimeSeriesServiceServer(s grpc.ServiceRegistrar, srv TimeSeriesServiceServer)
• type Measurement
  • func (*Measurement) Descriptor() ([]byte, []int)
  • func (x *Measurement) GetName() string
  • func (x *Measurement) GetTags() map[string]string
  • func (x *Measurement) GetTimestamp() int64
  • func (x *Measurement) GetValue() float64
  • func (*Measurement) ProtoMessage()
  • func (x *Measurement) ProtoReflect() protoreflect.Message
  • func (x *Measurement) Reset()
  • func (x *Measurement) String() string
• type PostMeasurementRequest
  • func (*PostMeasurementRequest) Descriptor() ([]byte, []int)
  • func (x *PostMeasurementRequest) GetMeasurement() *Measurement
  • func (x *PostMeasurementRequest) GetType() string
  • func (*PostMeasurementRequest) ProtoMessage()
  • func (x *PostMeasurementRequest) ProtoReflect() protoreflect.Message
  • func (x *PostMeasurementRequest) Reset()
  • func (x *PostMeasurementRequest) String() string
• type PostMeasurementResponse
  • func (*PostMeasurementResponse) Descriptor() ([]byte, []int)
  • func (x *PostMeasurementResponse) GetId() string
  • func (*PostMeasurementResponse) ProtoMessage()
  • func (x *PostMeasurementResponse) ProtoReflect() protoreflect.Message
  • func (x *PostMeasurementResponse) Reset()
  • func (x *PostMeasurementResponse) String() string
• type TimeSeriesServiceClient
  • func NewTimeSeriesServiceClient(cc grpc.ClientConnInterface) TimeSeriesServiceClient
• type TimeSeriesServiceServer
• type UnimplementedTimeSeriesServiceServer
  • func (UnimplementedTimeSeriesServiceServer) PostMeasurement(context.Context, *PostMeasurementRequest) (*PostMeasurementResponse, error)
• type UnsafeTimeSeriesServiceServer

Variables

var File_v1_timeseries_proto protoreflect.FileDescriptor

var TimeSeriesService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "timeseries.v1.TimeSeriesService",
	HandlerType: (*TimeSeriesServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PostMeasurement",
			Handler:    _TimeSeriesService_PostMeasurement_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1/timeseries.proto",
}

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

Functions

func RegisterTimeSeriesServiceServer

func RegisterTimeSeriesServiceServer(s grpc.ServiceRegistrar, srv TimeSeriesServiceServer)

Types

type Measurement

type Measurement struct {
	Name      string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value     float64           `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Tags      map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Measurement) Descriptor

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

Deprecated: Use Measurement.ProtoReflect.Descriptor instead.

func (*Measurement) GetName

func (x *Measurement) GetName() string

func (*Measurement) GetTags

func (x *Measurement) GetTags() map[string]string

func (*Measurement) GetTimestamp

func (x *Measurement) GetTimestamp() int64

func (*Measurement) GetValue

func (x *Measurement) GetValue() float64

func (*Measurement) ProtoMessage

func (*Measurement) ProtoMessage()

func (*Measurement) ProtoReflect

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

func (*Measurement) Reset

func (x *Measurement) Reset()

func (*Measurement) String

func (x *Measurement) String() string

type PostMeasurementRequest

type PostMeasurementRequest struct {
	Type        string       `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Measurement *Measurement `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	// contains filtered or unexported fields
}

func (*PostMeasurementRequest) Descriptor

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

Deprecated: Use PostMeasurementRequest.ProtoReflect.Descriptor instead.

func (*PostMeasurementRequest) GetMeasurement

func (x *PostMeasurementRequest) GetMeasurement() *Measurement

func (*PostMeasurementRequest) GetType

func (x *PostMeasurementRequest) GetType() string

func (*PostMeasurementRequest) ProtoMessage

func (*PostMeasurementRequest) ProtoMessage()

func (*PostMeasurementRequest) ProtoReflect

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

func (*PostMeasurementRequest) Reset

func (x *PostMeasurementRequest) Reset()

func (*PostMeasurementRequest) String

func (x *PostMeasurementRequest) String() string

type PostMeasurementResponse

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

func (*PostMeasurementResponse) Descriptor

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

Deprecated: Use PostMeasurementResponse.ProtoReflect.Descriptor instead.

func (*PostMeasurementResponse) GetId

func (x *PostMeasurementResponse) GetId() string

func (*PostMeasurementResponse) ProtoMessage

func (*PostMeasurementResponse) ProtoMessage()

func (*PostMeasurementResponse) ProtoReflect

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

func (*PostMeasurementResponse) Reset

func (x *PostMeasurementResponse) Reset()

func (*PostMeasurementResponse) String

func (x *PostMeasurementResponse) String() string

type TimeSeriesServiceClient

type TimeSeriesServiceClient interface {
	PostMeasurement(ctx context.Context, in *PostMeasurementRequest, opts ...grpc.CallOption) (*PostMeasurementResponse, error)
}

TimeSeriesServiceClient is the client API for TimeSeriesService 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 NewTimeSeriesServiceClient

func NewTimeSeriesServiceClient(cc grpc.ClientConnInterface) TimeSeriesServiceClient

type TimeSeriesServiceServer

type TimeSeriesServiceServer interface {
	PostMeasurement(context.Context, *PostMeasurementRequest) (*PostMeasurementResponse, error)
	// contains filtered or unexported methods
}

TimeSeriesServiceServer is the server API for TimeSeriesService service. All implementations must embed UnimplementedTimeSeriesServiceServer for forward compatibility

type UnimplementedTimeSeriesServiceServer

type UnimplementedTimeSeriesServiceServer struct {
}

UnimplementedTimeSeriesServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTimeSeriesServiceServer) PostMeasurement

func (UnimplementedTimeSeriesServiceServer) PostMeasurement(context.Context, *PostMeasurementRequest) (*PostMeasurementResponse, error)

type UnsafeTimeSeriesServiceServer

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

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