pb

package
v2.7.1-mercury-20231108 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

Deprecated: Use Report.ProtoReflect.Descriptor instead.

func (*Report) GetConfigDigest 

func (x *Report) GetConfigDigest() []byte

func (*Report) GetCreatedAt 

func (x *Report) GetCreatedAt() *Timestamp

func (*Report) GetCurrentBlockHash 

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

func (*Report) GetCurrentBlockNumber 

func (x *Report) GetCurrentBlockNumber() int64

func (*Report) GetCurrentBlockTimestamp added in v2.2.0 

func (x *Report) GetCurrentBlockTimestamp() uint64

func (*Report) GetEpoch 

func (x *Report) GetEpoch() uint32

func (*Report) GetFeedId 

func (x *Report) GetFeedId() []byte

func (*Report) GetObservationsTimestamp 

func (x *Report) GetObservationsTimestamp() int64

func (*Report) GetOperatorName 

func (x *Report) GetOperatorName() string

func (*Report) GetPayload 

func (x *Report) GetPayload() []byte

func (*Report) GetPrice 

func (x *Report) GetPrice() []byte

func (*Report) GetRound 

func (x *Report) GetRound() uint32

func (*Report) GetTransmittingOperator 

func (x *Report) GetTransmittingOperator() []byte

func (*Report) GetValidFromBlockNumber 

func (x *Report) GetValidFromBlockNumber() int64

func (*Report) ProtoMessage 

func (*Report) ProtoMessage()

func (*Report) ProtoReflect 

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

func (*Report) Reset 

func (x *Report) Reset()

func (*Report) String 

func (x *Report) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Timestamp.ProtoReflect.Descriptor instead.

func (*Timestamp) GetNanos 

func (x *Timestamp) GetNanos() int32

func (*Timestamp) GetSeconds 

func (x *Timestamp) GetSeconds() int64

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) ProtoReflect 

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

func (*Timestamp) Reset 

func (x *Timestamp) Reset()

func (*Timestamp) String 

func (x *Timestamp) String() string

type TransmitRequest 

type TransmitRequest struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,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) 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

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.