growlog_server

package
v0.0.0-...-93b5f13 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_proto_growlog_proto protoreflect.FileDescriptor
View Source
var GrowLog_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.GrowLog",
	HandlerType: (*GrowLogServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _GrowLog_Register_Handler,
		},
		{
			MethodName: "Login",
			Handler:    _GrowLog_Login_Handler,
		},
		{
			MethodName: "InsertRow",
			Handler:    _GrowLog_InsertRow_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InsertRows",
			Handler:       _GrowLog_InsertRows_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Select",
			Handler:       _GrowLog_Select_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/growlog.proto",
}

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

Functions

func RegisterGrowLogServer

func RegisterGrowLogServer(s grpc.ServiceRegistrar, srv GrowLogServer)

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 GrowLogClient

type GrowLogClient interface {
	Register(ctx context.Context, in *RegistrationInfo, opts ...grpc.CallOption) (*User, error)
	Login(ctx context.Context, in *UserCredential, opts ...grpc.CallOption) (*User, error)
	InsertRow(ctx context.Context, in *TimeSeriesDatum, opts ...grpc.CallOption) (*empty.Empty, error)
	InsertRows(ctx context.Context, opts ...grpc.CallOption) (GrowLog_InsertRowsClient, error)
	Select(ctx context.Context, in *Filter, opts ...grpc.CallOption) (GrowLog_SelectClient, error)
}

GrowLogClient is the client API for GrowLog 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 NewGrowLogClient

func NewGrowLogClient(cc grpc.ClientConnInterface) GrowLogClient

type GrowLogServer

type GrowLogServer interface {
	Register(context.Context, *RegistrationInfo) (*User, error)
	Login(context.Context, *UserCredential) (*User, error)
	InsertRow(context.Context, *TimeSeriesDatum) (*empty.Empty, error)
	InsertRows(GrowLog_InsertRowsServer) error
	Select(*Filter, GrowLog_SelectServer) error
	// contains filtered or unexported methods
}

GrowLogServer is the server API for GrowLog service. All implementations must embed UnimplementedGrowLogServer for forward compatibility

type GrowLog_InsertRowsClient

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

type GrowLog_InsertRowsServer

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

type GrowLog_SelectClient

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

type GrowLog_SelectServer

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

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 RegistrationInfo

type RegistrationInfo struct {
	Email            string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	Password         string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	FirstName        string `protobuf:"bytes,3,opt,name=firstName,proto3" json:"firstName,omitempty"`
	LastName         string `protobuf:"bytes,4,opt,name=lastName,proto3" json:"lastName,omitempty"`
	OrganizationName string `protobuf:"bytes,5,opt,name=organizationName,proto3" json:"organizationName,omitempty"`
	Timezone         string `protobuf:"bytes,6,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationInfo) Descriptor deprecated

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

Deprecated: Use RegistrationInfo.ProtoReflect.Descriptor instead.

func (*RegistrationInfo) GetEmail

func (x *RegistrationInfo) GetEmail() string

func (*RegistrationInfo) GetFirstName

func (x *RegistrationInfo) GetFirstName() string

func (*RegistrationInfo) GetLastName

func (x *RegistrationInfo) GetLastName() string

func (*RegistrationInfo) GetOrganizationName

func (x *RegistrationInfo) GetOrganizationName() string

func (*RegistrationInfo) GetPassword

func (x *RegistrationInfo) GetPassword() string

func (*RegistrationInfo) GetTimezone

func (x *RegistrationInfo) GetTimezone() string

func (*RegistrationInfo) ProtoMessage

func (*RegistrationInfo) ProtoMessage()

func (*RegistrationInfo) ProtoReflect

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

func (*RegistrationInfo) Reset

func (x *RegistrationInfo) Reset()

func (*RegistrationInfo) String

func (x *RegistrationInfo) 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 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 UnimplementedGrowLogServer

type UnimplementedGrowLogServer struct {
}

UnimplementedGrowLogServer must be embedded to have forward compatible implementations.

func (UnimplementedGrowLogServer) InsertRow

func (UnimplementedGrowLogServer) InsertRows

func (UnimplementedGrowLogServer) Login

func (UnimplementedGrowLogServer) Register

func (UnimplementedGrowLogServer) Select

type UnsafeGrowLogServer

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

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

type User

type User struct {
	// contains filtered or unexported fields
}

func (*User) Descriptor deprecated

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) ProtoReflect

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

func (*User) Reset

func (x *User) Reset()

func (*User) String

func (x *User) String() string

type UserCredential

type UserCredential struct {
	Email    string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*UserCredential) Descriptor deprecated

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

Deprecated: Use UserCredential.ProtoReflect.Descriptor instead.

func (*UserCredential) GetEmail

func (x *UserCredential) GetEmail() string

func (*UserCredential) GetPassword

func (x *UserCredential) GetPassword() string

func (*UserCredential) ProtoMessage

func (*UserCredential) ProtoMessage()

func (*UserCredential) ProtoReflect

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

func (*UserCredential) Reset

func (x *UserCredential) Reset()

func (*UserCredential) String

func (x *UserCredential) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL