telem

type AutomationTelemWrapper struct {

	// Types that are assignable to Msg:
	//
	//	*AutomationTelemWrapper_BlockNumber
	//	*AutomationTelemWrapper_NodeVersion
	Msg isAutomationTelemWrapper_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

type AutomationTelemWrapper_BlockNumber struct {
	BlockNumber *BlockNumber `protobuf:"bytes,1,opt,name=block_number,json=blockNumber,proto3,oneof"`
}

type AutomationTelemWrapper_NodeVersion struct {
	NodeVersion *NodeVersion `protobuf:"bytes,2,opt,name=node_version,json=nodeVersion,proto3,oneof"`
}

type BlockNumber struct {
	Timestamp    uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	BlockNumber  uint64 `protobuf:"varint,2,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	BlockHash    string `protobuf:"bytes,3,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	ConfigDigest []byte `protobuf:"bytes,4,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	// contains filtered or unexported fields
}

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
}

type EnhancedEAMercury struct {
	Version          uint32  `protobuf:"varint,32,opt,name=version,proto3" json:"version,omitempty"`
	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"`
	// v1 fields (block range)
	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 */
	// v2+v3 fields (timestamp range)
	FetchMaxFinalizedTimestamp    bool   `` /* 145-byte string literal not displayed */
	MaxFinalizedTimestamp         int64  `` /* 128-byte string literal not displayed */
	ObservationTimestamp          uint32 `protobuf:"varint,27,opt,name=observation_timestamp,json=observationTimestamp,proto3" json:"observation_timestamp,omitempty"`
	IsLinkFeed                    bool   `protobuf:"varint,28,opt,name=is_link_feed,json=isLinkFeed,proto3" json:"is_link_feed,omitempty"`
	LinkPrice                     int64  `protobuf:"varint,29,opt,name=link_price,json=linkPrice,proto3" json:"link_price,omitempty"`
	IsNativeFeed                  bool   `protobuf:"varint,30,opt,name=is_native_feed,json=isNativeFeed,proto3" json:"is_native_feed,omitempty"`
	NativePrice                   int64  `protobuf:"varint,31,opt,name=native_price,json=nativePrice,proto3" json:"native_price,omitempty"`
	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"`
	// v1+v2+v3
	ObservationBenchmarkPrice int64 `` // This value overflows, will be reserved and removed in future versions
	/* 140-byte string literal not displayed */
	ObservationBenchmarkPriceString string `` /* 159-byte string literal not displayed */
	// v1+v3
	ObservationBid       int64  `protobuf:"varint,16,opt,name=observation_bid,json=observationBid,proto3" json:"observation_bid,omitempty"` // This value overflows, will be reserved and removed in future versions
	ObservationAsk       int64  `protobuf:"varint,17,opt,name=observation_ask,json=observationAsk,proto3" json:"observation_ask,omitempty"` // This value overflows, will be reserved and removed in future versions
	ObservationBidString string `protobuf:"bytes,23,opt,name=observation_bid_string,json=observationBidString,proto3" json:"observation_bid_string,omitempty"`
	ObservationAskString string `protobuf:"bytes,24,opt,name=observation_ask_string,json=observationAskString,proto3" json:"observation_ask_string,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
}

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
}

type NodeVersion struct {
	Timestamp    uint64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	NodeVersion  string `protobuf:"bytes,2,opt,name=node_version,json=nodeVersion,proto3" json:"node_version,omitempty"`
	ConfigDigest []byte `protobuf:"bytes,3,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"`
	// contains filtered or unexported fields
}

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
}

type TelemClient interface {
	Telem(ctx context.Context, in *TelemRequest) (*TelemResponse, error)
	TelemBatch(ctx context.Context, in *TelemBatchRequest) (*TelemResponse, error)
}

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
}

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

type TelemServer interface {
	Telem(context.Context, *TelemRequest) (*TelemResponse, error)
	TelemBatch(context.Context, *TelemBatchRequest) (*TelemResponse, error)
}