mercuryv3pb

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ReportCodec_BuildReport_FullMethodName                    = "/loop.internal.pb.mercury.v3.ReportCodec/BuildReport"
	ReportCodec_MaxReportLength_FullMethodName                = "/loop.internal.pb.mercury.v3.ReportCodec/MaxReportLength"
	ReportCodec_ObservationTimestampFromReport_FullMethodName = "/loop.internal.pb.mercury.v3.ReportCodec/ObservationTimestampFromReport"
)
View Source 
const (
	DataSource_Observe_FullMethodName = "/loop.internal.pb.mercury.v3.DataSource/Observe"
)

Variables

View Source 
var DataSource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.v3.DataSource",
	HandlerType: (*DataSourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Observe",
			Handler:    _DataSource_Observe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "datasource_v3.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)

View Source 
var File_datasource_v3_proto protoreflect.FileDescriptor
View Source 
var File_reportcodec_v3_proto protoreflect.FileDescriptor
View Source 
var ReportCodec_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.v3.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: "reportcodec_v3.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) Descriptor() ([]byte, []int)

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetHash 

func (x *Block) GetHash() []byte

func (*Block) GetNumber 

func (x *Block) GetNumber() int64

func (*Block) GetTimestamp 

func (x *Block) GetTimestamp() uint64

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) ProtoReflect 

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

func (*Block) Reset 

func (x *Block) Reset()

func (*Block) String 

func (x *Block) String() string

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/v3/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/v3/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.

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

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/v3/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/v3/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"`
	Bid                   *pb.BigInt `protobuf:"bytes,2,opt,name=bid,proto3" json:"bid,omitempty"`
	Ask                   *pb.BigInt `protobuf:"bytes,3,opt,name=ask,proto3" json:"ask,omitempty"`
	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"`
	// 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 

func (x *Observation) GetAsk() *pb.BigInt

func (*Observation) GetBenchmarkPrice 

func (x *Observation) GetBenchmarkPrice() *pb.BigInt

func (*Observation) GetBid 

func (x *Observation) GetBid() *pb.BigInt

func (*Observation) GetLinkPrice 

func (x *Observation) GetLinkPrice() *pb.BigInt

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/v3/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/v3/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.

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

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"`
	Bid                *pb.BigInt `protobuf:"bytes,7,opt,name=bid,proto3" json:"bid,omitempty"`
	Ask                *pb.BigInt `protobuf:"bytes,8,opt,name=ask,proto3" json:"ask,omitempty"`
	// contains filtered or unexported fields
}

ReportFields is a gRPC adapter for the ReportFields struct pkg/types/mercury/v3/ReportFields.

func (*ReportFields) Descriptor deprecated 

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

Deprecated: Use ReportFields.ProtoReflect.Descriptor instead.

func (*ReportFields) GetAsk 

func (x *ReportFields) GetAsk() *pb.BigInt

func (*ReportFields) GetBenchmarkPrice 

func (x *ReportFields) GetBenchmarkPrice() *pb.BigInt

func (*ReportFields) GetBid 

func (x *ReportFields) GetBid() *pb.BigInt

func (*ReportFields) GetExpiresAt 

func (x *ReportFields) GetExpiresAt() uint32

func (*ReportFields) GetLinkFee 

func (x *ReportFields) GetLinkFee() *pb.BigInt

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.

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.

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.

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.