mothership_server

package
v0.0.0-...-fa3a857 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_mothership_proto protoreflect.FileDescriptor
View Source 
var Mothership_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Mothership",
	HandlerType: (*MothershipServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Mothership_Register_Handler,
		},
		{
			MethodName: "Login",
			Handler:    _Mothership_Login_Handler,
		},
		{
			MethodName: "RefreshToken",
			Handler:    _Mothership_RefreshToken_Handler,
		},
		{
			MethodName: "InsertTimeSeriesDatum",
			Handler:    _Mothership_InsertTimeSeriesDatum_Handler,
		},
		{
			MethodName: "InsertBulkTimeSeriesData",
			Handler:    _Mothership_InsertBulkTimeSeriesData_Handler,
		},
		{
			MethodName: "SelectBulkTimeSeriesData",
			Handler:    _Mothership_SelectBulkTimeSeriesData_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InsertTimeSeriesData",
			Handler:       _Mothership_InsertTimeSeriesData_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "proto/mothership.proto",
}

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

Functions

func RegisterMothershipServer 

func RegisterMothershipServer(s grpc.ServiceRegistrar, srv MothershipServer)

Types

type BulkTimeSeriesDataReq 

type BulkTimeSeriesDataReq struct {
	Data []*TimeSeriesDatumReq `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkTimeSeriesDataReq) Descriptor deprecated 

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

Deprecated: Use BulkTimeSeriesDataReq.ProtoReflect.Descriptor instead.

func (*BulkTimeSeriesDataReq) GetData 

func (x *BulkTimeSeriesDataReq) GetData() []*TimeSeriesDatumReq

func (*BulkTimeSeriesDataReq) ProtoMessage 

func (*BulkTimeSeriesDataReq) ProtoMessage()

func (*BulkTimeSeriesDataReq) ProtoReflect 

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

func (*BulkTimeSeriesDataReq) Reset 

func (x *BulkTimeSeriesDataReq) Reset()

func (*BulkTimeSeriesDataReq) String 

func (x *BulkTimeSeriesDataReq) String() string

type DataPointRes 

type DataPointRes 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 (*DataPointRes) Descriptor deprecated 

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

Deprecated: Use DataPointRes.ProtoReflect.Descriptor instead.

func (*DataPointRes) GetTimestamp 

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

func (*DataPointRes) GetValue 

func (x *DataPointRes) GetValue() float64

func (*DataPointRes) ProtoMessage 

func (*DataPointRes) ProtoMessage()

func (*DataPointRes) ProtoReflect 

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

func (*DataPointRes) Reset 

func (x *DataPointRes) Reset()

func (*DataPointRes) String 

func (x *DataPointRes) String() string

type FilterReq 

type FilterReq struct {
	Metric string               `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Labels []*LabelReq          `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 (*FilterReq) Descriptor deprecated 

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

Deprecated: Use FilterReq.ProtoReflect.Descriptor instead.

func (*FilterReq) GetEnd 

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

func (*FilterReq) GetLabels 

func (x *FilterReq) GetLabels() []*LabelReq

func (*FilterReq) GetMetric 

func (x *FilterReq) GetMetric() string

func (*FilterReq) GetStart 

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

func (*FilterReq) ProtoMessage 

func (*FilterReq) ProtoMessage()

func (*FilterReq) ProtoReflect 

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

func (*FilterReq) Reset 

func (x *FilterReq) Reset()

func (*FilterReq) String 

func (x *FilterReq) String() string

type LabelReq 

type LabelReq 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 (*LabelReq) Descriptor deprecated 

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

Deprecated: Use LabelReq.ProtoReflect.Descriptor instead.

func (*LabelReq) GetName 

func (x *LabelReq) GetName() string

func (*LabelReq) GetValue 

func (x *LabelReq) GetValue() string

func (*LabelReq) ProtoMessage 

func (*LabelReq) ProtoMessage()

func (*LabelReq) ProtoReflect 

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

func (*LabelReq) Reset 

func (x *LabelReq) Reset()

func (*LabelReq) String 

func (x *LabelReq) String() string

type LoginReq 

type LoginReq 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 (*LoginReq) Descriptor deprecated 

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

Deprecated: Use LoginReq.ProtoReflect.Descriptor instead.

func (*LoginReq) GetEmail 

func (x *LoginReq) GetEmail() string

func (*LoginReq) GetPassword 

func (x *LoginReq) GetPassword() string

func (*LoginReq) ProtoMessage 

func (*LoginReq) ProtoMessage()

func (*LoginReq) ProtoReflect 

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

func (*LoginReq) Reset 

func (x *LoginReq) Reset()

func (*LoginReq) String 

func (x *LoginReq) String() string

type LoginRes 

type LoginRes struct {
	AccessToken  string `protobuf:"bytes,1,opt,name=accessToken,proto3" json:"accessToken,omitempty"`
	RefreshToken string `protobuf:"bytes,2,opt,name=refreshToken,proto3" json:"refreshToken,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginRes) Descriptor deprecated 

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

Deprecated: Use LoginRes.ProtoReflect.Descriptor instead.

func (*LoginRes) GetAccessToken 

func (x *LoginRes) GetAccessToken() string

func (*LoginRes) GetRefreshToken 

func (x *LoginRes) GetRefreshToken() string

func (*LoginRes) ProtoMessage 

func (*LoginRes) ProtoMessage()

func (*LoginRes) ProtoReflect 

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

func (*LoginRes) Reset 

func (x *LoginRes) Reset()

func (*LoginRes) String 

func (x *LoginRes) String() string

type MothershipClient 

type MothershipClient interface {
	Register(ctx context.Context, in *RegistrationReq, opts ...grpc.CallOption) (*RegistrationRes, error)
	Login(ctx context.Context, in *LoginReq, opts ...grpc.CallOption) (*LoginRes, error)
	RefreshToken(ctx context.Context, in *RefreshTokenReq, opts ...grpc.CallOption) (*RefreshTokenRes, error)
	InsertTimeSeriesDatum(ctx context.Context, in *TimeSeriesDatumReq, opts ...grpc.CallOption) (*empty.Empty, error)
	InsertTimeSeriesData(ctx context.Context, opts ...grpc.CallOption) (Mothership_InsertTimeSeriesDataClient, error)
	InsertBulkTimeSeriesData(ctx context.Context, in *BulkTimeSeriesDataReq, opts ...grpc.CallOption) (*empty.Empty, error)
	SelectBulkTimeSeriesData(ctx context.Context, in *FilterReq, opts ...grpc.CallOption) (*SelectBulkRes, error)
}

MothershipClient is the client API for Mothership 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 NewMothershipClient 

func NewMothershipClient(cc grpc.ClientConnInterface) MothershipClient

type MothershipServer 

type MothershipServer interface {
	Register(context.Context, *RegistrationReq) (*RegistrationRes, error)
	Login(context.Context, *LoginReq) (*LoginRes, error)
	RefreshToken(context.Context, *RefreshTokenReq) (*RefreshTokenRes, error)
	InsertTimeSeriesDatum(context.Context, *TimeSeriesDatumReq) (*empty.Empty, error)
	InsertTimeSeriesData(Mothership_InsertTimeSeriesDataServer) error
	InsertBulkTimeSeriesData(context.Context, *BulkTimeSeriesDataReq) (*empty.Empty, error)
	SelectBulkTimeSeriesData(context.Context, *FilterReq) (*SelectBulkRes, error)
	// contains filtered or unexported methods
}

MothershipServer is the server API for Mothership service. All implementations must embed UnimplementedMothershipServer for forward compatibility

type Mothership_InsertTimeSeriesDataClient 

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

type Mothership_InsertTimeSeriesDataServer 

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

type RefreshTokenReq 

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

func (*RefreshTokenReq) Descriptor deprecated 

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

Deprecated: Use RefreshTokenReq.ProtoReflect.Descriptor instead.

func (*RefreshTokenReq) GetValue 

func (x *RefreshTokenReq) GetValue() string

func (*RefreshTokenReq) ProtoMessage 

func (*RefreshTokenReq) ProtoMessage()

func (*RefreshTokenReq) ProtoReflect 

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

func (*RefreshTokenReq) Reset 

func (x *RefreshTokenReq) Reset()

func (*RefreshTokenReq) String 

func (x *RefreshTokenReq) String() string

type RefreshTokenRes 

type RefreshTokenRes struct {
	AccessToken  string `protobuf:"bytes,1,opt,name=accessToken,proto3" json:"accessToken,omitempty"`
	RefreshToken string `protobuf:"bytes,2,opt,name=refreshToken,proto3" json:"refreshToken,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshTokenRes) Descriptor deprecated 

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

Deprecated: Use RefreshTokenRes.ProtoReflect.Descriptor instead.

func (*RefreshTokenRes) GetAccessToken 

func (x *RefreshTokenRes) GetAccessToken() string

func (*RefreshTokenRes) GetRefreshToken 

func (x *RefreshTokenRes) GetRefreshToken() string

func (*RefreshTokenRes) ProtoMessage 

func (*RefreshTokenRes) ProtoMessage()

func (*RefreshTokenRes) ProtoReflect 

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

func (*RefreshTokenRes) Reset 

func (x *RefreshTokenRes) Reset()

func (*RefreshTokenRes) String 

func (x *RefreshTokenRes) String() string

type RegistrationReq 

type RegistrationReq 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"`
	Company   string `protobuf:"bytes,5,opt,name=company,proto3" json:"company,omitempty"`
	Timezone  string `protobuf:"bytes,6,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationReq) Descriptor deprecated 

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

Deprecated: Use RegistrationReq.ProtoReflect.Descriptor instead.

func (*RegistrationReq) GetCompany 

func (x *RegistrationReq) GetCompany() string

func (*RegistrationReq) GetEmail 

func (x *RegistrationReq) GetEmail() string

func (*RegistrationReq) GetFirstName 

func (x *RegistrationReq) GetFirstName() string

func (*RegistrationReq) GetLastName 

func (x *RegistrationReq) GetLastName() string

func (*RegistrationReq) GetPassword 

func (x *RegistrationReq) GetPassword() string

func (*RegistrationReq) GetTimezone 

func (x *RegistrationReq) GetTimezone() string

func (*RegistrationReq) ProtoMessage 

func (*RegistrationReq) ProtoMessage()

func (*RegistrationReq) ProtoReflect 

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

func (*RegistrationReq) Reset 

func (x *RegistrationReq) Reset()

func (*RegistrationReq) String 

func (x *RegistrationReq) String() string

type RegistrationRes 

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

func (*RegistrationRes) Descriptor deprecated 

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

Deprecated: Use RegistrationRes.ProtoReflect.Descriptor instead.

func (*RegistrationRes) GetMessage 

func (x *RegistrationRes) GetMessage() string

func (*RegistrationRes) ProtoMessage 

func (*RegistrationRes) ProtoMessage()

func (*RegistrationRes) ProtoReflect 

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

func (*RegistrationRes) Reset 

func (x *RegistrationRes) Reset()

func (*RegistrationRes) String 

func (x *RegistrationRes) String() string

type SelectBulkRes 

type SelectBulkRes struct {
	DataPoints []*DataPointRes `protobuf:"bytes,1,rep,name=dataPoints,proto3" json:"dataPoints,omitempty"`
	// contains filtered or unexported fields
}

func (*SelectBulkRes) Descriptor deprecated 

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

Deprecated: Use SelectBulkRes.ProtoReflect.Descriptor instead.

func (*SelectBulkRes) GetDataPoints 

func (x *SelectBulkRes) GetDataPoints() []*DataPointRes

func (*SelectBulkRes) ProtoMessage 

func (*SelectBulkRes) ProtoMessage()

func (*SelectBulkRes) ProtoReflect 

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

func (*SelectBulkRes) Reset 

func (x *SelectBulkRes) Reset()

func (*SelectBulkRes) String 

func (x *SelectBulkRes) String() string

type TimeSeriesDatumReq 

type TimeSeriesDatumReq struct {
	Metric    string               `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Labels    []*LabelReq          `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 (*TimeSeriesDatumReq) Descriptor deprecated 

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

Deprecated: Use TimeSeriesDatumReq.ProtoReflect.Descriptor instead.

func (*TimeSeriesDatumReq) GetLabels 

func (x *TimeSeriesDatumReq) GetLabels() []*LabelReq

func (*TimeSeriesDatumReq) GetMetric 

func (x *TimeSeriesDatumReq) GetMetric() string

func (*TimeSeriesDatumReq) GetTimestamp 

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

func (*TimeSeriesDatumReq) GetValue 

func (x *TimeSeriesDatumReq) GetValue() float64

func (*TimeSeriesDatumReq) ProtoMessage 

func (*TimeSeriesDatumReq) ProtoMessage()

func (*TimeSeriesDatumReq) ProtoReflect 

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

func (*TimeSeriesDatumReq) Reset 

func (x *TimeSeriesDatumReq) Reset()

func (*TimeSeriesDatumReq) String 

func (x *TimeSeriesDatumReq) String() string

type UnimplementedMothershipServer 

type UnimplementedMothershipServer struct {
}

UnimplementedMothershipServer must be embedded to have forward compatible implementations.

func (UnimplementedMothershipServer) InsertBulkTimeSeriesData 

func (UnimplementedMothershipServer) InsertBulkTimeSeriesData(context.Context, *BulkTimeSeriesDataReq) (*empty.Empty, error)

func (UnimplementedMothershipServer) InsertTimeSeriesData 

func (UnimplementedMothershipServer) InsertTimeSeriesData(Mothership_InsertTimeSeriesDataServer) error

func (UnimplementedMothershipServer) InsertTimeSeriesDatum 

func (UnimplementedMothershipServer) InsertTimeSeriesDatum(context.Context, *TimeSeriesDatumReq) (*empty.Empty, error)

func (UnimplementedMothershipServer) Login 

func (UnimplementedMothershipServer) Login(context.Context, *LoginReq) (*LoginRes, error)

func (UnimplementedMothershipServer) RefreshToken 

func (UnimplementedMothershipServer) RefreshToken(context.Context, *RefreshTokenReq) (*RefreshTokenRes, error)

func (UnimplementedMothershipServer) Register 

func (UnimplementedMothershipServer) Register(context.Context, *RegistrationReq) (*RegistrationRes, error)

func (UnimplementedMothershipServer) SelectBulkTimeSeriesData 

func (UnimplementedMothershipServer) SelectBulkTimeSeriesData(context.Context, *FilterReq) (*SelectBulkRes, error)

type UnsafeMothershipServer 

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

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