telem

Documentation

Index

• Variables
• func RegisterTelemServer(s wsrpc.ServiceRegistrar, srv TelemServer)
• type TelemBatchRequest
  • func (*TelemBatchRequest) Descriptor() ([]byte, []int)
  • 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
  • func NewTelemClient(cc wsrpc.ClientInterface) TelemClient
• type TelemRequest
  • func (*TelemRequest) Descriptor() ([]byte, []int)
  • 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
  • func (*TelemResponse) Descriptor() ([]byte, []int)
  • func (x *TelemResponse) GetBody() string
  • func (*TelemResponse) ProtoMessage()
  • func (x *TelemResponse) ProtoReflect() protoreflect.Message
  • func (x *TelemResponse) Reset()
  • func (x *TelemResponse) String() string
• type TelemServer

Variables

var File_telem_proto protoreflect.FileDescriptor

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

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

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

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.