Documentation ¶
Index ¶
- Variables
- func RegisterGrowLogServer(s grpc.ServiceRegistrar, srv GrowLogServer)
- type DataPoint
- func (*DataPoint) Descriptor() ([]byte, []int)deprecated
- func (x *DataPoint) GetTimestamp() *timestamp.Timestamp
- func (x *DataPoint) GetValue() float64
- func (*DataPoint) ProtoMessage()
- func (x *DataPoint) ProtoReflect() protoreflect.Message
- func (x *DataPoint) Reset()
- func (x *DataPoint) String() string
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)deprecated
- func (x *Filter) GetEnd() *timestamp.Timestamp
- func (x *Filter) GetLabels() []*Label
- func (x *Filter) GetMetric() string
- func (x *Filter) GetStart() *timestamp.Timestamp
- func (*Filter) ProtoMessage()
- func (x *Filter) ProtoReflect() protoreflect.Message
- func (x *Filter) Reset()
- func (x *Filter) String() string
- type GrowLogClient
- type GrowLogServer
- type GrowLog_InsertRowsClient
- type GrowLog_InsertRowsServer
- type GrowLog_SelectClient
- type GrowLog_SelectServer
- type Label
- type RegistrationInfo
- func (*RegistrationInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RegistrationInfo) GetEmail() string
- func (x *RegistrationInfo) GetFirstName() string
- func (x *RegistrationInfo) GetLastName() string
- func (x *RegistrationInfo) GetOrganizationName() string
- func (x *RegistrationInfo) GetPassword() string
- func (x *RegistrationInfo) GetTimezone() string
- func (*RegistrationInfo) ProtoMessage()
- func (x *RegistrationInfo) ProtoReflect() protoreflect.Message
- func (x *RegistrationInfo) Reset()
- func (x *RegistrationInfo) String() string
- type SelectResponse
- type TimeSeriesDatum
- func (*TimeSeriesDatum) Descriptor() ([]byte, []int)deprecated
- func (x *TimeSeriesDatum) GetLabels() []*Label
- func (x *TimeSeriesDatum) GetMetric() string
- func (x *TimeSeriesDatum) GetTimestamp() *timestamp.Timestamp
- func (x *TimeSeriesDatum) GetValue() float64
- func (*TimeSeriesDatum) ProtoMessage()
- func (x *TimeSeriesDatum) ProtoReflect() protoreflect.Message
- func (x *TimeSeriesDatum) Reset()
- func (x *TimeSeriesDatum) String() string
- type UnimplementedGrowLogServer
- func (UnimplementedGrowLogServer) InsertRow(context.Context, *TimeSeriesDatum) (*empty.Empty, error)
- func (UnimplementedGrowLogServer) InsertRows(GrowLog_InsertRowsServer) error
- func (UnimplementedGrowLogServer) Login(context.Context, *UserCredential) (*User, error)
- func (UnimplementedGrowLogServer) Register(context.Context, *RegistrationInfo) (*User, error)
- func (UnimplementedGrowLogServer) Select(*Filter, GrowLog_SelectServer) error
- type UnsafeGrowLogServer
- type User
- type UserCredential
- func (*UserCredential) Descriptor() ([]byte, []int)deprecated
- func (x *UserCredential) GetEmail() string
- func (x *UserCredential) GetPassword() string
- func (*UserCredential) ProtoMessage()
- func (x *UserCredential) ProtoReflect() protoreflect.Message
- func (x *UserCredential) Reset()
- func (x *UserCredential) String() string
Constants ¶
This section is empty.
Variables ¶
var File_proto_growlog_proto protoreflect.FileDescriptor
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) GetTimestamp ¶
func (*DataPoint) ProtoMessage ¶
func (*DataPoint) ProtoMessage()
func (*DataPoint) ProtoReflect ¶
func (x *DataPoint) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶
func (x *Filter) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*Label) ProtoMessage()
func (*Label) ProtoReflect ¶
func (x *Label) ProtoReflect() protoreflect.Message
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) InsertRow(context.Context, *TimeSeriesDatum) (*empty.Empty, error)
func (UnimplementedGrowLogServer) InsertRows ¶
func (UnimplementedGrowLogServer) InsertRows(GrowLog_InsertRowsServer) error
func (UnimplementedGrowLogServer) Login ¶
func (UnimplementedGrowLogServer) Login(context.Context, *UserCredential) (*User, error)
func (UnimplementedGrowLogServer) Register ¶
func (UnimplementedGrowLogServer) Register(context.Context, *RegistrationInfo) (*User, error)
func (UnimplementedGrowLogServer) Select ¶
func (UnimplementedGrowLogServer) Select(*Filter, GrowLog_SelectServer) error
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) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶
func (x *User) ProtoReflect() protoreflect.Message
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