telem

package
v2.2.0-clf-20230607 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 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_enhanced_ea_proto protoreflect.FileDescriptor
View Source 
var File_core_services_synchronization_telem_telem_proto protoreflect.FileDescriptor
View Source 
var File_telem_enhanced_ea_mercury_proto protoreflect.FileDescriptor
View Source 
var File_telem_functions_request_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                         float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	BridgeTaskRunStartedTimestamp int64   `` /* 155-byte string literal not displayed */
	BridgeTaskRunEndedTimestamp   int64   `` /* 149-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 */
	ProviderIndicatedTime         int64   `` /* 127-byte string literal not displayed */
	Feed                          string  `protobuf:"bytes,9,opt,name=feed,proto3" json:"feed,omitempty"`
	ChainId                       string  `protobuf:"bytes,10,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	Observation                   int64   `protobuf:"varint,11,opt,name=observation,proto3" json:"observation,omitempty"`
	ConfigDigest                  string  `protobuf:"bytes,12,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	Round                         int64   `protobuf:"varint,13,opt,name=round,proto3" json:"round,omitempty"`
	Epoch                         int64   `protobuf:"varint,14,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) GetProviderDataStreamEstablished 

func (x *EnhancedEA) GetProviderDataStreamEstablished() int64

func (*EnhancedEA) GetProviderIndicatedTime 

func (x *EnhancedEA) GetProviderIndicatedTime() int64

func (*EnhancedEA) GetProviderReceivedTimestamp 

func (x *EnhancedEA) GetProviderReceivedTimestamp() int64

func (*EnhancedEA) GetProviderRequestedTimestamp 

func (x *EnhancedEA) GetProviderRequestedTimestamp() int64

func (*EnhancedEA) GetRound 

func (x *EnhancedEA) GetRound() int64

func (*EnhancedEA) GetValue 

func (x *EnhancedEA) GetValue() float64

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 EnhancedEAMercury added in v2.2.0 

type EnhancedEAMercury struct {
	DataSource                    string  `protobuf:"bytes,1,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	DpBenchmarkPrice              float64 `protobuf:"fixed64,2,opt,name=dp_benchmark_price,json=dpBenchmarkPrice,proto3" json:"dp_benchmark_price,omitempty"`
	DpBid                         float64 `protobuf:"fixed64,3,opt,name=dp_bid,json=dpBid,proto3" json:"dp_bid,omitempty"`
	DpAsk                         float64 `protobuf:"fixed64,4,opt,name=dp_ask,json=dpAsk,proto3" json:"dp_ask,omitempty"`
	CurrentBlockNumber            int64   `protobuf:"varint,5,opt,name=current_block_number,json=currentBlockNumber,proto3" json:"current_block_number,omitempty"`
	CurrentBlockHash              string  `protobuf:"bytes,6,opt,name=current_block_hash,json=currentBlockHash,proto3" json:"current_block_hash,omitempty"`
	CurrentBlockTimestamp         uint64  `` /* 127-byte string literal not displayed */
	BridgeTaskRunStartedTimestamp int64   `` /* 155-byte string literal not displayed */
	BridgeTaskRunEndedTimestamp   int64   `` /* 149-byte string literal not displayed */
	ProviderRequestedTimestamp    int64   `` /* 143-byte string literal not displayed */
	ProviderReceivedTimestamp     int64   `` /* 140-byte string literal not displayed */
	ProviderDataStreamEstablished int64   `` /* 154-byte string literal not displayed */
	ProviderIndicatedTime         int64   `` /* 128-byte string literal not displayed */
	Feed                          string  `protobuf:"bytes,14,opt,name=feed,proto3" json:"feed,omitempty"`
	ObservationBenchmarkPrice     int64   `` /* 140-byte string literal not displayed */
	ObservationBid                int64   `protobuf:"varint,16,opt,name=observation_bid,json=observationBid,proto3" json:"observation_bid,omitempty"`
	ObservationAsk                int64   `protobuf:"varint,17,opt,name=observation_ask,json=observationAsk,proto3" json:"observation_ask,omitempty"`
	ConfigDigest                  string  `protobuf:"bytes,18,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	Round                         int64   `protobuf:"varint,19,opt,name=round,proto3" json:"round,omitempty"`
	Epoch                         int64   `protobuf:"varint,20,opt,name=epoch,proto3" json:"epoch,omitempty"`
	AssetSymbol                   string  `protobuf:"bytes,21,opt,name=asset_symbol,json=assetSymbol,proto3" json:"asset_symbol,omitempty"`
	// contains filtered or unexported fields
}

func (*EnhancedEAMercury) Descriptor deprecated added in v2.2.0 

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

Deprecated: Use EnhancedEAMercury.ProtoReflect.Descriptor instead.

func (*EnhancedEAMercury) GetAssetSymbol added in v2.2.0 

func (x *EnhancedEAMercury) GetAssetSymbol() string

func (*EnhancedEAMercury) GetBridgeTaskRunEndedTimestamp added in v2.2.0 

func (x *EnhancedEAMercury) GetBridgeTaskRunEndedTimestamp() int64

func (*EnhancedEAMercury) GetBridgeTaskRunStartedTimestamp added in v2.2.0 

func (x *EnhancedEAMercury) GetBridgeTaskRunStartedTimestamp() int64

func (*EnhancedEAMercury) GetConfigDigest added in v2.2.0 

func (x *EnhancedEAMercury) GetConfigDigest() string

func (*EnhancedEAMercury) GetCurrentBlockHash added in v2.2.0 

func (x *EnhancedEAMercury) GetCurrentBlockHash() string

func (*EnhancedEAMercury) GetCurrentBlockNumber added in v2.2.0 

func (x *EnhancedEAMercury) GetCurrentBlockNumber() int64

func (*EnhancedEAMercury) GetCurrentBlockTimestamp added in v2.2.0 

func (x *EnhancedEAMercury) GetCurrentBlockTimestamp() uint64

func (*EnhancedEAMercury) GetDataSource added in v2.2.0 

func (x *EnhancedEAMercury) GetDataSource() string

func (*EnhancedEAMercury) GetDpAsk added in v2.2.0 

func (x *EnhancedEAMercury) GetDpAsk() float64

func (*EnhancedEAMercury) GetDpBenchmarkPrice added in v2.2.0 

func (x *EnhancedEAMercury) GetDpBenchmarkPrice() float64

func (*EnhancedEAMercury) GetDpBid added in v2.2.0 

func (x *EnhancedEAMercury) GetDpBid() float64

func (*EnhancedEAMercury) GetEpoch added in v2.2.0 

func (x *EnhancedEAMercury) GetEpoch() int64

func (*EnhancedEAMercury) GetFeed added in v2.2.0 

func (x *EnhancedEAMercury) GetFeed() string

func (*EnhancedEAMercury) GetObservationAsk added in v2.2.0 

func (x *EnhancedEAMercury) GetObservationAsk() int64

func (*EnhancedEAMercury) GetObservationBenchmarkPrice added in v2.2.0 

func (x *EnhancedEAMercury) GetObservationBenchmarkPrice() int64

func (*EnhancedEAMercury) GetObservationBid added in v2.2.0 

func (x *EnhancedEAMercury) GetObservationBid() int64

func (*EnhancedEAMercury) GetProviderDataStreamEstablished added in v2.2.0 

func (x *EnhancedEAMercury) GetProviderDataStreamEstablished() int64

func (*EnhancedEAMercury) GetProviderIndicatedTime added in v2.2.0 

func (x *EnhancedEAMercury) GetProviderIndicatedTime() int64

func (*EnhancedEAMercury) GetProviderReceivedTimestamp added in v2.2.0 

func (x *EnhancedEAMercury) GetProviderReceivedTimestamp() int64

func (*EnhancedEAMercury) GetProviderRequestedTimestamp added in v2.2.0 

func (x *EnhancedEAMercury) GetProviderRequestedTimestamp() int64

func (*EnhancedEAMercury) GetRound added in v2.2.0 

func (x *EnhancedEAMercury) GetRound() int64

func (*EnhancedEAMercury) ProtoMessage added in v2.2.0 

func (*EnhancedEAMercury) ProtoMessage()

func (*EnhancedEAMercury) ProtoReflect added in v2.2.0 

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

func (*EnhancedEAMercury) Reset added in v2.2.0 

func (x *EnhancedEAMercury) Reset()

func (*EnhancedEAMercury) String added in v2.2.0 

func (x *EnhancedEAMercury) String() string

type FunctionsRequest added in v2.2.0 

type FunctionsRequest struct {
	RequestId   string   `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	NodeAddress string   `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	Domains     []string `protobuf:"bytes,3,rep,name=domains,proto3" json:"domains,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionsRequest) Descriptor deprecated added in v2.2.0 

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

Deprecated: Use FunctionsRequest.ProtoReflect.Descriptor instead.

func (*FunctionsRequest) GetDomains added in v2.2.0 

func (x *FunctionsRequest) GetDomains() []string

func (*FunctionsRequest) GetNodeAddress added in v2.2.0 

func (x *FunctionsRequest) GetNodeAddress() string

func (*FunctionsRequest) GetRequestId added in v2.2.0 

func (x *FunctionsRequest) GetRequestId() string

func (*FunctionsRequest) ProtoMessage added in v2.2.0 

func (*FunctionsRequest) ProtoMessage()

func (*FunctionsRequest) ProtoReflect added in v2.2.0 

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

func (*FunctionsRequest) Reset added in v2.2.0 

func (x *FunctionsRequest) Reset()

func (*FunctionsRequest) String added in v2.2.0 

func (x *FunctionsRequest) 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.