Documentation
¶
Index ¶
- Variables
- func RegisterTelemServer(s wsrpc.ServiceRegistrar, srv TelemServer)
- type TelemBatchRequest
- func (*TelemBatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TelemBatchRequest) GetContractId() string
- func (x *TelemBatchRequest) GetSentAt() int64
- func (x *TelemBatchRequest) GetTelemetry() [][]byte
- func (x *TelemBatchRequest) GetTelemetryType() string
- func (*TelemBatchRequest) ProtoMessage()
- func (x *TelemBatchRequest) ProtoReflect() protoreflect.Message
- func (x *TelemBatchRequest) Reset()
- func (x *TelemBatchRequest) String() string
- type TelemClient
- type TelemRequest
- func (*TelemRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TelemRequest) GetAddress() string
- func (x *TelemRequest) GetSentAt() int64
- func (x *TelemRequest) GetTelemetry() []byte
- func (x *TelemRequest) GetTelemetryType() string
- func (*TelemRequest) ProtoMessage()
- func (x *TelemRequest) ProtoReflect() protoreflect.Message
- func (x *TelemRequest) Reset()
- func (x *TelemRequest) String() string
- type TelemResponse
- type TelemServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_telem_proto protoreflect.FileDescriptor
View Source
var Telem_ServiceDesc = wsrpc.ServiceDesc{ ServiceName: "telem.Telem", HandlerType: (*TelemServer)(nil), Methods: []wsrpc.MethodDesc{ { MethodName: "Telem", Handler: _Telem_Telem_Handler, }, { MethodName: "TelemBatch", Handler: _Telem_TelemBatch_Handler, }, }, }
Telem_ServiceDesc is the wsrpc.ServiceDesc for Telem service. It's only intended for direct use with wsrpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterTelemServer ¶
func RegisterTelemServer(s wsrpc.ServiceRegistrar, srv TelemServer)
Types ¶
type TelemBatchRequest ¶
type TelemBatchRequest struct {
ContractId string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
Telemetry [][]byte `protobuf:"bytes,2,rep,name=telemetry,proto3" json:"telemetry,omitempty"`
TelemetryType string `protobuf:"bytes,3,opt,name=telemetry_type,json=telemetryType,proto3" json:"telemetry_type,omitempty"`
SentAt int64 `protobuf:"varint,4,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
// contains filtered or unexported fields
}
func (*TelemBatchRequest) Descriptor
deprecated
func (*TelemBatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use TelemBatchRequest.ProtoReflect.Descriptor instead.
func (*TelemBatchRequest) GetContractId ¶
func (x *TelemBatchRequest) GetContractId() string
func (*TelemBatchRequest) GetSentAt ¶
func (x *TelemBatchRequest) GetSentAt() int64
func (*TelemBatchRequest) GetTelemetry ¶
func (x *TelemBatchRequest) GetTelemetry() [][]byte
func (*TelemBatchRequest) GetTelemetryType ¶
func (x *TelemBatchRequest) GetTelemetryType() string
func (*TelemBatchRequest) ProtoMessage ¶
func (*TelemBatchRequest) ProtoMessage()
func (*TelemBatchRequest) ProtoReflect ¶
func (x *TelemBatchRequest) ProtoReflect() protoreflect.Message
func (*TelemBatchRequest) Reset ¶
func (x *TelemBatchRequest) Reset()
func (*TelemBatchRequest) String ¶
func (x *TelemBatchRequest) String() string
type TelemClient ¶
type TelemClient interface {
Telem(ctx context.Context, in *TelemRequest) (*TelemResponse, error)
TelemBatch(ctx context.Context, in *TelemBatchRequest) (*TelemResponse, error)
}
TelemClient is the client API for Telem service.
func NewTelemClient ¶
func NewTelemClient(cc wsrpc.ClientInterface) TelemClient
type TelemRequest ¶
type TelemRequest struct {
Telemetry []byte `protobuf:"bytes,1,opt,name=telemetry,proto3" json:"telemetry,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
TelemetryType string `protobuf:"bytes,3,opt,name=telemetry_type,json=telemetryType,proto3" json:"telemetry_type,omitempty"`
SentAt int64 `protobuf:"varint,4,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
// contains filtered or unexported fields
}
func (*TelemRequest) Descriptor
deprecated
func (*TelemRequest) Descriptor() ([]byte, []int)
Deprecated: Use TelemRequest.ProtoReflect.Descriptor instead.
func (*TelemRequest) GetAddress ¶
func (x *TelemRequest) GetAddress() string
func (*TelemRequest) GetSentAt ¶
func (x *TelemRequest) GetSentAt() int64
func (*TelemRequest) GetTelemetry ¶
func (x *TelemRequest) GetTelemetry() []byte
func (*TelemRequest) GetTelemetryType ¶
func (x *TelemRequest) GetTelemetryType() string
func (*TelemRequest) ProtoMessage ¶
func (*TelemRequest) ProtoMessage()
func (*TelemRequest) ProtoReflect ¶
func (x *TelemRequest) ProtoReflect() protoreflect.Message
func (*TelemRequest) Reset ¶
func (x *TelemRequest) Reset()
func (*TelemRequest) String ¶
func (x *TelemRequest) String() string
type TelemResponse ¶
type TelemResponse struct {
Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
// contains filtered or unexported fields
}
func (*TelemResponse) Descriptor
deprecated
func (*TelemResponse) Descriptor() ([]byte, []int)
Deprecated: Use TelemResponse.ProtoReflect.Descriptor instead.
func (*TelemResponse) GetBody ¶
func (x *TelemResponse) GetBody() string
func (*TelemResponse) ProtoMessage ¶
func (*TelemResponse) ProtoMessage()
func (*TelemResponse) ProtoReflect ¶
func (x *TelemResponse) ProtoReflect() protoreflect.Message
func (*TelemResponse) Reset ¶
func (x *TelemResponse) Reset()
func (*TelemResponse) String ¶
func (x *TelemResponse) String() string
type TelemServer ¶
type TelemServer interface {
Telem(context.Context, *TelemRequest) (*TelemResponse, error)
TelemBatch(context.Context, *TelemBatchRequest) (*TelemResponse, error)
}
TelemServer is the server API for Telem service.
Source Files
Click to show internal directories.
Click to hide internal directories.