telem

package
v2.0.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_core_services_synchronization_telem_telem_enahced_ea_proto protoreflect.FileDescriptor
View Source 
var File_core_services_synchronization_telem_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 EnhancedEA 

type EnhancedEA struct {
	DataSource                    string `protobuf:"bytes,1,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	Value                         int64  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	BridgeTaskRunStartedTimestamp int64  `` /* 155-byte string literal not displayed */
	BridgeTaskRunEndedTimestamp   int64  `` /* 149-byte string literal not displayed */
	ProviderRequestedProtocol     string `` /* 138-byte string literal not displayed */
	ProviderRequestedTimestamp    int64  `` /* 142-byte string literal not displayed */
	ProviderReceivedTimestamp     int64  `` /* 139-byte string literal not displayed */
	ProviderDataStreamEstablished int64  `` /* 153-byte string literal not displayed */
	ProviderDataReceived          int64  `protobuf:"varint,9,opt,name=provider_data_received,json=providerDataReceived,proto3" json:"provider_data_received,omitempty"`
	ProviderIndicatedTime         int64  `` /* 128-byte string literal not displayed */
	Feed                          string `protobuf:"bytes,11,opt,name=feed,proto3" json:"feed,omitempty"`
	ChainId                       string `protobuf:"bytes,12,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	Observation                   int64  `protobuf:"varint,13,opt,name=observation,proto3" json:"observation,omitempty"`
	ConfigDigest                  string `protobuf:"bytes,14,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	Round                         int64  `protobuf:"varint,15,opt,name=round,proto3" json:"round,omitempty"`
	Epoch                         int64  `protobuf:"varint,16,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

func (*EnhancedEA) Descriptor deprecated 

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

Deprecated: Use EnhancedEA.ProtoReflect.Descriptor instead.

func (*EnhancedEA) GetBridgeTaskRunEndedTimestamp 

func (x *EnhancedEA) GetBridgeTaskRunEndedTimestamp() int64

func (*EnhancedEA) GetBridgeTaskRunStartedTimestamp 

func (x *EnhancedEA) GetBridgeTaskRunStartedTimestamp() int64

func (*EnhancedEA) GetChainId 

func (x *EnhancedEA) GetChainId() string

func (*EnhancedEA) GetConfigDigest 

func (x *EnhancedEA) GetConfigDigest() string

func (*EnhancedEA) GetDataSource 

func (x *EnhancedEA) GetDataSource() string

func (*EnhancedEA) GetEpoch 

func (x *EnhancedEA) GetEpoch() int64

func (*EnhancedEA) GetFeed 

func (x *EnhancedEA) GetFeed() string

func (*EnhancedEA) GetObservation 

func (x *EnhancedEA) GetObservation() int64

func (*EnhancedEA) GetProviderDataReceived 

func (x *EnhancedEA) GetProviderDataReceived() int64

func (*EnhancedEA) GetProviderDataStreamEstablished 

func (x *EnhancedEA) GetProviderDataStreamEstablished() int64

func (*EnhancedEA) GetProviderIndicatedTime 

func (x *EnhancedEA) GetProviderIndicatedTime() int64

func (*EnhancedEA) GetProviderReceivedTimestamp 

func (x *EnhancedEA) GetProviderReceivedTimestamp() int64

func (*EnhancedEA) GetProviderRequestedProtocol 

func (x *EnhancedEA) GetProviderRequestedProtocol() string

func (*EnhancedEA) GetProviderRequestedTimestamp 

func (x *EnhancedEA) GetProviderRequestedTimestamp() int64

func (*EnhancedEA) GetRound 

func (x *EnhancedEA) GetRound() int64

func (*EnhancedEA) GetValue 

func (x *EnhancedEA) GetValue() int64

func (*EnhancedEA) ProtoMessage 

func (*EnhancedEA) ProtoMessage()

func (*EnhancedEA) ProtoReflect 

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

func (*EnhancedEA) Reset 

func (x *EnhancedEA) Reset()

func (*EnhancedEA) String 

func (x *EnhancedEA) String() string

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

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.