Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterDataSourceServer(s grpc.ServiceRegistrar, srv DataSourceServer)
- func RegisterReportCodecServer(s grpc.ServiceRegistrar, srv ReportCodecServer)
- type Block
- type BuildReportReply
- type BuildReportRequest
- func (*BuildReportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BuildReportRequest) GetReportFields() *ReportFields
- func (*BuildReportRequest) ProtoMessage()
- func (x *BuildReportRequest) ProtoReflect() protoreflect.Message
- func (x *BuildReportRequest) Reset()
- func (x *BuildReportRequest) String() string
- type DataSourceClient
- type DataSourceServer
- type MaxReportLengthReply
- func (*MaxReportLengthReply) Descriptor() ([]byte, []int)deprecated
- func (x *MaxReportLengthReply) GetMaxReportLength() uint64
- func (*MaxReportLengthReply) ProtoMessage()
- func (x *MaxReportLengthReply) ProtoReflect() protoreflect.Message
- func (x *MaxReportLengthReply) Reset()
- func (x *MaxReportLengthReply) String() string
- type MaxReportLengthRequest
- func (*MaxReportLengthRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MaxReportLengthRequest) GetNumOracles() uint64
- func (*MaxReportLengthRequest) ProtoMessage()
- func (x *MaxReportLengthRequest) ProtoReflect() protoreflect.Message
- func (x *MaxReportLengthRequest) Reset()
- func (x *MaxReportLengthRequest) String() string
- type Observation
- func (*Observation) Descriptor() ([]byte, []int)deprecated
- func (x *Observation) GetAsk() *pb.BigIntdeprecated
- func (x *Observation) GetBenchmarkPrice() *pb.BigInt
- func (x *Observation) GetBid() *pb.BigIntdeprecated
- func (x *Observation) GetLinkPrice() *pb.BigInt
- func (x *Observation) GetMarketStatus() uint32
- func (x *Observation) GetMaxFinalizedTimestamp() int64
- func (x *Observation) GetNativePrice() *pb.BigInt
- func (*Observation) ProtoMessage()
- func (x *Observation) ProtoReflect() protoreflect.Message
- func (x *Observation) Reset()
- func (x *Observation) String() string
- type ObservationTimestampFromReportReply
- func (*ObservationTimestampFromReportReply) Descriptor() ([]byte, []int)deprecated
- func (x *ObservationTimestampFromReportReply) GetTimestamp() uint32
- func (*ObservationTimestampFromReportReply) ProtoMessage()
- func (x *ObservationTimestampFromReportReply) ProtoReflect() protoreflect.Message
- func (x *ObservationTimestampFromReportReply) Reset()
- func (x *ObservationTimestampFromReportReply) String() string
- type ObservationTimestampFromReportRequest
- func (*ObservationTimestampFromReportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ObservationTimestampFromReportRequest) GetReport() []byte
- func (*ObservationTimestampFromReportRequest) ProtoMessage()
- func (x *ObservationTimestampFromReportRequest) ProtoReflect() protoreflect.Message
- func (x *ObservationTimestampFromReportRequest) Reset()
- func (x *ObservationTimestampFromReportRequest) String() string
- type ObserveRequest
- func (*ObserveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ObserveRequest) GetFetchMaxFinalizedBlockNum() bool
- func (x *ObserveRequest) GetReportTimestamp() *pb.ReportTimestamp
- func (*ObserveRequest) ProtoMessage()
- func (x *ObserveRequest) ProtoReflect() protoreflect.Message
- func (x *ObserveRequest) Reset()
- func (x *ObserveRequest) String() string
- type ObserveResponse
- type ReportCodecClient
- type ReportCodecServer
- type ReportFields
- func (*ReportFields) Descriptor() ([]byte, []int)deprecated
- func (x *ReportFields) GetAsk() *pb.BigIntdeprecated
- func (x *ReportFields) GetBenchmarkPrice() *pb.BigInt
- func (x *ReportFields) GetBid() *pb.BigIntdeprecated
- func (x *ReportFields) GetExpiresAt() uint32
- func (x *ReportFields) GetLinkFee() *pb.BigInt
- func (x *ReportFields) GetMarketStatus() uint32
- func (x *ReportFields) GetNativeFee() *pb.BigInt
- func (x *ReportFields) GetTimestamp() uint32
- func (x *ReportFields) GetValidFromTimestamp() uint32
- func (*ReportFields) ProtoMessage()
- func (x *ReportFields) ProtoReflect() protoreflect.Message
- func (x *ReportFields) Reset()
- func (x *ReportFields) String() string
- type UnimplementedDataSourceServer
- type UnimplementedReportCodecServer
- func (UnimplementedReportCodecServer) BuildReport(context.Context, *BuildReportRequest) (*BuildReportReply, error)
- func (UnimplementedReportCodecServer) MaxReportLength(context.Context, *MaxReportLengthRequest) (*MaxReportLengthReply, error)
- func (UnimplementedReportCodecServer) ObservationTimestampFromReport(context.Context, *ObservationTimestampFromReportRequest) (*ObservationTimestampFromReportReply, error)
- type UnsafeDataSourceServer
- type UnsafeReportCodecServer
Constants ¶
const ( ReportCodec_BuildReport_FullMethodName = "/loop.internal.pb.mercury.v4.ReportCodec/BuildReport" ReportCodec_MaxReportLength_FullMethodName = "/loop.internal.pb.mercury.v4.ReportCodec/MaxReportLength" ReportCodec_ObservationTimestampFromReport_FullMethodName = "/loop.internal.pb.mercury.v4.ReportCodec/ObservationTimestampFromReport" )
const (
DataSource_Observe_FullMethodName = "/loop.internal.pb.mercury.v4.DataSource/Observe"
)
Variables ¶
var DataSource_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loop.internal.pb.mercury.v4.DataSource", HandlerType: (*DataSourceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Observe", Handler: _DataSource_Observe_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "loop/internal/pb/mercury/v4/datasource_v4.proto", }
DataSource_ServiceDesc is the grpc.ServiceDesc for DataSource service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_loop_internal_pb_mercury_v4_datasource_v4_proto protoreflect.FileDescriptor
var File_loop_internal_pb_mercury_v4_reportcodec_v4_proto protoreflect.FileDescriptor
var ReportCodec_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loop.internal.pb.mercury.v4.ReportCodec", HandlerType: (*ReportCodecServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "BuildReport", Handler: _ReportCodec_BuildReport_Handler, }, { MethodName: "MaxReportLength", Handler: _ReportCodec_MaxReportLength_Handler, }, { MethodName: "ObservationTimestampFromReport", Handler: _ReportCodec_ObservationTimestampFromReport_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "loop/internal/pb/mercury/v4/reportcodec_v4.proto", }
ReportCodec_ServiceDesc is the grpc.ServiceDesc for ReportCodec service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterDataSourceServer ¶
func RegisterDataSourceServer(s grpc.ServiceRegistrar, srv DataSourceServer)
func RegisterReportCodecServer ¶
func RegisterReportCodecServer(s grpc.ServiceRegistrar, srv ReportCodecServer)
Types ¶
type Block ¶
type Block struct { Number int64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"` Hash []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"` Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
Block is a gRPC adapter for pkg/types/mercury/v1/Block
func (*Block) Descriptor
deprecated
func (*Block) GetTimestamp ¶
func (*Block) ProtoMessage ¶
func (*Block) ProtoMessage()
func (*Block) ProtoReflect ¶
func (x *Block) ProtoReflect() protoreflect.Message
type BuildReportReply ¶
type BuildReportReply struct { Report []byte `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"` // contains filtered or unexported fields }
BuildReportReply is gRPC adapter for the return values of pkg/types/mercury/v4/ReportCodec.BuildReport.
func (*BuildReportReply) Descriptor
deprecated
func (*BuildReportReply) Descriptor() ([]byte, []int)
Deprecated: Use BuildReportReply.ProtoReflect.Descriptor instead.
func (*BuildReportReply) GetReport ¶
func (x *BuildReportReply) GetReport() []byte
func (*BuildReportReply) ProtoMessage ¶
func (*BuildReportReply) ProtoMessage()
func (*BuildReportReply) ProtoReflect ¶
func (x *BuildReportReply) ProtoReflect() protoreflect.Message
func (*BuildReportReply) Reset ¶
func (x *BuildReportReply) Reset()
func (*BuildReportReply) String ¶
func (x *BuildReportReply) String() string
type BuildReportRequest ¶
type BuildReportRequest struct { ReportFields *ReportFields `protobuf:"bytes,1,opt,name=reportFields,proto3" json:"reportFields,omitempty"` // contains filtered or unexported fields }
BuildReportRequest is gRPC adapter for the inputs arguments of pkg/types/mercury/v4/ReportCodec.BuildReport.
func (*BuildReportRequest) Descriptor
deprecated
func (*BuildReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use BuildReportRequest.ProtoReflect.Descriptor instead.
func (*BuildReportRequest) GetReportFields ¶
func (x *BuildReportRequest) GetReportFields() *ReportFields
func (*BuildReportRequest) ProtoMessage ¶
func (*BuildReportRequest) ProtoMessage()
func (*BuildReportRequest) ProtoReflect ¶
func (x *BuildReportRequest) ProtoReflect() protoreflect.Message
func (*BuildReportRequest) Reset ¶
func (x *BuildReportRequest) Reset()
func (*BuildReportRequest) String ¶
func (x *BuildReportRequest) String() string
type DataSourceClient ¶
type DataSourceClient interface {
Observe(ctx context.Context, in *ObserveRequest, opts ...grpc.CallOption) (*ObserveResponse, error)
}
DataSourceClient is the client API for DataSource service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
DataSource is a gRPC adapter for pkg/types/mercury/v1/DataSource
func NewDataSourceClient ¶
func NewDataSourceClient(cc grpc.ClientConnInterface) DataSourceClient
type DataSourceServer ¶
type DataSourceServer interface { Observe(context.Context, *ObserveRequest) (*ObserveResponse, error) // contains filtered or unexported methods }
DataSourceServer is the server API for DataSource service. All implementations must embed UnimplementedDataSourceServer for forward compatibility.
DataSource is a gRPC adapter for pkg/types/mercury/v1/DataSource
type MaxReportLengthReply ¶
type MaxReportLengthReply struct { MaxReportLength uint64 `protobuf:"varint,1,opt,name=maxReportLength,proto3" json:"maxReportLength,omitempty"` // contains filtered or unexported fields }
MaxReportLengthReply is gRPC adapter for the return values of github.com/smartcontractkit/chainlink-data-streams/mercury/v4/ReportCodec.MaxReportLength.
func (*MaxReportLengthReply) Descriptor
deprecated
func (*MaxReportLengthReply) Descriptor() ([]byte, []int)
Deprecated: Use MaxReportLengthReply.ProtoReflect.Descriptor instead.
func (*MaxReportLengthReply) GetMaxReportLength ¶
func (x *MaxReportLengthReply) GetMaxReportLength() uint64
func (*MaxReportLengthReply) ProtoMessage ¶
func (*MaxReportLengthReply) ProtoMessage()
func (*MaxReportLengthReply) ProtoReflect ¶
func (x *MaxReportLengthReply) ProtoReflect() protoreflect.Message
func (*MaxReportLengthReply) Reset ¶
func (x *MaxReportLengthReply) Reset()
func (*MaxReportLengthReply) String ¶
func (x *MaxReportLengthReply) String() string
type MaxReportLengthRequest ¶
type MaxReportLengthRequest struct { NumOracles uint64 `protobuf:"varint,1,opt,name=numOracles,proto3" json:"numOracles,omitempty"` // contains filtered or unexported fields }
MaxReportLengthRequest is gRPC adapter for the input arguments of github.com/smartcontractkit/chainlink-data-streams/mercury/v4/ReportCodec.MaxReportLength.
func (*MaxReportLengthRequest) Descriptor
deprecated
func (*MaxReportLengthRequest) Descriptor() ([]byte, []int)
Deprecated: Use MaxReportLengthRequest.ProtoReflect.Descriptor instead.
func (*MaxReportLengthRequest) GetNumOracles ¶
func (x *MaxReportLengthRequest) GetNumOracles() uint64
func (*MaxReportLengthRequest) ProtoMessage ¶
func (*MaxReportLengthRequest) ProtoMessage()
func (*MaxReportLengthRequest) ProtoReflect ¶
func (x *MaxReportLengthRequest) ProtoReflect() protoreflect.Message
func (*MaxReportLengthRequest) Reset ¶
func (x *MaxReportLengthRequest) Reset()
func (*MaxReportLengthRequest) String ¶
func (x *MaxReportLengthRequest) String() string
type Observation ¶
type Observation struct { BenchmarkPrice *pb.BigInt `protobuf:"bytes,1,opt,name=benchmarkPrice,proto3" json:"benchmarkPrice,omitempty"` // Deprecated: Marked as deprecated in loop/internal/pb/mercury/v4/datasource_v4.proto. Bid *pb.BigInt `protobuf:"bytes,2,opt,name=bid,proto3" json:"bid,omitempty"` // Field not used for v4. // Deprecated: Marked as deprecated in loop/internal/pb/mercury/v4/datasource_v4.proto. Ask *pb.BigInt `protobuf:"bytes,3,opt,name=ask,proto3" json:"ask,omitempty"` // Field not used for v4. MaxFinalizedTimestamp int64 `protobuf:"varint,4,opt,name=maxFinalizedTimestamp,proto3" json:"maxFinalizedTimestamp,omitempty"` LinkPrice *pb.BigInt `protobuf:"bytes,5,opt,name=linkPrice,proto3" json:"linkPrice,omitempty"` NativePrice *pb.BigInt `protobuf:"bytes,6,opt,name=nativePrice,proto3" json:"nativePrice,omitempty"` MarketStatus uint32 `protobuf:"varint,7,opt,name=marketStatus,proto3" json:"marketStatus,omitempty"` // contains filtered or unexported fields }
Observation is a gRPC adapter for pkg/types/mercury/v1/Observation
func (*Observation) Descriptor
deprecated
func (*Observation) Descriptor() ([]byte, []int)
Deprecated: Use Observation.ProtoReflect.Descriptor instead.
func (*Observation) GetAsk
deprecated
func (x *Observation) GetAsk() *pb.BigInt
Deprecated: Marked as deprecated in loop/internal/pb/mercury/v4/datasource_v4.proto.
func (*Observation) GetBenchmarkPrice ¶
func (x *Observation) GetBenchmarkPrice() *pb.BigInt
func (*Observation) GetBid
deprecated
func (x *Observation) GetBid() *pb.BigInt
Deprecated: Marked as deprecated in loop/internal/pb/mercury/v4/datasource_v4.proto.
func (*Observation) GetLinkPrice ¶
func (x *Observation) GetLinkPrice() *pb.BigInt
func (*Observation) GetMarketStatus ¶
func (x *Observation) GetMarketStatus() uint32
func (*Observation) GetMaxFinalizedTimestamp ¶
func (x *Observation) GetMaxFinalizedTimestamp() int64
func (*Observation) GetNativePrice ¶
func (x *Observation) GetNativePrice() *pb.BigInt
func (*Observation) ProtoMessage ¶
func (*Observation) ProtoMessage()
func (*Observation) ProtoReflect ¶
func (x *Observation) ProtoReflect() protoreflect.Message
func (*Observation) Reset ¶
func (x *Observation) Reset()
func (*Observation) String ¶
func (x *Observation) String() string
type ObservationTimestampFromReportReply ¶
type ObservationTimestampFromReportReply struct { Timestamp uint32 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
ObservationTimestampFromReportReply is gRPC adapter for the return values of github.com/smartcontractkit/chainlink-data-streams/mercury/v4/ReportCodec.ObservationTimestampFromReport.
func (*ObservationTimestampFromReportReply) Descriptor
deprecated
func (*ObservationTimestampFromReportReply) Descriptor() ([]byte, []int)
Deprecated: Use ObservationTimestampFromReportReply.ProtoReflect.Descriptor instead.
func (*ObservationTimestampFromReportReply) GetTimestamp ¶
func (x *ObservationTimestampFromReportReply) GetTimestamp() uint32
func (*ObservationTimestampFromReportReply) ProtoMessage ¶
func (*ObservationTimestampFromReportReply) ProtoMessage()
func (*ObservationTimestampFromReportReply) ProtoReflect ¶
func (x *ObservationTimestampFromReportReply) ProtoReflect() protoreflect.Message
func (*ObservationTimestampFromReportReply) Reset ¶
func (x *ObservationTimestampFromReportReply) Reset()
func (*ObservationTimestampFromReportReply) String ¶
func (x *ObservationTimestampFromReportReply) String() string
type ObservationTimestampFromReportRequest ¶
type ObservationTimestampFromReportRequest struct { Report []byte `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"` // contains filtered or unexported fields }
ObservationTimestampFromReportRequest is gRPC adapter for the input arguments github.com/smartcontractkit/chainlink-data-streams/mercury/v4/ReportCodec.ObservationTimestampFromReport.
func (*ObservationTimestampFromReportRequest) Descriptor
deprecated
func (*ObservationTimestampFromReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ObservationTimestampFromReportRequest.ProtoReflect.Descriptor instead.
func (*ObservationTimestampFromReportRequest) GetReport ¶
func (x *ObservationTimestampFromReportRequest) GetReport() []byte
func (*ObservationTimestampFromReportRequest) ProtoMessage ¶
func (*ObservationTimestampFromReportRequest) ProtoMessage()
func (*ObservationTimestampFromReportRequest) ProtoReflect ¶
func (x *ObservationTimestampFromReportRequest) ProtoReflect() protoreflect.Message
func (*ObservationTimestampFromReportRequest) Reset ¶
func (x *ObservationTimestampFromReportRequest) Reset()
func (*ObservationTimestampFromReportRequest) String ¶
func (x *ObservationTimestampFromReportRequest) String() string
type ObserveRequest ¶
type ObserveRequest struct { ReportTimestamp *pb.ReportTimestamp `protobuf:"bytes,1,opt,name=report_timestamp,json=reportTimestamp,proto3" json:"report_timestamp,omitempty"` FetchMaxFinalizedBlockNum bool `protobuf:"varint,2,opt,name=fetchMaxFinalizedBlockNum,proto3" json:"fetchMaxFinalizedBlockNum,omitempty"` // contains filtered or unexported fields }
ObserveRequest is the request payload for the Observe method, which is a gRPC adapter for input arguments of pkg/types/mercury/v1/DataSource.Observe
func (*ObserveRequest) Descriptor
deprecated
func (*ObserveRequest) Descriptor() ([]byte, []int)
Deprecated: Use ObserveRequest.ProtoReflect.Descriptor instead.
func (*ObserveRequest) GetFetchMaxFinalizedBlockNum ¶
func (x *ObserveRequest) GetFetchMaxFinalizedBlockNum() bool
func (*ObserveRequest) GetReportTimestamp ¶
func (x *ObserveRequest) GetReportTimestamp() *pb.ReportTimestamp
func (*ObserveRequest) ProtoMessage ¶
func (*ObserveRequest) ProtoMessage()
func (*ObserveRequest) ProtoReflect ¶
func (x *ObserveRequest) ProtoReflect() protoreflect.Message
func (*ObserveRequest) Reset ¶
func (x *ObserveRequest) Reset()
func (*ObserveRequest) String ¶
func (x *ObserveRequest) String() string
type ObserveResponse ¶
type ObserveResponse struct { Observation *Observation `protobuf:"bytes,1,opt,name=observation,proto3" json:"observation,omitempty"` // contains filtered or unexported fields }
ObserveResponse is the response payload for the Observe method, which is a gRPC adapter for output arguments of pkg/types/mercury/v1/DataSource.Observe
func (*ObserveResponse) Descriptor
deprecated
func (*ObserveResponse) Descriptor() ([]byte, []int)
Deprecated: Use ObserveResponse.ProtoReflect.Descriptor instead.
func (*ObserveResponse) GetObservation ¶
func (x *ObserveResponse) GetObservation() *Observation
func (*ObserveResponse) ProtoMessage ¶
func (*ObserveResponse) ProtoMessage()
func (*ObserveResponse) ProtoReflect ¶
func (x *ObserveResponse) ProtoReflect() protoreflect.Message
func (*ObserveResponse) Reset ¶
func (x *ObserveResponse) Reset()
func (*ObserveResponse) String ¶
func (x *ObserveResponse) String() string
type ReportCodecClient ¶
type ReportCodecClient interface { BuildReport(ctx context.Context, in *BuildReportRequest, opts ...grpc.CallOption) (*BuildReportReply, error) MaxReportLength(ctx context.Context, in *MaxReportLengthRequest, opts ...grpc.CallOption) (*MaxReportLengthReply, error) ObservationTimestampFromReport(ctx context.Context, in *ObservationTimestampFromReportRequest, opts ...grpc.CallOption) (*ObservationTimestampFromReportReply, error) }
ReportCodecClient is the client API for ReportCodec service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
ReportCodec is a gRPC adapter for the ReportCodec interface pkg/types/mercury/v4/ReportCodec. NOTE: MaxReport and ObservationTimestampFromReport are common amongst all mercury versions, but BuildReport is not. in principle they could be refactor to be shared, but it's not clear if that's worth the effort.
func NewReportCodecClient ¶
func NewReportCodecClient(cc grpc.ClientConnInterface) ReportCodecClient
type ReportCodecServer ¶
type ReportCodecServer interface { BuildReport(context.Context, *BuildReportRequest) (*BuildReportReply, error) MaxReportLength(context.Context, *MaxReportLengthRequest) (*MaxReportLengthReply, error) ObservationTimestampFromReport(context.Context, *ObservationTimestampFromReportRequest) (*ObservationTimestampFromReportReply, error) // contains filtered or unexported methods }
ReportCodecServer is the server API for ReportCodec service. All implementations must embed UnimplementedReportCodecServer for forward compatibility.
ReportCodec is a gRPC adapter for the ReportCodec interface pkg/types/mercury/v4/ReportCodec. NOTE: MaxReport and ObservationTimestampFromReport are common amongst all mercury versions, but BuildReport is not. in principle they could be refactor to be shared, but it's not clear if that's worth the effort.
type ReportFields ¶
type ReportFields struct { ValidFromTimestamp uint32 `protobuf:"varint,1,opt,name=validFromTimestamp,proto3" json:"validFromTimestamp,omitempty"` Timestamp uint32 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` NativeFee *pb.BigInt `protobuf:"bytes,3,opt,name=nativeFee,proto3" json:"nativeFee,omitempty"` LinkFee *pb.BigInt `protobuf:"bytes,4,opt,name=linkFee,proto3" json:"linkFee,omitempty"` ExpiresAt uint32 `protobuf:"varint,5,opt,name=expiresAt,proto3" json:"expiresAt,omitempty"` BenchmarkPrice *pb.BigInt `protobuf:"bytes,6,opt,name=benchmarkPrice,proto3" json:"benchmarkPrice,omitempty"` // Deprecated: Marked as deprecated in loop/internal/pb/mercury/v4/reportcodec_v4.proto. Bid *pb.BigInt `protobuf:"bytes,7,opt,name=bid,proto3" json:"bid,omitempty"` // Field not used for v4. // Deprecated: Marked as deprecated in loop/internal/pb/mercury/v4/reportcodec_v4.proto. Ask *pb.BigInt `protobuf:"bytes,8,opt,name=ask,proto3" json:"ask,omitempty"` // Field not used for v4. MarketStatus uint32 `protobuf:"varint,9,opt,name=marketStatus,proto3" json:"marketStatus,omitempty"` // contains filtered or unexported fields }
ReportFields is a gRPC adapter for the ReportFields struct pkg/types/mercury/v4/ReportFields.
func (*ReportFields) Descriptor
deprecated
func (*ReportFields) Descriptor() ([]byte, []int)
Deprecated: Use ReportFields.ProtoReflect.Descriptor instead.
func (*ReportFields) GetAsk
deprecated
func (x *ReportFields) GetAsk() *pb.BigInt
Deprecated: Marked as deprecated in loop/internal/pb/mercury/v4/reportcodec_v4.proto.
func (*ReportFields) GetBenchmarkPrice ¶
func (x *ReportFields) GetBenchmarkPrice() *pb.BigInt
func (*ReportFields) GetBid
deprecated
func (x *ReportFields) GetBid() *pb.BigInt
Deprecated: Marked as deprecated in loop/internal/pb/mercury/v4/reportcodec_v4.proto.
func (*ReportFields) GetExpiresAt ¶
func (x *ReportFields) GetExpiresAt() uint32
func (*ReportFields) GetLinkFee ¶
func (x *ReportFields) GetLinkFee() *pb.BigInt
func (*ReportFields) GetMarketStatus ¶
func (x *ReportFields) GetMarketStatus() uint32
func (*ReportFields) GetNativeFee ¶
func (x *ReportFields) GetNativeFee() *pb.BigInt
func (*ReportFields) GetTimestamp ¶
func (x *ReportFields) GetTimestamp() uint32
func (*ReportFields) GetValidFromTimestamp ¶
func (x *ReportFields) GetValidFromTimestamp() uint32
func (*ReportFields) ProtoMessage ¶
func (*ReportFields) ProtoMessage()
func (*ReportFields) ProtoReflect ¶
func (x *ReportFields) ProtoReflect() protoreflect.Message
func (*ReportFields) Reset ¶
func (x *ReportFields) Reset()
func (*ReportFields) String ¶
func (x *ReportFields) String() string
type UnimplementedDataSourceServer ¶
type UnimplementedDataSourceServer struct{}
UnimplementedDataSourceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedDataSourceServer) Observe ¶
func (UnimplementedDataSourceServer) Observe(context.Context, *ObserveRequest) (*ObserveResponse, error)
type UnimplementedReportCodecServer ¶
type UnimplementedReportCodecServer struct{}
UnimplementedReportCodecServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedReportCodecServer) BuildReport ¶
func (UnimplementedReportCodecServer) BuildReport(context.Context, *BuildReportRequest) (*BuildReportReply, error)
func (UnimplementedReportCodecServer) MaxReportLength ¶
func (UnimplementedReportCodecServer) MaxReportLength(context.Context, *MaxReportLengthRequest) (*MaxReportLengthReply, error)
func (UnimplementedReportCodecServer) ObservationTimestampFromReport ¶
func (UnimplementedReportCodecServer) ObservationTimestampFromReport(context.Context, *ObservationTimestampFromReportRequest) (*ObservationTimestampFromReportReply, error)
type UnsafeDataSourceServer ¶
type UnsafeDataSourceServer interface {
// contains filtered or unexported methods
}
UnsafeDataSourceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataSourceServer will result in compilation errors.
type UnsafeReportCodecServer ¶
type UnsafeReportCodecServer interface {
// contains filtered or unexported methods
}
UnsafeReportCodecServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReportCodecServer will result in compilation errors.