rpc

package
v0.1.9 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2025 License: MIT Imports: 9 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	Transmitter_Transmit_FullMethodName     = "/rpc.Transmitter/Transmit"
	Transmitter_LatestReport_FullMethodName = "/rpc.Transmitter/LatestReport"
)

Variables

View Source 
var File_transmitter_proto protoreflect.FileDescriptor
View Source 
var Transmitter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.Transmitter",
	HandlerType: (*TransmitterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Transmit",
			Handler:    _Transmitter_Transmit_Handler,
		},
		{
			MethodName: "LatestReport",
			Handler:    _Transmitter_LatestReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "transmitter.proto",
}

Transmitter_ServiceDesc is the grpc.ServiceDesc for Transmitter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTransmitterServer 

func RegisterTransmitterServer(s grpc.ServiceRegistrar, srv TransmitterServer)

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

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"`
	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 

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

type TransmitterClient 

type TransmitterClient interface {
	Transmit(ctx context.Context, in *TransmitRequest, opts ...grpc.CallOption) (*TransmitResponse, error)
	LatestReport(ctx context.Context, in *LatestReportRequest, opts ...grpc.CallOption) (*LatestReportResponse, error)
}

TransmitterClient is the client API for Transmitter 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 NewTransmitterClient 

func NewTransmitterClient(cc grpc.ClientConnInterface) TransmitterClient

type TransmitterServer 

type TransmitterServer interface {
	Transmit(context.Context, *TransmitRequest) (*TransmitResponse, error)
	LatestReport(context.Context, *LatestReportRequest) (*LatestReportResponse, error)
	// contains filtered or unexported methods
}

TransmitterServer is the server API for Transmitter service. All implementations must embed UnimplementedTransmitterServer for forward compatibility.

type UnimplementedTransmitterServer 

type UnimplementedTransmitterServer struct{}

UnimplementedTransmitterServer 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 (UnimplementedTransmitterServer) LatestReport 

func (UnimplementedTransmitterServer) LatestReport(context.Context, *LatestReportRequest) (*LatestReportResponse, error)

func (UnimplementedTransmitterServer) Transmit 

func (UnimplementedTransmitterServer) Transmit(context.Context, *TransmitRequest) (*TransmitResponse, error)

type UnsafeTransmitterServer 

type UnsafeTransmitterServer interface {
	// contains filtered or unexported methods
}

UnsafeTransmitterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TransmitterServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis

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.