Versions in this module Expand all Collapse all v0 v0.5.0 Oct 28, 2024 v0.4.1 Nov 21, 2024 v0.4.0 Sep 2, 2024 v0.3.1 Nov 21, 2024 v0.3.0 Aug 22, 2024 v0.2.1 Nov 21, 2024 v0.2.0 Jul 16, 2024 v0.1.1 Nov 12, 2024 v0.0.1 Nov 21, 2024 Changes in this version + const MercuryAdapter_NewMercuryV1Factory_FullMethodName + const MercuryAdapter_NewMercuryV2Factory_FullMethodName + const MercuryAdapter_NewMercuryV3Factory_FullMethodName + const MercuryAdapter_NewMercuryV4Factory_FullMethodName + const MercuryChainReader_LatestHeads_FullMethodName + const MercuryPluginFactory_NewMercuryPlugin_FullMethodName + const MercuryPlugin_Close_FullMethodName + const MercuryPlugin_Observation_FullMethodName + const MercuryPlugin_Report_FullMethodName + const OnchainConfigCodec_Decode_FullMethodName + const OnchainConfigCodec_Encode_FullMethodName + const ReportCodecV1_BuildReport_FullMethodName + const ReportCodecV1_CurrentBlockNumFromReport_FullMethodName + const ReportCodecV1_MaxReportLength_FullMethodName + const ReportCodecV2_BuildReport_FullMethodName + const ReportCodecV2_MaxReportLength_FullMethodName + const ReportCodecV2_ObservationTimestampFromReport_FullMethodName + const ReportCodecV3_BuildReport_FullMethodName + const ReportCodecV3_MaxReportLength_FullMethodName + const ReportCodecV3_ObservationTimestampFromReport_FullMethodName + const ReportCodecV4_BuildReport_FullMethodName + const ReportCodecV4_MaxReportLength_FullMethodName + const ReportCodecV4_ObservationTimestampFromReport_FullMethodName + const ServerFetcher_FetchInitialMaxFinalizedBlockNumber_FullMethodName + const ServerFetcher_LatestPrice_FullMethodName + const ServerFetcher_LatestTimestamp_FullMethodName + var File_mercury_loop_proto protoreflect.FileDescriptor + var File_mercury_plugin_proto protoreflect.FileDescriptor + var MercuryAdapter_ServiceDesc = grpc.ServiceDesc + var MercuryChainReader_ServiceDesc = grpc.ServiceDesc + var MercuryPluginFactory_ServiceDesc = grpc.ServiceDesc + var MercuryPlugin_ServiceDesc = grpc.ServiceDesc + var OnchainConfigCodec_ServiceDesc = grpc.ServiceDesc + var ReportCodecV1_ServiceDesc = grpc.ServiceDesc + var ReportCodecV2_ServiceDesc = grpc.ServiceDesc + var ReportCodecV3_ServiceDesc = grpc.ServiceDesc + var ReportCodecV4_ServiceDesc = grpc.ServiceDesc + var ServerFetcher_ServiceDesc = grpc.ServiceDesc + func RegisterMercuryAdapterServer(s grpc.ServiceRegistrar, srv MercuryAdapterServer) + func RegisterMercuryChainReaderServer(s grpc.ServiceRegistrar, srv MercuryChainReaderServer) + func RegisterMercuryPluginFactoryServer(s grpc.ServiceRegistrar, srv MercuryPluginFactoryServer) + func RegisterMercuryPluginServer(s grpc.ServiceRegistrar, srv MercuryPluginServer) + func RegisterOnchainConfigCodecServer(s grpc.ServiceRegistrar, srv OnchainConfigCodecServer) + func RegisterReportCodecV1Server(s grpc.ServiceRegistrar, srv ReportCodecV1Server) + func RegisterReportCodecV2Server(s grpc.ServiceRegistrar, srv ReportCodecV2Server) + func RegisterReportCodecV3Server(s grpc.ServiceRegistrar, srv ReportCodecV3Server) + func RegisterReportCodecV4Server(s grpc.ServiceRegistrar, srv ReportCodecV4Server) + func RegisterServerFetcherServer(s grpc.ServiceRegistrar, srv ServerFetcherServer) + type AttributedObservation struct + Observation []byte + Observer uint32 + func (*AttributedObservation) Descriptor() ([]byte, []int) + func (*AttributedObservation) ProtoMessage() + func (x *AttributedObservation) GetObservation() []byte + func (x *AttributedObservation) GetObserver() uint32 + func (x *AttributedObservation) ProtoReflect() protoreflect.Message + func (x *AttributedObservation) Reset() + func (x *AttributedObservation) String() string + type DecodeOnchainConfigReply struct + OnchainConfig *OnchainConfig + func (*DecodeOnchainConfigReply) Descriptor() ([]byte, []int) + func (*DecodeOnchainConfigReply) ProtoMessage() + func (x *DecodeOnchainConfigReply) GetOnchainConfig() *OnchainConfig + func (x *DecodeOnchainConfigReply) ProtoReflect() protoreflect.Message + func (x *DecodeOnchainConfigReply) Reset() + func (x *DecodeOnchainConfigReply) String() string + type DecodeOnchainConfigRequest struct + OnchainConfig []byte + func (*DecodeOnchainConfigRequest) Descriptor() ([]byte, []int) + func (*DecodeOnchainConfigRequest) ProtoMessage() + func (x *DecodeOnchainConfigRequest) GetOnchainConfig() []byte + func (x *DecodeOnchainConfigRequest) ProtoReflect() protoreflect.Message + func (x *DecodeOnchainConfigRequest) Reset() + func (x *DecodeOnchainConfigRequest) String() string + type EncodeOnchainConfigReply struct + OnchainConfig []byte + func (*EncodeOnchainConfigReply) Descriptor() ([]byte, []int) + func (*EncodeOnchainConfigReply) ProtoMessage() + func (x *EncodeOnchainConfigReply) GetOnchainConfig() []byte + func (x *EncodeOnchainConfigReply) ProtoReflect() protoreflect.Message + func (x *EncodeOnchainConfigReply) Reset() + func (x *EncodeOnchainConfigReply) String() string + type EncodeOnchainConfigRequest struct + OnchainConfig *OnchainConfig + func (*EncodeOnchainConfigRequest) Descriptor() ([]byte, []int) + func (*EncodeOnchainConfigRequest) ProtoMessage() + func (x *EncodeOnchainConfigRequest) GetOnchainConfig() *OnchainConfig + func (x *EncodeOnchainConfigRequest) ProtoReflect() protoreflect.Message + func (x *EncodeOnchainConfigRequest) Reset() + func (x *EncodeOnchainConfigRequest) String() string + type FetchInitialMaxFinalizedBlockNumberReply struct + InitialMaxFinalizedBlockNumber int64 + func (*FetchInitialMaxFinalizedBlockNumberReply) Descriptor() ([]byte, []int) + func (*FetchInitialMaxFinalizedBlockNumberReply) ProtoMessage() + func (x *FetchInitialMaxFinalizedBlockNumberReply) GetInitialMaxFinalizedBlockNumber() int64 + func (x *FetchInitialMaxFinalizedBlockNumberReply) ProtoReflect() protoreflect.Message + func (x *FetchInitialMaxFinalizedBlockNumberReply) Reset() + func (x *FetchInitialMaxFinalizedBlockNumberReply) String() string + type FetchInitialMaxFinalizedBlockNumberRequest struct + func (*FetchInitialMaxFinalizedBlockNumberRequest) Descriptor() ([]byte, []int) + func (*FetchInitialMaxFinalizedBlockNumberRequest) ProtoMessage() + func (x *FetchInitialMaxFinalizedBlockNumberRequest) ProtoReflect() protoreflect.Message + func (x *FetchInitialMaxFinalizedBlockNumberRequest) Reset() + func (x *FetchInitialMaxFinalizedBlockNumberRequest) String() string + type Head struct + Hash []byte + Number uint64 + Timestamp uint64 + func (*Head) Descriptor() ([]byte, []int) + func (*Head) ProtoMessage() + func (x *Head) GetHash() []byte + func (x *Head) GetNumber() uint64 + func (x *Head) GetTimestamp() uint64 + func (x *Head) ProtoReflect() protoreflect.Message + func (x *Head) Reset() + func (x *Head) String() string + type LatestHeadsReply struct + Heads []*Head + func (*LatestHeadsReply) Descriptor() ([]byte, []int) + func (*LatestHeadsReply) ProtoMessage() + func (x *LatestHeadsReply) GetHeads() []*Head + func (x *LatestHeadsReply) ProtoReflect() protoreflect.Message + func (x *LatestHeadsReply) Reset() + func (x *LatestHeadsReply) String() string + type LatestHeadsRequest struct + NumHeads int64 + func (*LatestHeadsRequest) Descriptor() ([]byte, []int) + func (*LatestHeadsRequest) ProtoMessage() + func (x *LatestHeadsRequest) GetNumHeads() int64 + func (x *LatestHeadsRequest) ProtoReflect() protoreflect.Message + func (x *LatestHeadsRequest) Reset() + func (x *LatestHeadsRequest) String() string + type LatestPriceReply struct + LatestPrice *pb.BigInt + func (*LatestPriceReply) Descriptor() ([]byte, []int) + func (*LatestPriceReply) ProtoMessage() + func (x *LatestPriceReply) GetLatestPrice() *pb.BigInt + func (x *LatestPriceReply) ProtoReflect() protoreflect.Message + func (x *LatestPriceReply) Reset() + func (x *LatestPriceReply) String() string + type LatestPriceRequest struct + FeedID []byte + func (*LatestPriceRequest) Descriptor() ([]byte, []int) + func (*LatestPriceRequest) ProtoMessage() + func (x *LatestPriceRequest) GetFeedID() []byte + func (x *LatestPriceRequest) ProtoReflect() protoreflect.Message + func (x *LatestPriceRequest) Reset() + func (x *LatestPriceRequest) String() string + type LatestTimestampReply struct + LatestTimestamp int64 + func (*LatestTimestampReply) Descriptor() ([]byte, []int) + func (*LatestTimestampReply) ProtoMessage() + func (x *LatestTimestampReply) GetLatestTimestamp() int64 + func (x *LatestTimestampReply) ProtoReflect() protoreflect.Message + func (x *LatestTimestampReply) Reset() + func (x *LatestTimestampReply) String() string + type LatestTimestampRequest struct + func (*LatestTimestampRequest) Descriptor() ([]byte, []int) + func (*LatestTimestampRequest) ProtoMessage() + func (x *LatestTimestampRequest) ProtoReflect() protoreflect.Message + func (x *LatestTimestampRequest) Reset() + func (x *LatestTimestampRequest) String() string + type MercuryAdapterClient interface + NewMercuryV1Factory func(ctx context.Context, in *NewMercuryV1FactoryRequest, opts ...grpc.CallOption) (*NewMercuryV1FactoryReply, error) + NewMercuryV2Factory func(ctx context.Context, in *NewMercuryV2FactoryRequest, opts ...grpc.CallOption) (*NewMercuryV2FactoryReply, error) + NewMercuryV3Factory func(ctx context.Context, in *NewMercuryV3FactoryRequest, opts ...grpc.CallOption) (*NewMercuryV3FactoryReply, error) + NewMercuryV4Factory func(ctx context.Context, in *NewMercuryV4FactoryRequest, opts ...grpc.CallOption) (*NewMercuryV4FactoryReply, error) + func NewMercuryAdapterClient(cc grpc.ClientConnInterface) MercuryAdapterClient + type MercuryAdapterServer interface + NewMercuryV1Factory func(context.Context, *NewMercuryV1FactoryRequest) (*NewMercuryV1FactoryReply, error) + NewMercuryV2Factory func(context.Context, *NewMercuryV2FactoryRequest) (*NewMercuryV2FactoryReply, error) + NewMercuryV3Factory func(context.Context, *NewMercuryV3FactoryRequest) (*NewMercuryV3FactoryReply, error) + NewMercuryV4Factory func(context.Context, *NewMercuryV4FactoryRequest) (*NewMercuryV4FactoryReply, error) + type MercuryChainReaderClient interface + LatestHeads func(ctx context.Context, in *LatestHeadsRequest, opts ...grpc.CallOption) (*LatestHeadsReply, error) + func NewMercuryChainReaderClient(cc grpc.ClientConnInterface) MercuryChainReaderClient + type MercuryChainReaderServer interface + LatestHeads func(context.Context, *LatestHeadsRequest) (*LatestHeadsReply, error) + type MercuryPluginClient interface + Close func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) + Observation func(ctx context.Context, in *ObservationRequest, opts ...grpc.CallOption) (*ObservationResponse, error) + Report func(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportResponse, error) + func NewMercuryPluginClient(cc grpc.ClientConnInterface) MercuryPluginClient + type MercuryPluginConfig struct + ConfigDigest []byte + EstimatedRoundInterval int64 + F uint32 + MaxDurationObservation int64 + N uint32 + OffchainConfig []byte + OnchainConfig []byte + OracleID uint32 + func (*MercuryPluginConfig) Descriptor() ([]byte, []int) + func (*MercuryPluginConfig) ProtoMessage() + func (x *MercuryPluginConfig) GetConfigDigest() []byte + func (x *MercuryPluginConfig) GetEstimatedRoundInterval() int64 + func (x *MercuryPluginConfig) GetF() uint32 + func (x *MercuryPluginConfig) GetMaxDurationObservation() int64 + func (x *MercuryPluginConfig) GetN() uint32 + func (x *MercuryPluginConfig) GetOffchainConfig() []byte + func (x *MercuryPluginConfig) GetOnchainConfig() []byte + func (x *MercuryPluginConfig) GetOracleID() uint32 + func (x *MercuryPluginConfig) ProtoReflect() protoreflect.Message + func (x *MercuryPluginConfig) Reset() + func (x *MercuryPluginConfig) String() string + type MercuryPluginFactoryClient interface + NewMercuryPlugin func(ctx context.Context, in *NewMercuryPluginRequest, opts ...grpc.CallOption) (*NewMercuryPluginResponse, error) + func NewMercuryPluginFactoryClient(cc grpc.ClientConnInterface) MercuryPluginFactoryClient + type MercuryPluginFactoryServer interface + NewMercuryPlugin func(context.Context, *NewMercuryPluginRequest) (*NewMercuryPluginResponse, error) + type MercuryPluginInfo struct + MercuryPluginLimits *MercuryPluginLimits + Name string + func (*MercuryPluginInfo) Descriptor() ([]byte, []int) + func (*MercuryPluginInfo) ProtoMessage() + func (x *MercuryPluginInfo) GetMercuryPluginLimits() *MercuryPluginLimits + func (x *MercuryPluginInfo) GetName() string + func (x *MercuryPluginInfo) ProtoReflect() protoreflect.Message + func (x *MercuryPluginInfo) Reset() + func (x *MercuryPluginInfo) String() string + type MercuryPluginLimits struct + MaxObservationLength uint64 + MaxReportLength uint64 + func (*MercuryPluginLimits) Descriptor() ([]byte, []int) + func (*MercuryPluginLimits) ProtoMessage() + func (x *MercuryPluginLimits) GetMaxObservationLength() uint64 + func (x *MercuryPluginLimits) GetMaxReportLength() uint64 + func (x *MercuryPluginLimits) ProtoReflect() protoreflect.Message + func (x *MercuryPluginLimits) Reset() + func (x *MercuryPluginLimits) String() string + type MercuryPluginServer interface + Close func(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + Observation func(context.Context, *ObservationRequest) (*ObservationResponse, error) + Report func(context.Context, *ReportRequest) (*ReportResponse, error) + type NewMercuryPluginRequest struct + MercuryPluginConfig *MercuryPluginConfig + func (*NewMercuryPluginRequest) Descriptor() ([]byte, []int) + func (*NewMercuryPluginRequest) ProtoMessage() + func (x *NewMercuryPluginRequest) GetMercuryPluginConfig() *MercuryPluginConfig + func (x *NewMercuryPluginRequest) ProtoReflect() protoreflect.Message + func (x *NewMercuryPluginRequest) Reset() + func (x *NewMercuryPluginRequest) String() string + type NewMercuryPluginResponse struct + MercuryPluginID uint32 + MercuryPluginInfo *MercuryPluginInfo + func (*NewMercuryPluginResponse) Descriptor() ([]byte, []int) + func (*NewMercuryPluginResponse) ProtoMessage() + func (x *NewMercuryPluginResponse) GetMercuryPluginID() uint32 + func (x *NewMercuryPluginResponse) GetMercuryPluginInfo() *MercuryPluginInfo + func (x *NewMercuryPluginResponse) ProtoReflect() protoreflect.Message + func (x *NewMercuryPluginResponse) Reset() + func (x *NewMercuryPluginResponse) String() string + type NewMercuryV1FactoryReply struct + MercuryV1FactoryID uint32 + func (*NewMercuryV1FactoryReply) Descriptor() ([]byte, []int) + func (*NewMercuryV1FactoryReply) ProtoMessage() + func (x *NewMercuryV1FactoryReply) GetMercuryV1FactoryID() uint32 + func (x *NewMercuryV1FactoryReply) ProtoReflect() protoreflect.Message + func (x *NewMercuryV1FactoryReply) Reset() + func (x *NewMercuryV1FactoryReply) String() string + type NewMercuryV1FactoryRequest struct + DataSourceV1ID uint32 + MercuryProviderID uint32 + func (*NewMercuryV1FactoryRequest) Descriptor() ([]byte, []int) + func (*NewMercuryV1FactoryRequest) ProtoMessage() + func (x *NewMercuryV1FactoryRequest) GetDataSourceV1ID() uint32 + func (x *NewMercuryV1FactoryRequest) GetMercuryProviderID() uint32 + func (x *NewMercuryV1FactoryRequest) ProtoReflect() protoreflect.Message + func (x *NewMercuryV1FactoryRequest) Reset() + func (x *NewMercuryV1FactoryRequest) String() string + type NewMercuryV2FactoryReply struct + MercuryV2FactoryID uint32 + func (*NewMercuryV2FactoryReply) Descriptor() ([]byte, []int) + func (*NewMercuryV2FactoryReply) ProtoMessage() + func (x *NewMercuryV2FactoryReply) GetMercuryV2FactoryID() uint32 + func (x *NewMercuryV2FactoryReply) ProtoReflect() protoreflect.Message + func (x *NewMercuryV2FactoryReply) Reset() + func (x *NewMercuryV2FactoryReply) String() string + type NewMercuryV2FactoryRequest struct + DataSourceV2ID uint32 + MercuryProviderID uint32 + func (*NewMercuryV2FactoryRequest) Descriptor() ([]byte, []int) + func (*NewMercuryV2FactoryRequest) ProtoMessage() + func (x *NewMercuryV2FactoryRequest) GetDataSourceV2ID() uint32 + func (x *NewMercuryV2FactoryRequest) GetMercuryProviderID() uint32 + func (x *NewMercuryV2FactoryRequest) ProtoReflect() protoreflect.Message + func (x *NewMercuryV2FactoryRequest) Reset() + func (x *NewMercuryV2FactoryRequest) String() string + type NewMercuryV3FactoryReply struct + MercuryV3FactoryID uint32 + func (*NewMercuryV3FactoryReply) Descriptor() ([]byte, []int) + func (*NewMercuryV3FactoryReply) ProtoMessage() + func (x *NewMercuryV3FactoryReply) GetMercuryV3FactoryID() uint32 + func (x *NewMercuryV3FactoryReply) ProtoReflect() protoreflect.Message + func (x *NewMercuryV3FactoryReply) Reset() + func (x *NewMercuryV3FactoryReply) String() string + type NewMercuryV3FactoryRequest struct + DataSourceV3ID uint32 + MercuryProviderID uint32 + func (*NewMercuryV3FactoryRequest) Descriptor() ([]byte, []int) + func (*NewMercuryV3FactoryRequest) ProtoMessage() + func (x *NewMercuryV3FactoryRequest) GetDataSourceV3ID() uint32 + func (x *NewMercuryV3FactoryRequest) GetMercuryProviderID() uint32 + func (x *NewMercuryV3FactoryRequest) ProtoReflect() protoreflect.Message + func (x *NewMercuryV3FactoryRequest) Reset() + func (x *NewMercuryV3FactoryRequest) String() string + type NewMercuryV4FactoryReply struct + MercuryV4FactoryID uint32 + func (*NewMercuryV4FactoryReply) Descriptor() ([]byte, []int) + func (*NewMercuryV4FactoryReply) ProtoMessage() + func (x *NewMercuryV4FactoryReply) GetMercuryV4FactoryID() uint32 + func (x *NewMercuryV4FactoryReply) ProtoReflect() protoreflect.Message + func (x *NewMercuryV4FactoryReply) Reset() + func (x *NewMercuryV4FactoryReply) String() string + type NewMercuryV4FactoryRequest struct + DataSourceV4ID uint32 + MercuryProviderID uint32 + func (*NewMercuryV4FactoryRequest) Descriptor() ([]byte, []int) + func (*NewMercuryV4FactoryRequest) ProtoMessage() + func (x *NewMercuryV4FactoryRequest) GetDataSourceV4ID() uint32 + func (x *NewMercuryV4FactoryRequest) GetMercuryProviderID() uint32 + func (x *NewMercuryV4FactoryRequest) ProtoReflect() protoreflect.Message + func (x *NewMercuryV4FactoryRequest) Reset() + func (x *NewMercuryV4FactoryRequest) String() string + type ObservationRequest struct + PreviousReport []byte + ReportTimestamp *pb.ReportTimestamp + func (*ObservationRequest) Descriptor() ([]byte, []int) + func (*ObservationRequest) ProtoMessage() + func (x *ObservationRequest) GetPreviousReport() []byte + func (x *ObservationRequest) GetReportTimestamp() *pb.ReportTimestamp + func (x *ObservationRequest) ProtoReflect() protoreflect.Message + func (x *ObservationRequest) Reset() + func (x *ObservationRequest) String() string + type ObservationResponse struct + Observation []byte + func (*ObservationResponse) Descriptor() ([]byte, []int) + func (*ObservationResponse) ProtoMessage() + func (x *ObservationResponse) GetObservation() []byte + func (x *ObservationResponse) ProtoReflect() protoreflect.Message + func (x *ObservationResponse) Reset() + func (x *ObservationResponse) String() string + type OnchainConfig struct + Max *pb.BigInt + Min *pb.BigInt + func (*OnchainConfig) Descriptor() ([]byte, []int) + func (*OnchainConfig) ProtoMessage() + func (x *OnchainConfig) GetMax() *pb.BigInt + func (x *OnchainConfig) GetMin() *pb.BigInt + func (x *OnchainConfig) ProtoReflect() protoreflect.Message + func (x *OnchainConfig) Reset() + func (x *OnchainConfig) String() string + type OnchainConfigCodecClient interface + Decode func(ctx context.Context, in *DecodeOnchainConfigRequest, opts ...grpc.CallOption) (*DecodeOnchainConfigReply, error) + Encode func(ctx context.Context, in *EncodeOnchainConfigRequest, opts ...grpc.CallOption) (*EncodeOnchainConfigReply, error) + func NewOnchainConfigCodecClient(cc grpc.ClientConnInterface) OnchainConfigCodecClient + type OnchainConfigCodecServer interface + Decode func(context.Context, *DecodeOnchainConfigRequest) (*DecodeOnchainConfigReply, error) + Encode func(context.Context, *EncodeOnchainConfigRequest) (*EncodeOnchainConfigReply, error) + type ReportCodecV1Client interface + BuildReport func(ctx context.Context, in *v1.BuildReportRequest, opts ...grpc.CallOption) (*v1.BuildReportReply, error) + CurrentBlockNumFromReport func(ctx context.Context, in *v1.CurrentBlockNumFromReportRequest, ...) (*v1.CurrentBlockNumFromReportResponse, error) + MaxReportLength func(ctx context.Context, in *v1.MaxReportLengthRequest, opts ...grpc.CallOption) (*v1.MaxReportLengthReply, error) + func NewReportCodecV1Client(cc grpc.ClientConnInterface) ReportCodecV1Client + type ReportCodecV1Server interface + BuildReport func(context.Context, *v1.BuildReportRequest) (*v1.BuildReportReply, error) + CurrentBlockNumFromReport func(context.Context, *v1.CurrentBlockNumFromReportRequest) (*v1.CurrentBlockNumFromReportResponse, error) + MaxReportLength func(context.Context, *v1.MaxReportLengthRequest) (*v1.MaxReportLengthReply, error) + type ReportCodecV2Client interface + BuildReport func(ctx context.Context, in *v2.BuildReportRequest, opts ...grpc.CallOption) (*v2.BuildReportReply, error) + MaxReportLength func(ctx context.Context, in *v2.MaxReportLengthRequest, opts ...grpc.CallOption) (*v2.MaxReportLengthReply, error) + ObservationTimestampFromReport func(ctx context.Context, in *v2.ObservationTimestampFromReportRequest, ...) (*v2.ObservationTimestampFromReportReply, error) + func NewReportCodecV2Client(cc grpc.ClientConnInterface) ReportCodecV2Client + type ReportCodecV2Server interface + BuildReport func(context.Context, *v2.BuildReportRequest) (*v2.BuildReportReply, error) + MaxReportLength func(context.Context, *v2.MaxReportLengthRequest) (*v2.MaxReportLengthReply, error) + ObservationTimestampFromReport func(context.Context, *v2.ObservationTimestampFromReportRequest) (*v2.ObservationTimestampFromReportReply, error) + type ReportCodecV3Client interface + BuildReport func(ctx context.Context, in *v3.BuildReportRequest, opts ...grpc.CallOption) (*v3.BuildReportReply, error) + MaxReportLength func(ctx context.Context, in *v3.MaxReportLengthRequest, opts ...grpc.CallOption) (*v3.MaxReportLengthReply, error) + ObservationTimestampFromReport func(ctx context.Context, in *v3.ObservationTimestampFromReportRequest, ...) (*v3.ObservationTimestampFromReportReply, error) + func NewReportCodecV3Client(cc grpc.ClientConnInterface) ReportCodecV3Client + type ReportCodecV3Server interface + BuildReport func(context.Context, *v3.BuildReportRequest) (*v3.BuildReportReply, error) + MaxReportLength func(context.Context, *v3.MaxReportLengthRequest) (*v3.MaxReportLengthReply, error) + ObservationTimestampFromReport func(context.Context, *v3.ObservationTimestampFromReportRequest) (*v3.ObservationTimestampFromReportReply, error) + type ReportCodecV4Client interface + BuildReport func(ctx context.Context, in *v4.BuildReportRequest, opts ...grpc.CallOption) (*v4.BuildReportReply, error) + MaxReportLength func(ctx context.Context, in *v4.MaxReportLengthRequest, opts ...grpc.CallOption) (*v4.MaxReportLengthReply, error) + ObservationTimestampFromReport func(ctx context.Context, in *v4.ObservationTimestampFromReportRequest, ...) (*v4.ObservationTimestampFromReportReply, error) + func NewReportCodecV4Client(cc grpc.ClientConnInterface) ReportCodecV4Client + type ReportCodecV4Server interface + BuildReport func(context.Context, *v4.BuildReportRequest) (*v4.BuildReportReply, error) + MaxReportLength func(context.Context, *v4.MaxReportLengthRequest) (*v4.MaxReportLengthReply, error) + ObservationTimestampFromReport func(context.Context, *v4.ObservationTimestampFromReportRequest) (*v4.ObservationTimestampFromReportReply, error) + type ReportRequest struct + Observations []*AttributedObservation + PreviousReport []byte + ReportTimestamp *pb.ReportTimestamp + func (*ReportRequest) Descriptor() ([]byte, []int) + func (*ReportRequest) ProtoMessage() + func (x *ReportRequest) GetObservations() []*AttributedObservation + func (x *ReportRequest) GetPreviousReport() []byte + func (x *ReportRequest) GetReportTimestamp() *pb.ReportTimestamp + func (x *ReportRequest) ProtoReflect() protoreflect.Message + func (x *ReportRequest) Reset() + func (x *ReportRequest) String() string + type ReportResponse struct + Report []byte + ShouldReport bool + func (*ReportResponse) Descriptor() ([]byte, []int) + func (*ReportResponse) ProtoMessage() + func (x *ReportResponse) GetReport() []byte + func (x *ReportResponse) GetShouldReport() bool + func (x *ReportResponse) ProtoReflect() protoreflect.Message + func (x *ReportResponse) Reset() + func (x *ReportResponse) String() string + type ServerFetcherClient interface + FetchInitialMaxFinalizedBlockNumber func(ctx context.Context, in *FetchInitialMaxFinalizedBlockNumberRequest, ...) (*FetchInitialMaxFinalizedBlockNumberReply, error) + LatestPrice func(ctx context.Context, in *LatestPriceRequest, opts ...grpc.CallOption) (*LatestPriceReply, error) + LatestTimestamp func(ctx context.Context, in *LatestTimestampRequest, opts ...grpc.CallOption) (*LatestTimestampReply, error) + func NewServerFetcherClient(cc grpc.ClientConnInterface) ServerFetcherClient + type ServerFetcherServer interface + FetchInitialMaxFinalizedBlockNumber func(context.Context, *FetchInitialMaxFinalizedBlockNumberRequest) (*FetchInitialMaxFinalizedBlockNumberReply, error) + LatestPrice func(context.Context, *LatestPriceRequest) (*LatestPriceReply, error) + LatestTimestamp func(context.Context, *LatestTimestampRequest) (*LatestTimestampReply, error) + type UnimplementedMercuryAdapterServer struct + func (UnimplementedMercuryAdapterServer) NewMercuryV1Factory(context.Context, *NewMercuryV1FactoryRequest) (*NewMercuryV1FactoryReply, error) + func (UnimplementedMercuryAdapterServer) NewMercuryV2Factory(context.Context, *NewMercuryV2FactoryRequest) (*NewMercuryV2FactoryReply, error) + func (UnimplementedMercuryAdapterServer) NewMercuryV3Factory(context.Context, *NewMercuryV3FactoryRequest) (*NewMercuryV3FactoryReply, error) + func (UnimplementedMercuryAdapterServer) NewMercuryV4Factory(context.Context, *NewMercuryV4FactoryRequest) (*NewMercuryV4FactoryReply, error) + type UnimplementedMercuryChainReaderServer struct + func (UnimplementedMercuryChainReaderServer) LatestHeads(context.Context, *LatestHeadsRequest) (*LatestHeadsReply, error) + type UnimplementedMercuryPluginFactoryServer struct + func (UnimplementedMercuryPluginFactoryServer) NewMercuryPlugin(context.Context, *NewMercuryPluginRequest) (*NewMercuryPluginResponse, error) + type UnimplementedMercuryPluginServer struct + func (UnimplementedMercuryPluginServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + func (UnimplementedMercuryPluginServer) Observation(context.Context, *ObservationRequest) (*ObservationResponse, error) + func (UnimplementedMercuryPluginServer) Report(context.Context, *ReportRequest) (*ReportResponse, error) + type UnimplementedOnchainConfigCodecServer struct + func (UnimplementedOnchainConfigCodecServer) Decode(context.Context, *DecodeOnchainConfigRequest) (*DecodeOnchainConfigReply, error) + func (UnimplementedOnchainConfigCodecServer) Encode(context.Context, *EncodeOnchainConfigRequest) (*EncodeOnchainConfigReply, error) + type UnimplementedReportCodecV1Server struct + func (UnimplementedReportCodecV1Server) BuildReport(context.Context, *v1.BuildReportRequest) (*v1.BuildReportReply, error) + func (UnimplementedReportCodecV1Server) CurrentBlockNumFromReport(context.Context, *v1.CurrentBlockNumFromReportRequest) (*v1.CurrentBlockNumFromReportResponse, error) + func (UnimplementedReportCodecV1Server) MaxReportLength(context.Context, *v1.MaxReportLengthRequest) (*v1.MaxReportLengthReply, error) + type UnimplementedReportCodecV2Server struct + func (UnimplementedReportCodecV2Server) BuildReport(context.Context, *v2.BuildReportRequest) (*v2.BuildReportReply, error) + func (UnimplementedReportCodecV2Server) MaxReportLength(context.Context, *v2.MaxReportLengthRequest) (*v2.MaxReportLengthReply, error) + func (UnimplementedReportCodecV2Server) ObservationTimestampFromReport(context.Context, *v2.ObservationTimestampFromReportRequest) (*v2.ObservationTimestampFromReportReply, error) + type UnimplementedReportCodecV3Server struct + func (UnimplementedReportCodecV3Server) BuildReport(context.Context, *v3.BuildReportRequest) (*v3.BuildReportReply, error) + func (UnimplementedReportCodecV3Server) MaxReportLength(context.Context, *v3.MaxReportLengthRequest) (*v3.MaxReportLengthReply, error) + func (UnimplementedReportCodecV3Server) ObservationTimestampFromReport(context.Context, *v3.ObservationTimestampFromReportRequest) (*v3.ObservationTimestampFromReportReply, error) + type UnimplementedReportCodecV4Server struct + func (UnimplementedReportCodecV4Server) BuildReport(context.Context, *v4.BuildReportRequest) (*v4.BuildReportReply, error) + func (UnimplementedReportCodecV4Server) MaxReportLength(context.Context, *v4.MaxReportLengthRequest) (*v4.MaxReportLengthReply, error) + func (UnimplementedReportCodecV4Server) ObservationTimestampFromReport(context.Context, *v4.ObservationTimestampFromReportRequest) (*v4.ObservationTimestampFromReportReply, error) + type UnimplementedServerFetcherServer struct + func (UnimplementedServerFetcherServer) FetchInitialMaxFinalizedBlockNumber(context.Context, *FetchInitialMaxFinalizedBlockNumberRequest) (*FetchInitialMaxFinalizedBlockNumberReply, error) + func (UnimplementedServerFetcherServer) LatestPrice(context.Context, *LatestPriceRequest) (*LatestPriceReply, error) + func (UnimplementedServerFetcherServer) LatestTimestamp(context.Context, *LatestTimestampRequest) (*LatestTimestampReply, error) + type UnsafeMercuryAdapterServer interface + type UnsafeMercuryChainReaderServer interface + type UnsafeMercuryPluginFactoryServer interface + type UnsafeMercuryPluginServer interface + type UnsafeOnchainConfigCodecServer interface + type UnsafeReportCodecV1Server interface + type UnsafeReportCodecV2Server interface + type UnsafeReportCodecV3Server interface + type UnsafeReportCodecV4Server interface + type UnsafeServerFetcherServer interface v0.0.1-beta Nov 26, 2024
Go to main page