tstorage_server

package
v0.0.0-...-f0e8755 Latest Latest
Warning

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

 Go to latest Published: Aug 1, 2021 License: ISC Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_tstorage_proto protoreflect.FileDescriptor
View Source 
var TStorage_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.TStorage",
	HandlerType: (*TStorageServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InsertRow",
			Handler:    _TStorage_InsertRow_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InsertRows",
			Handler:       _TStorage_InsertRows_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Select",
			Handler:       _TStorage_Select_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/tstorage.proto",
}

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

Functions

func RegisterTStorageServer 

func RegisterTStorageServer(s grpc.ServiceRegistrar, srv TStorageServer)

Types

type DataPoint 

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

func (*DataPoint) Descriptor deprecated 

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

Deprecated: Use DataPoint.ProtoReflect.Descriptor instead.

func (*DataPoint) GetTimestamp 

func (x *DataPoint) GetTimestamp() *timestamp.Timestamp

func (*DataPoint) GetValue 

func (x *DataPoint) GetValue() 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 Filter 

type Filter struct {
	Metric string               `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Labels []*Label             `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	Start  *timestamp.Timestamp `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"`
	End    *timestamp.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetEnd 

func (x *Filter) GetEnd() *timestamp.Timestamp

func (*Filter) GetLabels 

func (x *Filter) GetLabels() []*Label

func (*Filter) GetMetric 

func (x *Filter) GetMetric() string

func (*Filter) GetStart 

func (x *Filter) GetStart() *timestamp.Timestamp

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type Label 

type Label struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Label) Descriptor deprecated 

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

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetName 

func (x *Label) GetName() string

func (*Label) GetValue 

func (x *Label) GetValue() string

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) ProtoReflect 

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

func (*Label) Reset 

func (x *Label) Reset()

func (*Label) String 

func (x *Label) String() string

type SelectResponse 

type SelectResponse struct {
	Points []*DataPoint `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectResponse) Descriptor deprecated 

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

Deprecated: Use SelectResponse.ProtoReflect.Descriptor instead.

func (*SelectResponse) GetPoints 

func (x *SelectResponse) GetPoints() []*DataPoint

func (*SelectResponse) ProtoMessage 

func (*SelectResponse) ProtoMessage()

func (*SelectResponse) ProtoReflect 

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

func (*SelectResponse) Reset 

func (x *SelectResponse) Reset()

func (*SelectResponse) String 

func (x *SelectResponse) String() string

type TStorageClient 

type TStorageClient interface {
	InsertRow(ctx context.Context, in *TimeSeriesDatum, opts ...grpc.CallOption) (*empty.Empty, error)
	InsertRows(ctx context.Context, opts ...grpc.CallOption) (TStorage_InsertRowsClient, error)
	Select(ctx context.Context, in *Filter, opts ...grpc.CallOption) (TStorage_SelectClient, error)
}

TStorageClient is the client API for TStorage 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 NewTStorageClient 

func NewTStorageClient(cc grpc.ClientConnInterface) TStorageClient

type TStorageServer 

type TStorageServer interface {
	InsertRow(context.Context, *TimeSeriesDatum) (*empty.Empty, error)
	InsertRows(TStorage_InsertRowsServer) error
	Select(*Filter, TStorage_SelectServer) error
	// contains filtered or unexported methods
}

TStorageServer is the server API for TStorage service. All implementations must embed UnimplementedTStorageServer for forward compatibility

type TStorage_InsertRowsClient 

type TStorage_InsertRowsClient interface {
	Send(*TimeSeriesDatum) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type TStorage_InsertRowsServer 

type TStorage_InsertRowsServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*TimeSeriesDatum, error)
	grpc.ServerStream
}

type TStorage_SelectClient 

type TStorage_SelectClient interface {
	Recv() (*DataPoint, error)
	grpc.ClientStream
}

type TStorage_SelectServer 

type TStorage_SelectServer interface {
	Send(*DataPoint) error
	grpc.ServerStream
}

type TimeSeriesDatum 

type TimeSeriesDatum struct {
	Metric    string               `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Labels    []*Label             `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	Value     float64              `protobuf:"fixed64,3,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeSeriesDatum) Descriptor deprecated 

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

Deprecated: Use TimeSeriesDatum.ProtoReflect.Descriptor instead.

func (*TimeSeriesDatum) GetLabels 

func (x *TimeSeriesDatum) GetLabels() []*Label

func (*TimeSeriesDatum) GetMetric 

func (x *TimeSeriesDatum) GetMetric() string

func (*TimeSeriesDatum) GetTimestamp 

func (x *TimeSeriesDatum) GetTimestamp() *timestamp.Timestamp

func (*TimeSeriesDatum) GetValue 

func (x *TimeSeriesDatum) GetValue() float64

func (*TimeSeriesDatum) ProtoMessage 

func (*TimeSeriesDatum) ProtoMessage()

func (*TimeSeriesDatum) ProtoReflect 

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

func (*TimeSeriesDatum) Reset 

func (x *TimeSeriesDatum) Reset()

func (*TimeSeriesDatum) String 

func (x *TimeSeriesDatum) String() string

type UnimplementedTStorageServer 

type UnimplementedTStorageServer struct {
}

UnimplementedTStorageServer must be embedded to have forward compatible implementations.

func (UnimplementedTStorageServer) InsertRow 

func (UnimplementedTStorageServer) InsertRow(context.Context, *TimeSeriesDatum) (*empty.Empty, error)

func (UnimplementedTStorageServer) InsertRows 

func (UnimplementedTStorageServer) InsertRows(TStorage_InsertRowsServer) error

func (UnimplementedTStorageServer) Select 

func (UnimplementedTStorageServer) Select(*Filter, TStorage_SelectServer) error

type UnsafeTStorageServer 

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

UnsafeTStorageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TStorageServer 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.