mercuryv1pb

package
v0.2.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	ReportCodec_BuildReport_FullMethodName               = "/loop.internal.pb.mercury.v1.ReportCodec/BuildReport"
	ReportCodec_MaxReportLength_FullMethodName           = "/loop.internal.pb.mercury.v1.ReportCodec/MaxReportLength"
	ReportCodec_CurrentBlockNumFromReport_FullMethodName = "/loop.internal.pb.mercury.v1.ReportCodec/CurrentBlockNumFromReport"
)
View Source 
const (
	DataSource_Observe_FullMethodName = "/loop.internal.pb.mercury.v1.DataSource/Observe"
)

Variables

View Source 
var DataSource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.v1.DataSource",
	HandlerType: (*DataSourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Observe",
			Handler:    _DataSource_Observe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "datasource_v1.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_v1_proto protoreflect.FileDescriptor
View Source 
var File_reportcodec_v1_proto protoreflect.FileDescriptor
View Source 
var ReportCodec_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.v1.ReportCodec",
	HandlerType: (*ReportCodecServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BuildReport",
			Handler:    _ReportCodec_BuildReport_Handler,
		},
		{
			MethodName: "MaxReportLength",
			Handler:    _ReportCodec_MaxReportLength_Handler,
		},
		{
			MethodName: "CurrentBlockNumFromReport",
			Handler:    _ReportCodec_CurrentBlockNumFromReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "reportcodec_v1.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 github.com/goplugin/plugin-data-streams/mercury/v1/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 github.com/goplugin/plugin-data-streams/mercury/v1/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 CurrentBlockNumFromReportRequest 

type CurrentBlockNumFromReportRequest struct {
	Report []byte `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

CurrentBlockNumFromReportRequest is gRPC adapter for github.com/goplugin/plugin-data-streams/mercury/v1/ReportCodec.CurrentBlockNumFromReport.

func (*CurrentBlockNumFromReportRequest) Descriptor deprecated 

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

Deprecated: Use CurrentBlockNumFromReportRequest.ProtoReflect.Descriptor instead.

func (*CurrentBlockNumFromReportRequest) GetReport 

func (x *CurrentBlockNumFromReportRequest) GetReport() []byte

func (*CurrentBlockNumFromReportRequest) ProtoMessage 

func (*CurrentBlockNumFromReportRequest) ProtoMessage()

func (*CurrentBlockNumFromReportRequest) ProtoReflect 

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

func (*CurrentBlockNumFromReportRequest) Reset 

func (x *CurrentBlockNumFromReportRequest) Reset()

func (*CurrentBlockNumFromReportRequest) String 

func (x *CurrentBlockNumFromReportRequest) String() string

type CurrentBlockNumFromReportResponse 

type CurrentBlockNumFromReportResponse struct {
	CurrentBlockNum int64 `protobuf:"varint,1,opt,name=currentBlockNum,proto3" json:"currentBlockNum,omitempty"`
	// contains filtered or unexported fields
}

CurrentBlockNumFromReportResponse is gRPC adapter for github.com/goplugin/plugin-data-streams/mercury/v1/ReportCodec.CurrentBlockNumFromReport.

func (*CurrentBlockNumFromReportResponse) Descriptor deprecated 

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

Deprecated: Use CurrentBlockNumFromReportResponse.ProtoReflect.Descriptor instead.

func (*CurrentBlockNumFromReportResponse) GetCurrentBlockNum 

func (x *CurrentBlockNumFromReportResponse) GetCurrentBlockNum() int64

func (*CurrentBlockNumFromReportResponse) ProtoMessage 

func (*CurrentBlockNumFromReportResponse) ProtoMessage()

func (*CurrentBlockNumFromReportResponse) ProtoReflect 

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

func (*CurrentBlockNumFromReportResponse) Reset 

func (x *CurrentBlockNumFromReportResponse) Reset()

func (*CurrentBlockNumFromReportResponse) String 

func (x *CurrentBlockNumFromReportResponse) 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 has return arguments for github.com/goplugin/plugin-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 github.com/goplugin/plugin-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"`
	CurrentBlockNum         int64      `protobuf:"varint,4,opt,name=currentBlockNum,proto3" json:"currentBlockNum,omitempty"`
	CurrentBlockHash        []byte     `protobuf:"bytes,5,opt,name=currentBlockHash,proto3" json:"currentBlockHash,omitempty"`
	CurrentBlockTimestamp   uint64     `protobuf:"varint,6,opt,name=currentBlockTimestamp,proto3" json:"currentBlockTimestamp,omitempty"`
	LatestBlocks            []*Block   `protobuf:"bytes,7,rep,name=latestBlocks,proto3" json:"latestBlocks,omitempty"`
	MaxFinalizedBlockNumber int64      `protobuf:"varint,8,opt,name=maxFinalizedBlockNumber,proto3" json:"maxFinalizedBlockNumber,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) GetCurrentBlockHash 

func (x *Observation) GetCurrentBlockHash() []byte

func (*Observation) GetCurrentBlockNum 

func (x *Observation) GetCurrentBlockNum() int64

func (*Observation) GetCurrentBlockTimestamp 

func (x *Observation) GetCurrentBlockTimestamp() uint64

func (*Observation) GetLatestBlocks 

func (x *Observation) GetLatestBlocks() []*Block

func (*Observation) GetMaxFinalizedBlockNumber 

func (x *Observation) GetMaxFinalizedBlockNumber() int64

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 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)
	CurrentBlockNumFromReport(ctx context.Context, in *CurrentBlockNumFromReportRequest, opts ...grpc.CallOption) (*CurrentBlockNumFromReportResponse, 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)
	CurrentBlockNumFromReport(context.Context, *CurrentBlockNumFromReportRequest) (*CurrentBlockNumFromReportResponse, 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 {
	Timestamp             uint32     `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	BenchmarkPrice        *pb.BigInt `protobuf:"bytes,2,opt,name=benchmarkPrice,proto3" json:"benchmarkPrice,omitempty"`
	Bid                   *pb.BigInt `protobuf:"bytes,3,opt,name=bid,proto3" json:"bid,omitempty"`
	Ask                   *pb.BigInt `protobuf:"bytes,4,opt,name=ask,proto3" json:"ask,omitempty"`
	CurrentBlockNum       int64      `protobuf:"varint,5,opt,name=currentBlockNum,proto3" json:"currentBlockNum,omitempty"`
	CurrentBlockHash      []byte     `protobuf:"bytes,6,opt,name=currentBlockHash,proto3" json:"currentBlockHash,omitempty"`
	ValidFromBlockNum     int64      `protobuf:"varint,7,opt,name=validFromBlockNum,proto3" json:"validFromBlockNum,omitempty"`
	CurrentBlockTimestamp uint64     `protobuf:"varint,8,opt,name=currentBlockTimestamp,proto3" json:"currentBlockTimestamp,omitempty"`
	// contains filtered or unexported fields
}

ReportFields is gRPC wrapper for struct github.com/goplugin/plugin-data-streams/mercury/v1/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) GetCurrentBlockHash 

func (x *ReportFields) GetCurrentBlockHash() []byte

func (*ReportFields) GetCurrentBlockNum 

func (x *ReportFields) GetCurrentBlockNum() int64

func (*ReportFields) GetCurrentBlockTimestamp 

func (x *ReportFields) GetCurrentBlockTimestamp() uint64

func (*ReportFields) GetTimestamp 

func (x *ReportFields) GetTimestamp() uint32

func (*ReportFields) GetValidFromBlockNum 

func (x *ReportFields) GetValidFromBlockNum() int64

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) CurrentBlockNumFromReport 

func (UnimplementedReportCodecServer) CurrentBlockNumFromReport(context.Context, *CurrentBlockNumFromReportRequest) (*CurrentBlockNumFromReportResponse, error)

func (UnimplementedReportCodecServer) MaxReportLength 

func (UnimplementedReportCodecServer) MaxReportLength(context.Context, *MaxReportLengthRequest) (*MaxReportLengthReply, 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.