Documentation ¶
Index ¶
- Variables
- func RegisterMercuryServer(s wsrpc.ServiceRegistrar, srv MercuryServer)
- type LatestReportRequest
- func (*LatestReportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LatestReportRequest) GetFeedId() []byte
- func (*LatestReportRequest) ProtoMessage()
- func (x *LatestReportRequest) ProtoReflect() protoreflect.Message
- func (x *LatestReportRequest) Reset()
- func (x *LatestReportRequest) String() string
- type LatestReportResponse
- func (*LatestReportResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LatestReportResponse) GetError() string
- func (x *LatestReportResponse) GetReport() *Report
- func (*LatestReportResponse) ProtoMessage()
- func (x *LatestReportResponse) ProtoReflect() protoreflect.Message
- func (x *LatestReportResponse) Reset()
- func (x *LatestReportResponse) String() string
- type MercuryClient
- type MercuryServer
- type Report
- func (*Report) Descriptor() ([]byte, []int)deprecated
- func (x *Report) GetConfigDigest() []byte
- func (x *Report) GetCreatedAt() *Timestamp
- func (x *Report) GetCurrentBlockHash() []byte
- func (x *Report) GetCurrentBlockNumber() int64
- func (x *Report) GetCurrentBlockTimestamp() uint64
- func (x *Report) GetEpoch() uint32
- func (x *Report) GetFeedId() []byte
- func (x *Report) GetObservationsTimestamp() int64
- func (x *Report) GetOperatorName() string
- func (x *Report) GetPayload() []byte
- func (x *Report) GetPrice() []byte
- func (x *Report) GetRound() uint32
- func (x *Report) GetTransmittingOperator() []byte
- func (x *Report) GetValidFromBlockNumber() int64
- func (*Report) ProtoMessage()
- func (x *Report) ProtoReflect() protoreflect.Message
- func (x *Report) Reset()
- func (x *Report) String() string
- type Timestamp
- type TransmitRequest
- func (*TransmitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TransmitRequest) GetPayload() []byte
- func (x *TransmitRequest) GetReportFormat() uint32
- func (*TransmitRequest) ProtoMessage()
- func (x *TransmitRequest) ProtoReflect() protoreflect.Message
- func (x *TransmitRequest) Reset()
- func (x *TransmitRequest) String() string
- type TransmitResponse
- func (*TransmitResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TransmitResponse) GetCode() int32
- func (x *TransmitResponse) GetError() string
- func (*TransmitResponse) ProtoMessage()
- func (x *TransmitResponse) ProtoReflect() protoreflect.Message
- func (x *TransmitResponse) Reset()
- func (x *TransmitResponse) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_mercury_proto protoreflect.FileDescriptor
View Source
var Mercury_ServiceDesc = wsrpc.ServiceDesc{ ServiceName: "pb.Mercury", HandlerType: (*MercuryServer)(nil), Methods: []wsrpc.MethodDesc{ { MethodName: "Transmit", Handler: _Mercury_Transmit_Handler, }, { MethodName: "LatestReport", Handler: _Mercury_LatestReport_Handler, }, }, }
Mercury_ServiceDesc is the wsrpc.ServiceDesc for Mercury service. It's only intended for direct use with wsrpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMercuryServer ¶
func RegisterMercuryServer(s wsrpc.ServiceRegistrar, srv MercuryServer)
Types ¶
type LatestReportRequest ¶
type LatestReportRequest struct { FeedId []byte `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"` // contains filtered or unexported fields }
func (*LatestReportRequest) Descriptor
deprecated
func (*LatestReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use LatestReportRequest.ProtoReflect.Descriptor instead.
func (*LatestReportRequest) GetFeedId ¶
func (x *LatestReportRequest) GetFeedId() []byte
func (*LatestReportRequest) ProtoMessage ¶
func (*LatestReportRequest) ProtoMessage()
func (*LatestReportRequest) ProtoReflect ¶
func (x *LatestReportRequest) ProtoReflect() protoreflect.Message
func (*LatestReportRequest) Reset ¶
func (x *LatestReportRequest) Reset()
func (*LatestReportRequest) String ¶
func (x *LatestReportRequest) String() string
type LatestReportResponse ¶
type LatestReportResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Report *Report `protobuf:"bytes,2,opt,name=report,proto3" json:"report,omitempty"` // contains filtered or unexported fields }
func (*LatestReportResponse) Descriptor
deprecated
func (*LatestReportResponse) Descriptor() ([]byte, []int)
Deprecated: Use LatestReportResponse.ProtoReflect.Descriptor instead.
func (*LatestReportResponse) GetError ¶
func (x *LatestReportResponse) GetError() string
func (*LatestReportResponse) GetReport ¶
func (x *LatestReportResponse) GetReport() *Report
func (*LatestReportResponse) ProtoMessage ¶
func (*LatestReportResponse) ProtoMessage()
func (*LatestReportResponse) ProtoReflect ¶
func (x *LatestReportResponse) ProtoReflect() protoreflect.Message
func (*LatestReportResponse) Reset ¶
func (x *LatestReportResponse) Reset()
func (*LatestReportResponse) String ¶
func (x *LatestReportResponse) String() string
type MercuryClient ¶
type MercuryClient interface { Transmit(ctx context.Context, in *TransmitRequest) (*TransmitResponse, error) LatestReport(ctx context.Context, in *LatestReportRequest) (*LatestReportResponse, error) }
MercuryClient is the client API for Mercury service.
func NewMercuryClient ¶
func NewMercuryClient(cc wsrpc.ClientInterface) MercuryClient
type MercuryServer ¶
type MercuryServer interface { Transmit(context.Context, *TransmitRequest) (*TransmitResponse, error) LatestReport(context.Context, *LatestReportRequest) (*LatestReportResponse, error) }
MercuryServer is the server API for Mercury service.
type Report ¶
type Report struct { FeedId []byte `protobuf:"bytes,1,opt,name=feedId,proto3" json:"feedId,omitempty"` Price []byte `protobuf:"bytes,2,opt,name=price,proto3" json:"price,omitempty"` Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` ValidFromBlockNumber int64 `protobuf:"varint,4,opt,name=validFromBlockNumber,proto3" json:"validFromBlockNumber,omitempty"` CurrentBlockNumber int64 `protobuf:"varint,5,opt,name=currentBlockNumber,proto3" json:"currentBlockNumber,omitempty"` CurrentBlockHash []byte `protobuf:"bytes,6,opt,name=currentBlockHash,proto3" json:"currentBlockHash,omitempty"` CurrentBlockTimestamp uint64 `protobuf:"varint,7,opt,name=currentBlockTimestamp,proto3" json:"currentBlockTimestamp,omitempty"` ObservationsTimestamp int64 `protobuf:"varint,8,opt,name=observationsTimestamp,proto3" json:"observationsTimestamp,omitempty"` ConfigDigest []byte `protobuf:"bytes,9,opt,name=configDigest,proto3" json:"configDigest,omitempty"` Epoch uint32 `protobuf:"varint,10,opt,name=epoch,proto3" json:"epoch,omitempty"` Round uint32 `protobuf:"varint,11,opt,name=round,proto3" json:"round,omitempty"` OperatorName string `protobuf:"bytes,12,opt,name=operatorName,proto3" json:"operatorName,omitempty"` TransmittingOperator []byte `protobuf:"bytes,13,opt,name=transmittingOperator,proto3" json:"transmittingOperator,omitempty"` CreatedAt *Timestamp `protobuf:"bytes,14,opt,name=createdAt,proto3" json:"createdAt,omitempty"` // contains filtered or unexported fields }
func (*Report) Descriptor
deprecated
func (*Report) GetConfigDigest ¶
func (*Report) GetCreatedAt ¶
func (*Report) GetCurrentBlockHash ¶
func (*Report) GetCurrentBlockNumber ¶
func (*Report) GetCurrentBlockTimestamp ¶ added in v2.2.0
func (*Report) GetObservationsTimestamp ¶
func (*Report) GetOperatorName ¶
func (*Report) GetPayload ¶
func (*Report) GetTransmittingOperator ¶
func (*Report) GetValidFromBlockNumber ¶
func (*Report) ProtoMessage ¶
func (*Report) ProtoMessage()
func (*Report) ProtoReflect ¶
func (x *Report) ProtoReflect() protoreflect.Message
type Timestamp ¶
type Timestamp struct { // Represents seconds of UTC time since Unix epoch // 1970-01-01T00:00:00Z. Must be from 0001-01-01T00:00:00Z to // 9999-12-31T23:59:59Z inclusive. Seconds int64 `protobuf:"varint,1,opt,name=seconds,proto3" json:"seconds,omitempty"` // Non-negative fractions of a second at nanosecond resolution. Negative // second values with fractions must still have non-negative nanos values // that count forward in time. Must be from 0 to 999,999,999 // inclusive. Nanos int32 `protobuf:"varint,2,opt,name=nanos,proto3" json:"nanos,omitempty"` // contains filtered or unexported fields }
Taken from: https://github.com/protocolbuffers/protobuf/blob/main/src/google/protobuf/timestamp.proto
func (*Timestamp) Descriptor
deprecated
func (*Timestamp) GetSeconds ¶
func (*Timestamp) ProtoMessage ¶
func (*Timestamp) ProtoMessage()
func (*Timestamp) ProtoReflect ¶
func (x *Timestamp) ProtoReflect() protoreflect.Message
type TransmitRequest ¶
type TransmitRequest struct { Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` ReportFormat uint32 `protobuf:"varint,2,opt,name=reportFormat,proto3" json:"reportFormat,omitempty"` // contains filtered or unexported fields }
func (*TransmitRequest) Descriptor
deprecated
func (*TransmitRequest) Descriptor() ([]byte, []int)
Deprecated: Use TransmitRequest.ProtoReflect.Descriptor instead.
func (*TransmitRequest) GetPayload ¶
func (x *TransmitRequest) GetPayload() []byte
func (*TransmitRequest) GetReportFormat ¶ added in v2.10.0
func (x *TransmitRequest) GetReportFormat() uint32
func (*TransmitRequest) ProtoMessage ¶
func (*TransmitRequest) ProtoMessage()
func (*TransmitRequest) ProtoReflect ¶
func (x *TransmitRequest) ProtoReflect() protoreflect.Message
func (*TransmitRequest) Reset ¶
func (x *TransmitRequest) Reset()
func (*TransmitRequest) String ¶
func (x *TransmitRequest) String() string
type TransmitResponse ¶
type TransmitResponse struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*TransmitResponse) Descriptor
deprecated
func (*TransmitResponse) Descriptor() ([]byte, []int)
Deprecated: Use TransmitResponse.ProtoReflect.Descriptor instead.
func (*TransmitResponse) GetCode ¶
func (x *TransmitResponse) GetCode() int32
func (*TransmitResponse) GetError ¶
func (x *TransmitResponse) GetError() string
func (*TransmitResponse) ProtoMessage ¶
func (*TransmitResponse) ProtoMessage()
func (*TransmitResponse) ProtoReflect ¶
func (x *TransmitResponse) ProtoReflect() protoreflect.Message
func (*TransmitResponse) Reset ¶
func (x *TransmitResponse) Reset()
func (*TransmitResponse) String ¶
func (x *TransmitResponse) String() string
Click to show internal directories.
Click to hide internal directories.