mercurypb

package
v0.4.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: 14 Imported by: 0

README

the bizarre naming pattern like /v1/datasource_v1.proto instead of /v1/datasource.proto is to work around the baffling proto constraint that (filenames must be globally unique) [https://github.com/golang/protobuf/issues/1122].

Documentation

Index

Constants

View Source 
const (
	MercuryAdapter_NewMercuryV1Factory_FullMethodName = "/loop.internal.pb.mercury.MercuryAdapter/NewMercuryV1Factory"
	MercuryAdapter_NewMercuryV2Factory_FullMethodName = "/loop.internal.pb.mercury.MercuryAdapter/NewMercuryV2Factory"
	MercuryAdapter_NewMercuryV3Factory_FullMethodName = "/loop.internal.pb.mercury.MercuryAdapter/NewMercuryV3Factory"
	MercuryAdapter_NewMercuryV4Factory_FullMethodName = "/loop.internal.pb.mercury.MercuryAdapter/NewMercuryV4Factory"
)
View Source 
const (
	OnchainConfigCodec_Encode_FullMethodName = "/loop.internal.pb.mercury.OnchainConfigCodec/Encode"
	OnchainConfigCodec_Decode_FullMethodName = "/loop.internal.pb.mercury.OnchainConfigCodec/Decode"
)
View Source 
const (
	ReportCodecV4_BuildReport_FullMethodName                    = "/loop.internal.pb.mercury.ReportCodecV4/BuildReport"
	ReportCodecV4_MaxReportLength_FullMethodName                = "/loop.internal.pb.mercury.ReportCodecV4/MaxReportLength"
	ReportCodecV4_ObservationTimestampFromReport_FullMethodName = "/loop.internal.pb.mercury.ReportCodecV4/ObservationTimestampFromReport"
)
View Source 
const (
	ReportCodecV3_BuildReport_FullMethodName                    = "/loop.internal.pb.mercury.ReportCodecV3/BuildReport"
	ReportCodecV3_MaxReportLength_FullMethodName                = "/loop.internal.pb.mercury.ReportCodecV3/MaxReportLength"
	ReportCodecV3_ObservationTimestampFromReport_FullMethodName = "/loop.internal.pb.mercury.ReportCodecV3/ObservationTimestampFromReport"
)
View Source 
const (
	ReportCodecV1_BuildReport_FullMethodName               = "/loop.internal.pb.mercury.ReportCodecV1/BuildReport"
	ReportCodecV1_MaxReportLength_FullMethodName           = "/loop.internal.pb.mercury.ReportCodecV1/MaxReportLength"
	ReportCodecV1_CurrentBlockNumFromReport_FullMethodName = "/loop.internal.pb.mercury.ReportCodecV1/CurrentBlockNumFromReport"
)
View Source 
const (
	ReportCodecV2_BuildReport_FullMethodName                    = "/loop.internal.pb.mercury.ReportCodecV2/BuildReport"
	ReportCodecV2_MaxReportLength_FullMethodName                = "/loop.internal.pb.mercury.ReportCodecV2/MaxReportLength"
	ReportCodecV2_ObservationTimestampFromReport_FullMethodName = "/loop.internal.pb.mercury.ReportCodecV2/ObservationTimestampFromReport"
)
View Source 
const (
	ServerFetcher_FetchInitialMaxFinalizedBlockNumber_FullMethodName = "/loop.internal.pb.mercury.ServerFetcher/FetchInitialMaxFinalizedBlockNumber"
	ServerFetcher_LatestPrice_FullMethodName                         = "/loop.internal.pb.mercury.ServerFetcher/LatestPrice"
	ServerFetcher_LatestTimestamp_FullMethodName                     = "/loop.internal.pb.mercury.ServerFetcher/LatestTimestamp"
)
View Source 
const (
	MercuryPlugin_Observation_FullMethodName = "/loop.internal.pb.mercury.MercuryPlugin/Observation"
	MercuryPlugin_Report_FullMethodName      = "/loop.internal.pb.mercury.MercuryPlugin/Report"
	MercuryPlugin_Close_FullMethodName       = "/loop.internal.pb.mercury.MercuryPlugin/Close"
)
View Source 
const (
	MercuryChainReader_LatestHeads_FullMethodName = "/loop.internal.pb.mercury.MercuryChainReader/LatestHeads"
)
View Source 
const (
	MercuryPluginFactory_NewMercuryPlugin_FullMethodName = "/loop.internal.pb.mercury.MercuryPluginFactory/NewMercuryPlugin"
)

Variables

View Source 
var File_mercury_loop_proto protoreflect.FileDescriptor
View Source 
var File_mercury_plugin_proto protoreflect.FileDescriptor
View Source 
var MercuryAdapter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.MercuryAdapter",
	HandlerType: (*MercuryAdapterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewMercuryV1Factory",
			Handler:    _MercuryAdapter_NewMercuryV1Factory_Handler,
		},
		{
			MethodName: "NewMercuryV2Factory",
			Handler:    _MercuryAdapter_NewMercuryV2Factory_Handler,
		},
		{
			MethodName: "NewMercuryV3Factory",
			Handler:    _MercuryAdapter_NewMercuryV3Factory_Handler,
		},
		{
			MethodName: "NewMercuryV4Factory",
			Handler:    _MercuryAdapter_NewMercuryV4Factory_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_loop.proto",
}

MercuryAdapter_ServiceDesc is the grpc.ServiceDesc for MercuryAdapter 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 MercuryChainReader_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.MercuryChainReader",
	HandlerType: (*MercuryChainReaderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LatestHeads",
			Handler:    _MercuryChainReader_LatestHeads_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_loop.proto",
}

MercuryChainReader_ServiceDesc is the grpc.ServiceDesc for MercuryChainReader 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 MercuryPluginFactory_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.MercuryPluginFactory",
	HandlerType: (*MercuryPluginFactoryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewMercuryPlugin",
			Handler:    _MercuryPluginFactory_NewMercuryPlugin_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_plugin.proto",
}

MercuryPluginFactory_ServiceDesc is the grpc.ServiceDesc for MercuryPluginFactory 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 MercuryPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.MercuryPlugin",
	HandlerType: (*MercuryPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Observation",
			Handler:    _MercuryPlugin_Observation_Handler,
		},
		{
			MethodName: "Report",
			Handler:    _MercuryPlugin_Report_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _MercuryPlugin_Close_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_plugin.proto",
}

MercuryPlugin_ServiceDesc is the grpc.ServiceDesc for MercuryPlugin 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 OnchainConfigCodec_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.OnchainConfigCodec",
	HandlerType: (*OnchainConfigCodecServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Encode",
			Handler:    _OnchainConfigCodec_Encode_Handler,
		},
		{
			MethodName: "Decode",
			Handler:    _OnchainConfigCodec_Decode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_loop.proto",
}

OnchainConfigCodec_ServiceDesc is the grpc.ServiceDesc for OnchainConfigCodec 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 ReportCodecV1_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.ReportCodecV1",
	HandlerType: (*ReportCodecV1Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BuildReport",
			Handler:    _ReportCodecV1_BuildReport_Handler,
		},
		{
			MethodName: "MaxReportLength",
			Handler:    _ReportCodecV1_MaxReportLength_Handler,
		},
		{
			MethodName: "CurrentBlockNumFromReport",
			Handler:    _ReportCodecV1_CurrentBlockNumFromReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_loop.proto",
}

ReportCodecV1_ServiceDesc is the grpc.ServiceDesc for ReportCodecV1 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 ReportCodecV2_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.ReportCodecV2",
	HandlerType: (*ReportCodecV2Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BuildReport",
			Handler:    _ReportCodecV2_BuildReport_Handler,
		},
		{
			MethodName: "MaxReportLength",
			Handler:    _ReportCodecV2_MaxReportLength_Handler,
		},
		{
			MethodName: "ObservationTimestampFromReport",
			Handler:    _ReportCodecV2_ObservationTimestampFromReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_loop.proto",
}

ReportCodecV2_ServiceDesc is the grpc.ServiceDesc for ReportCodecV2 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 ReportCodecV3_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.ReportCodecV3",
	HandlerType: (*ReportCodecV3Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BuildReport",
			Handler:    _ReportCodecV3_BuildReport_Handler,
		},
		{
			MethodName: "MaxReportLength",
			Handler:    _ReportCodecV3_MaxReportLength_Handler,
		},
		{
			MethodName: "ObservationTimestampFromReport",
			Handler:    _ReportCodecV3_ObservationTimestampFromReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_loop.proto",
}

ReportCodecV3_ServiceDesc is the grpc.ServiceDesc for ReportCodecV3 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 ReportCodecV4_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.ReportCodecV4",
	HandlerType: (*ReportCodecV4Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BuildReport",
			Handler:    _ReportCodecV4_BuildReport_Handler,
		},
		{
			MethodName: "MaxReportLength",
			Handler:    _ReportCodecV4_MaxReportLength_Handler,
		},
		{
			MethodName: "ObservationTimestampFromReport",
			Handler:    _ReportCodecV4_ObservationTimestampFromReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_loop.proto",
}

ReportCodecV4_ServiceDesc is the grpc.ServiceDesc for ReportCodecV4 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 ServerFetcher_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.internal.pb.mercury.ServerFetcher",
	HandlerType: (*ServerFetcherServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FetchInitialMaxFinalizedBlockNumber",
			Handler:    _ServerFetcher_FetchInitialMaxFinalizedBlockNumber_Handler,
		},
		{
			MethodName: "LatestPrice",
			Handler:    _ServerFetcher_LatestPrice_Handler,
		},
		{
			MethodName: "LatestTimestamp",
			Handler:    _ServerFetcher_LatestTimestamp_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mercury_loop.proto",
}

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

Functions

func RegisterMercuryAdapterServer 

func RegisterMercuryAdapterServer(s grpc.ServiceRegistrar, srv MercuryAdapterServer)

func RegisterMercuryChainReaderServer 

func RegisterMercuryChainReaderServer(s grpc.ServiceRegistrar, srv MercuryChainReaderServer)

func RegisterMercuryPluginFactoryServer 

func RegisterMercuryPluginFactoryServer(s grpc.ServiceRegistrar, srv MercuryPluginFactoryServer)

func RegisterMercuryPluginServer 

func RegisterMercuryPluginServer(s grpc.ServiceRegistrar, srv MercuryPluginServer)

func RegisterOnchainConfigCodecServer 

func RegisterOnchainConfigCodecServer(s grpc.ServiceRegistrar, srv OnchainConfigCodecServer)

func RegisterReportCodecV1Server 

func RegisterReportCodecV1Server(s grpc.ServiceRegistrar, srv ReportCodecV1Server)

func RegisterReportCodecV2Server 

func RegisterReportCodecV2Server(s grpc.ServiceRegistrar, srv ReportCodecV2Server)

func RegisterReportCodecV3Server 

func RegisterReportCodecV3Server(s grpc.ServiceRegistrar, srv ReportCodecV3Server)

func RegisterReportCodecV4Server 

func RegisterReportCodecV4Server(s grpc.ServiceRegistrar, srv ReportCodecV4Server)

func RegisterServerFetcherServer 

func RegisterServerFetcherServer(s grpc.ServiceRegistrar, srv ServerFetcherServer)

Types

type AttributedObservation 

type AttributedObservation struct {
	Observation []byte `protobuf:"bytes,1,opt,name=observation,proto3" json:"observation,omitempty"`
	Observer    uint32 `protobuf:"varint,2,opt,name=observer,proto3" json:"observer,omitempty"` // uint8
	// contains filtered or unexported fields
}

TODO some definitions are shared with reporting plugin for ocr2. not sure to copy or share. copy for now... AttributedObservation represents github.com/goplugin/plugin-libocr/offchainreporting2plus/types.AttributedObservation

func (*AttributedObservation) Descriptor deprecated 

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

Deprecated: Use AttributedObservation.ProtoReflect.Descriptor instead.

func (*AttributedObservation) GetObservation 

func (x *AttributedObservation) GetObservation() []byte

func (*AttributedObservation) GetObserver 

func (x *AttributedObservation) GetObserver() uint32

func (*AttributedObservation) ProtoMessage 

func (*AttributedObservation) ProtoMessage()

func (*AttributedObservation) ProtoReflect 

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

func (*AttributedObservation) Reset 

func (x *AttributedObservation) Reset()

func (*AttributedObservation) String 

func (x *AttributedObservation) String() string

type DecodeOnchainConfigReply 

type DecodeOnchainConfigReply struct {
	OnchainConfig *OnchainConfig `protobuf:"bytes,1,opt,name=onchainConfig,proto3" json:"onchainConfig,omitempty"`
	// contains filtered or unexported fields
}

DecodeOnchainConfigReply has is gRPC adapter for the return values of pkg/types/mercury/OnchainConfig.Decode.

func (*DecodeOnchainConfigReply) Descriptor deprecated 

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

Deprecated: Use DecodeOnchainConfigReply.ProtoReflect.Descriptor instead.

func (*DecodeOnchainConfigReply) GetOnchainConfig 

func (x *DecodeOnchainConfigReply) GetOnchainConfig() *OnchainConfig

func (*DecodeOnchainConfigReply) ProtoMessage 

func (*DecodeOnchainConfigReply) ProtoMessage()

func (*DecodeOnchainConfigReply) ProtoReflect 

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

func (*DecodeOnchainConfigReply) Reset 

func (x *DecodeOnchainConfigReply) Reset()

func (*DecodeOnchainConfigReply) String 

func (x *DecodeOnchainConfigReply) String() string

type DecodeOnchainConfigRequest 

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

DecodeOnchainConfigRequest is gRPC adapter for the inputs arguments of pkg/types/mercury/OnchainConfig.Decode.

func (*DecodeOnchainConfigRequest) Descriptor deprecated 

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

Deprecated: Use DecodeOnchainConfigRequest.ProtoReflect.Descriptor instead.

func (*DecodeOnchainConfigRequest) GetOnchainConfig 

func (x *DecodeOnchainConfigRequest) GetOnchainConfig() []byte

func (*DecodeOnchainConfigRequest) ProtoMessage 

func (*DecodeOnchainConfigRequest) ProtoMessage()

func (*DecodeOnchainConfigRequest) ProtoReflect 

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

func (*DecodeOnchainConfigRequest) Reset 

func (x *DecodeOnchainConfigRequest) Reset()

func (*DecodeOnchainConfigRequest) String 

func (x *DecodeOnchainConfigRequest) String() string

type EncodeOnchainConfigReply 

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

EncodeOnchainConfigReply is gRPC adapter for the return values of pkg/types/mercury/OnchainConfig.Encode.

func (*EncodeOnchainConfigReply) Descriptor deprecated 

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

Deprecated: Use EncodeOnchainConfigReply.ProtoReflect.Descriptor instead.

func (*EncodeOnchainConfigReply) GetOnchainConfig 

func (x *EncodeOnchainConfigReply) GetOnchainConfig() []byte

func (*EncodeOnchainConfigReply) ProtoMessage 

func (*EncodeOnchainConfigReply) ProtoMessage()

func (*EncodeOnchainConfigReply) ProtoReflect 

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

func (*EncodeOnchainConfigReply) Reset 

func (x *EncodeOnchainConfigReply) Reset()

func (*EncodeOnchainConfigReply) String 

func (x *EncodeOnchainConfigReply) String() string

type EncodeOnchainConfigRequest 

type EncodeOnchainConfigRequest struct {
	OnchainConfig *OnchainConfig `protobuf:"bytes,1,opt,name=onchainConfig,proto3" json:"onchainConfig,omitempty"`
	// contains filtered or unexported fields
}

EncodeOnchainConfigRequest is gRPC adapter for the inputs arguments of pkg/types/mercury/OnchainConfig.Encode.

func (*EncodeOnchainConfigRequest) Descriptor deprecated 

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

Deprecated: Use EncodeOnchainConfigRequest.ProtoReflect.Descriptor instead.

func (*EncodeOnchainConfigRequest) GetOnchainConfig 

func (x *EncodeOnchainConfigRequest) GetOnchainConfig() *OnchainConfig

func (*EncodeOnchainConfigRequest) ProtoMessage 

func (*EncodeOnchainConfigRequest) ProtoMessage()

func (*EncodeOnchainConfigRequest) ProtoReflect 

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

func (*EncodeOnchainConfigRequest) Reset 

func (x *EncodeOnchainConfigRequest) Reset()

func (*EncodeOnchainConfigRequest) String 

func (x *EncodeOnchainConfigRequest) String() string

type FetchInitialMaxFinalizedBlockNumberReply 

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

FetchInitialMaxFinalizedBlockNumberReply is gRPC adapter for pkg/types/mercury/ServerFetcher.FetchInitialMaxFinalizedBlockNumber.

func (*FetchInitialMaxFinalizedBlockNumberReply) Descriptor deprecated 

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

Deprecated: Use FetchInitialMaxFinalizedBlockNumberReply.ProtoReflect.Descriptor instead.

func (*FetchInitialMaxFinalizedBlockNumberReply) GetInitialMaxFinalizedBlockNumber 

func (x *FetchInitialMaxFinalizedBlockNumberReply) GetInitialMaxFinalizedBlockNumber() int64

func (*FetchInitialMaxFinalizedBlockNumberReply) ProtoMessage 

func (*FetchInitialMaxFinalizedBlockNumberReply) ProtoMessage()

func (*FetchInitialMaxFinalizedBlockNumberReply) ProtoReflect 

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

func (*FetchInitialMaxFinalizedBlockNumberReply) Reset 

func (x *FetchInitialMaxFinalizedBlockNumberReply) Reset()

func (*FetchInitialMaxFinalizedBlockNumberReply) String 

func (x *FetchInitialMaxFinalizedBlockNumberReply) String() string

type FetchInitialMaxFinalizedBlockNumberRequest 

type FetchInitialMaxFinalizedBlockNumberRequest struct {
	// contains filtered or unexported fields
}

FetchInitialMaxFinalizedBlockNumberRequest is gRPC adapter for pkg/types/mercury/ServerFetcher.FetchInitialMaxFinalizedBlockNumber.

func (*FetchInitialMaxFinalizedBlockNumberRequest) Descriptor deprecated 

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

Deprecated: Use FetchInitialMaxFinalizedBlockNumberRequest.ProtoReflect.Descriptor instead.

func (*FetchInitialMaxFinalizedBlockNumberRequest) ProtoMessage 

func (*FetchInitialMaxFinalizedBlockNumberRequest) ProtoMessage()

func (*FetchInitialMaxFinalizedBlockNumberRequest) ProtoReflect 

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

func (*FetchInitialMaxFinalizedBlockNumberRequest) Reset 

func (x *FetchInitialMaxFinalizedBlockNumberRequest) Reset()

func (*FetchInitialMaxFinalizedBlockNumberRequest) String 

func (x *FetchInitialMaxFinalizedBlockNumberRequest) String() string
type Head struct {
	Number    uint64 `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
}

Head is gRPC adapter for the Head struct pkg/types/mercury/MercuryChainReader.

func (*Head) Descriptor deprecated 

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

Deprecated: Use Head.ProtoReflect.Descriptor instead.

func (*Head) GetHash 

func (x *Head) GetHash() []byte

func (*Head) GetNumber 

func (x *Head) GetNumber() uint64

func (*Head) GetTimestamp 

func (x *Head) GetTimestamp() uint64

func (*Head) ProtoMessage 

func (*Head) ProtoMessage()

func (*Head) ProtoReflect 

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

func (*Head) Reset 

func (x *Head) Reset()

func (*Head) String 

func (x *Head) String() string

type LatestHeadsReply 

type LatestHeadsReply struct {
	Heads []*Head `protobuf:"bytes,1,rep,name=heads,proto3" json:"heads,omitempty"`
	// contains filtered or unexported fields
}

LatestHeadsReply is gRPC adapter for return arguments to pkg/types/mercury/MercuryChainReader.LatestHeads.

func (*LatestHeadsReply) Descriptor deprecated 

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

Deprecated: Use LatestHeadsReply.ProtoReflect.Descriptor instead.

func (*LatestHeadsReply) GetHeads 

func (x *LatestHeadsReply) GetHeads() []*Head

func (*LatestHeadsReply) ProtoMessage 

func (*LatestHeadsReply) ProtoMessage()

func (*LatestHeadsReply) ProtoReflect 

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

func (*LatestHeadsReply) Reset 

func (x *LatestHeadsReply) Reset()

func (*LatestHeadsReply) String 

func (x *LatestHeadsReply) String() string

type LatestHeadsRequest 

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

LatestHeadsRequest is gRPC adapter for input arguments to pkg/types/mercury/MercuryChainReader.LatestHeads.

func (*LatestHeadsRequest) Descriptor deprecated 

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

Deprecated: Use LatestHeadsRequest.ProtoReflect.Descriptor instead.

func (*LatestHeadsRequest) GetNumHeads 

func (x *LatestHeadsRequest) GetNumHeads() int64

func (*LatestHeadsRequest) ProtoMessage 

func (*LatestHeadsRequest) ProtoMessage()

func (*LatestHeadsRequest) ProtoReflect 

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

func (*LatestHeadsRequest) Reset 

func (x *LatestHeadsRequest) Reset()

func (*LatestHeadsRequest) String 

func (x *LatestHeadsRequest) String() string

type LatestPriceReply 

type LatestPriceReply struct {
	LatestPrice *pb.BigInt `protobuf:"bytes,1,opt,name=latestPrice,proto3" json:"latestPrice,omitempty"`
	// contains filtered or unexported fields
}

LatestPriceReply is gRPC adapter for pkg/types/mercury/ServerFetcher.LatestPrice.

func (*LatestPriceReply) Descriptor deprecated 

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

Deprecated: Use LatestPriceReply.ProtoReflect.Descriptor instead.

func (*LatestPriceReply) GetLatestPrice 

func (x *LatestPriceReply) GetLatestPrice() *pb.BigInt

func (*LatestPriceReply) ProtoMessage 

func (*LatestPriceReply) ProtoMessage()

func (*LatestPriceReply) ProtoReflect 

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

func (*LatestPriceReply) Reset 

func (x *LatestPriceReply) Reset()

func (*LatestPriceReply) String 

func (x *LatestPriceReply) String() string

type LatestPriceRequest 

type LatestPriceRequest struct {
	FeedID []byte `protobuf:"bytes,1,opt,name=feedID,proto3" json:"feedID,omitempty"` // WARNING: this must be [32]byte in ServerFetcher interface
	// contains filtered or unexported fields
}

LatestPriceRequest is gRPC adapter for pkg/types/mercury/ServerFetcher.LatestPrice.

func (*LatestPriceRequest) Descriptor deprecated 

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

Deprecated: Use LatestPriceRequest.ProtoReflect.Descriptor instead.

func (*LatestPriceRequest) GetFeedID 

func (x *LatestPriceRequest) GetFeedID() []byte

func (*LatestPriceRequest) ProtoMessage 

func (*LatestPriceRequest) ProtoMessage()

func (*LatestPriceRequest) ProtoReflect 

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

func (*LatestPriceRequest) Reset 

func (x *LatestPriceRequest) Reset()

func (*LatestPriceRequest) String 

func (x *LatestPriceRequest) String() string

type LatestTimestampReply 

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

LatestTimestampReply is gRPC adapter for pkg/types/mercury/ServerFetcher.LatestTimestamp.

func (*LatestTimestampReply) Descriptor deprecated 

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

Deprecated: Use LatestTimestampReply.ProtoReflect.Descriptor instead.

func (*LatestTimestampReply) GetLatestTimestamp 

func (x *LatestTimestampReply) GetLatestTimestamp() int64

func (*LatestTimestampReply) ProtoMessage 

func (*LatestTimestampReply) ProtoMessage()

func (*LatestTimestampReply) ProtoReflect 

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

func (*LatestTimestampReply) Reset 

func (x *LatestTimestampReply) Reset()

func (*LatestTimestampReply) String 

func (x *LatestTimestampReply) String() string

type LatestTimestampRequest 

type LatestTimestampRequest struct {
	// contains filtered or unexported fields
}

LatestTimestampRequest is gRPC adapter for pkg/types/mercury/ServerFetcher.LatestTimestamp.

func (*LatestTimestampRequest) Descriptor deprecated 

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

Deprecated: Use LatestTimestampRequest.ProtoReflect.Descriptor instead.

func (*LatestTimestampRequest) ProtoMessage 

func (*LatestTimestampRequest) ProtoMessage()

func (*LatestTimestampRequest) ProtoReflect 

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

func (*LatestTimestampRequest) Reset 

func (x *LatestTimestampRequest) Reset()

func (*LatestTimestampRequest) String 

func (x *LatestTimestampRequest) String() string

type MercuryAdapterClient 

type MercuryAdapterClient interface {
	NewMercuryV1Factory(ctx context.Context, in *NewMercuryV1FactoryRequest, opts ...grpc.CallOption) (*NewMercuryV1FactoryReply, error)
	NewMercuryV2Factory(ctx context.Context, in *NewMercuryV2FactoryRequest, opts ...grpc.CallOption) (*NewMercuryV2FactoryReply, error)
	NewMercuryV3Factory(ctx context.Context, in *NewMercuryV3FactoryRequest, opts ...grpc.CallOption) (*NewMercuryV3FactoryReply, error)
	NewMercuryV4Factory(ctx context.Context, in *NewMercuryV4FactoryRequest, opts ...grpc.CallOption) (*NewMercuryV4FactoryReply, error)
}

MercuryAdapterClient is the client API for MercuryAdapter 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 NewMercuryAdapterClient 

func NewMercuryAdapterClient(cc grpc.ClientConnInterface) MercuryAdapterClient

type MercuryAdapterServer 

type MercuryAdapterServer interface {
	NewMercuryV1Factory(context.Context, *NewMercuryV1FactoryRequest) (*NewMercuryV1FactoryReply, error)
	NewMercuryV2Factory(context.Context, *NewMercuryV2FactoryRequest) (*NewMercuryV2FactoryReply, error)
	NewMercuryV3Factory(context.Context, *NewMercuryV3FactoryRequest) (*NewMercuryV3FactoryReply, error)
	NewMercuryV4Factory(context.Context, *NewMercuryV4FactoryRequest) (*NewMercuryV4FactoryReply, error)
	// contains filtered or unexported methods
}

MercuryAdapterServer is the server API for MercuryAdapter service. All implementations must embed UnimplementedMercuryAdapterServer for forward compatibility

type MercuryChainReaderClient 

type MercuryChainReaderClient interface {
	LatestHeads(ctx context.Context, in *LatestHeadsRequest, opts ...grpc.CallOption) (*LatestHeadsReply, error)
}

MercuryChainReaderClient is the client API for MercuryChainReader 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 NewMercuryChainReaderClient 

func NewMercuryChainReaderClient(cc grpc.ClientConnInterface) MercuryChainReaderClient

type MercuryChainReaderServer 

type MercuryChainReaderServer interface {
	LatestHeads(context.Context, *LatestHeadsRequest) (*LatestHeadsReply, error)
	// contains filtered or unexported methods
}

MercuryChainReaderServer is the server API for MercuryChainReader service. All implementations must embed UnimplementedMercuryChainReaderServer for forward compatibility

type MercuryPluginClient 

type MercuryPluginClient interface {
	Observation(ctx context.Context, in *ObservationRequest, opts ...grpc.CallOption) (*ObservationResponse, error)
	Report(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportResponse, error)
	Close(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

MercuryPluginClient is the client API for MercuryPlugin 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 NewMercuryPluginClient 

func NewMercuryPluginClient(cc grpc.ClientConnInterface) MercuryPluginClient

type MercuryPluginConfig 

type MercuryPluginConfig struct {
	ConfigDigest           []byte `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"` // [32]byte
	OracleID               uint32 `protobuf:"varint,2,opt,name=oracleID,proto3" json:"oracleID,omitempty"`        // uint8
	N                      uint32 `protobuf:"varint,3,opt,name=n,proto3" json:"n,omitempty"`
	F                      uint32 `protobuf:"varint,4,opt,name=f,proto3" json:"f,omitempty"`
	OnchainConfig          []byte `protobuf:"bytes,5,opt,name=onchainConfig,proto3" json:"onchainConfig,omitempty"`
	OffchainConfig         []byte `protobuf:"bytes,6,opt,name=offchainConfig,proto3" json:"offchainConfig,omitempty"`
	EstimatedRoundInterval int64  `protobuf:"varint,7,opt,name=estimatedRoundInterval,proto3" json:"estimatedRoundInterval,omitempty"`
	MaxDurationObservation int64  `protobuf:"varint,8,opt,name=maxDurationObservation,proto3" json:"maxDurationObservation,omitempty"`
	// contains filtered or unexported fields
}

MercuryPluginConfig represents github.com/goplugin/plugin-libocr/offchainreporting2plus/ocr3types.MercuryPluginConfig

func (*MercuryPluginConfig) Descriptor deprecated 

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

Deprecated: Use MercuryPluginConfig.ProtoReflect.Descriptor instead.

func (*MercuryPluginConfig) GetConfigDigest 

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

func (*MercuryPluginConfig) GetEstimatedRoundInterval 

func (x *MercuryPluginConfig) GetEstimatedRoundInterval() int64

func (*MercuryPluginConfig) GetF 

func (x *MercuryPluginConfig) GetF() uint32

func (*MercuryPluginConfig) GetMaxDurationObservation 

func (x *MercuryPluginConfig) GetMaxDurationObservation() int64

func (*MercuryPluginConfig) GetN 

func (x *MercuryPluginConfig) GetN() uint32

func (*MercuryPluginConfig) GetOffchainConfig 

func (x *MercuryPluginConfig) GetOffchainConfig() []byte

func (*MercuryPluginConfig) GetOnchainConfig 

func (x *MercuryPluginConfig) GetOnchainConfig() []byte

func (*MercuryPluginConfig) GetOracleID 

func (x *MercuryPluginConfig) GetOracleID() uint32

func (*MercuryPluginConfig) ProtoMessage 

func (*MercuryPluginConfig) ProtoMessage()

func (*MercuryPluginConfig) ProtoReflect 

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

func (*MercuryPluginConfig) Reset 

func (x *MercuryPluginConfig) Reset()

func (*MercuryPluginConfig) String 

func (x *MercuryPluginConfig) String() string

type MercuryPluginFactoryClient 

type MercuryPluginFactoryClient interface {
	NewMercuryPlugin(ctx context.Context, in *NewMercuryPluginRequest, opts ...grpc.CallOption) (*NewMercuryPluginResponse, error)
}

MercuryPluginFactoryClient is the client API for MercuryPluginFactory 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 NewMercuryPluginFactoryClient 

func NewMercuryPluginFactoryClient(cc grpc.ClientConnInterface) MercuryPluginFactoryClient

type MercuryPluginFactoryServer 

type MercuryPluginFactoryServer interface {
	NewMercuryPlugin(context.Context, *NewMercuryPluginRequest) (*NewMercuryPluginResponse, error)
	// contains filtered or unexported methods
}

MercuryPluginFactoryServer is the server API for MercuryPluginFactory service. All implementations must embed UnimplementedMercuryPluginFactoryServer for forward compatibility

type MercuryPluginInfo 

type MercuryPluginInfo struct {
	Name                string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MercuryPluginLimits *MercuryPluginLimits `protobuf:"bytes,3,opt,name=mercuryPluginLimits,proto3" json:"mercuryPluginLimits,omitempty"`
	// contains filtered or unexported fields
}

MercuryPluginInfo represents github.com/goplugin/plugin-libocr/offchainreporting2plus/types.MercuryPluginInfo

func (*MercuryPluginInfo) Descriptor deprecated 

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

Deprecated: Use MercuryPluginInfo.ProtoReflect.Descriptor instead.

func (*MercuryPluginInfo) GetMercuryPluginLimits 

func (x *MercuryPluginInfo) GetMercuryPluginLimits() *MercuryPluginLimits

func (*MercuryPluginInfo) GetName 

func (x *MercuryPluginInfo) GetName() string

func (*MercuryPluginInfo) ProtoMessage 

func (*MercuryPluginInfo) ProtoMessage()

func (*MercuryPluginInfo) ProtoReflect 

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

func (*MercuryPluginInfo) Reset 

func (x *MercuryPluginInfo) Reset()

func (*MercuryPluginInfo) String 

func (x *MercuryPluginInfo) String() string

type MercuryPluginLimits 

type MercuryPluginLimits struct {
	MaxObservationLength uint64 `protobuf:"varint,1,opt,name=maxObservationLength,proto3" json:"maxObservationLength,omitempty"`
	MaxReportLength      uint64 `protobuf:"varint,2,opt,name=maxReportLength,proto3" json:"maxReportLength,omitempty"`
	// contains filtered or unexported fields
}

MercuryPluginLimits represents github.com/goplugin/plugin-libocr/offchainreporting2plus/types.MercuryPluginLimits

func (*MercuryPluginLimits) Descriptor deprecated 

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

Deprecated: Use MercuryPluginLimits.ProtoReflect.Descriptor instead.

func (*MercuryPluginLimits) GetMaxObservationLength 

func (x *MercuryPluginLimits) GetMaxObservationLength() uint64

func (*MercuryPluginLimits) GetMaxReportLength 

func (x *MercuryPluginLimits) GetMaxReportLength() uint64

func (*MercuryPluginLimits) ProtoMessage 

func (*MercuryPluginLimits) ProtoMessage()

func (*MercuryPluginLimits) ProtoReflect 

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

func (*MercuryPluginLimits) Reset 

func (x *MercuryPluginLimits) Reset()

func (*MercuryPluginLimits) String 

func (x *MercuryPluginLimits) String() string

type MercuryPluginServer 

type MercuryPluginServer interface {
	Observation(context.Context, *ObservationRequest) (*ObservationResponse, error)
	Report(context.Context, *ReportRequest) (*ReportResponse, error)
	Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

MercuryPluginServer is the server API for MercuryPlugin service. All implementations must embed UnimplementedMercuryPluginServer for forward compatibility

type NewMercuryPluginRequest 

type NewMercuryPluginRequest struct {
	MercuryPluginConfig *MercuryPluginConfig `protobuf:"bytes,1,opt,name=mercuryPluginConfig,proto3" json:"mercuryPluginConfig,omitempty"`
	// contains filtered or unexported fields
}

func (*NewMercuryPluginRequest) Descriptor deprecated 

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

Deprecated: Use NewMercuryPluginRequest.ProtoReflect.Descriptor instead.

func (*NewMercuryPluginRequest) GetMercuryPluginConfig 

func (x *NewMercuryPluginRequest) GetMercuryPluginConfig() *MercuryPluginConfig

func (*NewMercuryPluginRequest) ProtoMessage 

func (*NewMercuryPluginRequest) ProtoMessage()

func (*NewMercuryPluginRequest) ProtoReflect 

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

func (*NewMercuryPluginRequest) Reset 

func (x *NewMercuryPluginRequest) Reset()

func (*NewMercuryPluginRequest) String 

func (x *NewMercuryPluginRequest) String() string

type NewMercuryPluginResponse 

type NewMercuryPluginResponse struct {
	MercuryPluginID   uint32             `protobuf:"varint,1,opt,name=mercuryPluginID,proto3" json:"mercuryPluginID,omitempty"`
	MercuryPluginInfo *MercuryPluginInfo `protobuf:"bytes,2,opt,name=mercuryPluginInfo,proto3" json:"mercuryPluginInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*NewMercuryPluginResponse) Descriptor deprecated 

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

Deprecated: Use NewMercuryPluginResponse.ProtoReflect.Descriptor instead.

func (*NewMercuryPluginResponse) GetMercuryPluginID 

func (x *NewMercuryPluginResponse) GetMercuryPluginID() uint32

func (*NewMercuryPluginResponse) GetMercuryPluginInfo 

func (x *NewMercuryPluginResponse) GetMercuryPluginInfo() *MercuryPluginInfo

func (*NewMercuryPluginResponse) ProtoMessage 

func (*NewMercuryPluginResponse) ProtoMessage()

func (*NewMercuryPluginResponse) ProtoReflect 

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

func (*NewMercuryPluginResponse) Reset 

func (x *NewMercuryPluginResponse) Reset()

func (*NewMercuryPluginResponse) String 

func (x *NewMercuryPluginResponse) String() string

type NewMercuryV1FactoryReply 

type NewMercuryV1FactoryReply struct {
	MercuryV1FactoryID uint32 `protobuf:"varint,1,opt,name=mercuryV1FactoryID,proto3" json:"mercuryV1FactoryID,omitempty"`
	// contains filtered or unexported fields
}

NewMercuryV1FactoryReply tracks the factory identifier used for brokering connecitons.

func (*NewMercuryV1FactoryReply) Descriptor deprecated 

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

Deprecated: Use NewMercuryV1FactoryReply.ProtoReflect.Descriptor instead.

func (*NewMercuryV1FactoryReply) GetMercuryV1FactoryID 

func (x *NewMercuryV1FactoryReply) GetMercuryV1FactoryID() uint32

func (*NewMercuryV1FactoryReply) ProtoMessage 

func (*NewMercuryV1FactoryReply) ProtoMessage()

func (*NewMercuryV1FactoryReply) ProtoReflect 

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

func (*NewMercuryV1FactoryReply) Reset 

func (x *NewMercuryV1FactoryReply) Reset()

func (*NewMercuryV1FactoryReply) String 

func (x *NewMercuryV1FactoryReply) String() string

type NewMercuryV1FactoryRequest 

type NewMercuryV1FactoryRequest struct {
	MercuryProviderID uint32 `protobuf:"varint,1,opt,name=mercuryProviderID,proto3" json:"mercuryProviderID,omitempty"`
	DataSourceV1ID    uint32 `protobuf:"varint,2,opt,name=dataSourceV1ID,proto3" json:"dataSourceV1ID,omitempty"` // id of the data source server for this factory instance
	// contains filtered or unexported fields
}

NewMercuryV1FactoryRequest is a grpc wrapper for the input to github.com/goplugin/plugin-data-streams/mercury/v1/NewFactory.

func (*NewMercuryV1FactoryRequest) Descriptor deprecated 

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

Deprecated: Use NewMercuryV1FactoryRequest.ProtoReflect.Descriptor instead.

func (*NewMercuryV1FactoryRequest) GetDataSourceV1ID 

func (x *NewMercuryV1FactoryRequest) GetDataSourceV1ID() uint32

func (*NewMercuryV1FactoryRequest) GetMercuryProviderID 

func (x *NewMercuryV1FactoryRequest) GetMercuryProviderID() uint32

func (*NewMercuryV1FactoryRequest) ProtoMessage 

func (*NewMercuryV1FactoryRequest) ProtoMessage()

func (*NewMercuryV1FactoryRequest) ProtoReflect 

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

func (*NewMercuryV1FactoryRequest) Reset 

func (x *NewMercuryV1FactoryRequest) Reset()

func (*NewMercuryV1FactoryRequest) String 

func (x *NewMercuryV1FactoryRequest) String() string

type NewMercuryV2FactoryReply 

type NewMercuryV2FactoryReply struct {
	MercuryV2FactoryID uint32 `protobuf:"varint,1,opt,name=mercuryV2FactoryID,proto3" json:"mercuryV2FactoryID,omitempty"`
	// contains filtered or unexported fields
}

NewMercuryV2FactoryReply tracks the factory identifier used for brokering connecitons.

func (*NewMercuryV2FactoryReply) Descriptor deprecated 

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

Deprecated: Use NewMercuryV2FactoryReply.ProtoReflect.Descriptor instead.

func (*NewMercuryV2FactoryReply) GetMercuryV2FactoryID 

func (x *NewMercuryV2FactoryReply) GetMercuryV2FactoryID() uint32

func (*NewMercuryV2FactoryReply) ProtoMessage 

func (*NewMercuryV2FactoryReply) ProtoMessage()

func (*NewMercuryV2FactoryReply) ProtoReflect 

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

func (*NewMercuryV2FactoryReply) Reset 

func (x *NewMercuryV2FactoryReply) Reset()

func (*NewMercuryV2FactoryReply) String 

func (x *NewMercuryV2FactoryReply) String() string

type NewMercuryV2FactoryRequest 

type NewMercuryV2FactoryRequest struct {
	MercuryProviderID uint32 `protobuf:"varint,1,opt,name=mercuryProviderID,proto3" json:"mercuryProviderID,omitempty"`
	DataSourceV2ID    uint32 `protobuf:"varint,2,opt,name=dataSourceV2ID,proto3" json:"dataSourceV2ID,omitempty"` // id of the data source server for this factory instance
	// contains filtered or unexported fields
}

NewMercuryV2FactoryRequest is a grpc wrapper for the input to github.com/goplugin/plugin-data-streams/mercury/v2/NewFactory.

func (*NewMercuryV2FactoryRequest) Descriptor deprecated 

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

Deprecated: Use NewMercuryV2FactoryRequest.ProtoReflect.Descriptor instead.

func (*NewMercuryV2FactoryRequest) GetDataSourceV2ID 

func (x *NewMercuryV2FactoryRequest) GetDataSourceV2ID() uint32

func (*NewMercuryV2FactoryRequest) GetMercuryProviderID 

func (x *NewMercuryV2FactoryRequest) GetMercuryProviderID() uint32

func (*NewMercuryV2FactoryRequest) ProtoMessage 

func (*NewMercuryV2FactoryRequest) ProtoMessage()

func (*NewMercuryV2FactoryRequest) ProtoReflect 

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

func (*NewMercuryV2FactoryRequest) Reset 

func (x *NewMercuryV2FactoryRequest) Reset()

func (*NewMercuryV2FactoryRequest) String 

func (x *NewMercuryV2FactoryRequest) String() string

type NewMercuryV3FactoryReply 

type NewMercuryV3FactoryReply struct {
	MercuryV3FactoryID uint32 `protobuf:"varint,1,opt,name=mercuryV3FactoryID,proto3" json:"mercuryV3FactoryID,omitempty"`
	// contains filtered or unexported fields
}

NewMercuryV3FactoryReply tracks the factory identifier used for brokering connecitons.

func (*NewMercuryV3FactoryReply) Descriptor deprecated 

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

Deprecated: Use NewMercuryV3FactoryReply.ProtoReflect.Descriptor instead.

func (*NewMercuryV3FactoryReply) GetMercuryV3FactoryID 

func (x *NewMercuryV3FactoryReply) GetMercuryV3FactoryID() uint32

func (*NewMercuryV3FactoryReply) ProtoMessage 

func (*NewMercuryV3FactoryReply) ProtoMessage()

func (*NewMercuryV3FactoryReply) ProtoReflect 

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

func (*NewMercuryV3FactoryReply) Reset 

func (x *NewMercuryV3FactoryReply) Reset()

func (*NewMercuryV3FactoryReply) String 

func (x *NewMercuryV3FactoryReply) String() string

type NewMercuryV3FactoryRequest 

type NewMercuryV3FactoryRequest struct {
	MercuryProviderID uint32 `protobuf:"varint,1,opt,name=mercuryProviderID,proto3" json:"mercuryProviderID,omitempty"`
	DataSourceV3ID    uint32 `protobuf:"varint,2,opt,name=dataSourceV3ID,proto3" json:"dataSourceV3ID,omitempty"` // id of the data source server for this factory instance
	// contains filtered or unexported fields
}

NewMercuryV3FactoryRequest is a grpc wrapper for the input to github.com/goplugin/plugin-data-streams/mercury/v3/NewFactory.

func (*NewMercuryV3FactoryRequest) Descriptor deprecated 

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

Deprecated: Use NewMercuryV3FactoryRequest.ProtoReflect.Descriptor instead.

func (*NewMercuryV3FactoryRequest) GetDataSourceV3ID 

func (x *NewMercuryV3FactoryRequest) GetDataSourceV3ID() uint32

func (*NewMercuryV3FactoryRequest) GetMercuryProviderID 

func (x *NewMercuryV3FactoryRequest) GetMercuryProviderID() uint32

func (*NewMercuryV3FactoryRequest) ProtoMessage 

func (*NewMercuryV3FactoryRequest) ProtoMessage()

func (*NewMercuryV3FactoryRequest) ProtoReflect 

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

func (*NewMercuryV3FactoryRequest) Reset 

func (x *NewMercuryV3FactoryRequest) Reset()

func (*NewMercuryV3FactoryRequest) String 

func (x *NewMercuryV3FactoryRequest) String() string

type NewMercuryV4FactoryReply 

type NewMercuryV4FactoryReply struct {
	MercuryV4FactoryID uint32 `protobuf:"varint,1,opt,name=mercuryV4FactoryID,proto3" json:"mercuryV4FactoryID,omitempty"`
	// contains filtered or unexported fields
}

NewMercuryV4FactoryReply tracks the factory identifier used for brokering connecitons.

func (*NewMercuryV4FactoryReply) Descriptor deprecated 

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

Deprecated: Use NewMercuryV4FactoryReply.ProtoReflect.Descriptor instead.

func (*NewMercuryV4FactoryReply) GetMercuryV4FactoryID 

func (x *NewMercuryV4FactoryReply) GetMercuryV4FactoryID() uint32

func (*NewMercuryV4FactoryReply) ProtoMessage 

func (*NewMercuryV4FactoryReply) ProtoMessage()

func (*NewMercuryV4FactoryReply) ProtoReflect 

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

func (*NewMercuryV4FactoryReply) Reset 

func (x *NewMercuryV4FactoryReply) Reset()

func (*NewMercuryV4FactoryReply) String 

func (x *NewMercuryV4FactoryReply) String() string

type NewMercuryV4FactoryRequest 

type NewMercuryV4FactoryRequest struct {
	MercuryProviderID uint32 `protobuf:"varint,1,opt,name=mercuryProviderID,proto3" json:"mercuryProviderID,omitempty"`
	DataSourceV4ID    uint32 `protobuf:"varint,2,opt,name=dataSourceV4ID,proto3" json:"dataSourceV4ID,omitempty"` // id of the data source server for this factory instance
	// contains filtered or unexported fields
}

NewMercuryV4FactoryRequest is a grpc wrapper for the input to github.com/goplugin/plugin-data-streams/mercury/v4/NewFactory.

func (*NewMercuryV4FactoryRequest) Descriptor deprecated 

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

Deprecated: Use NewMercuryV4FactoryRequest.ProtoReflect.Descriptor instead.

func (*NewMercuryV4FactoryRequest) GetDataSourceV4ID 

func (x *NewMercuryV4FactoryRequest) GetDataSourceV4ID() uint32

func (*NewMercuryV4FactoryRequest) GetMercuryProviderID 

func (x *NewMercuryV4FactoryRequest) GetMercuryProviderID() uint32

func (*NewMercuryV4FactoryRequest) ProtoMessage 

func (*NewMercuryV4FactoryRequest) ProtoMessage()

func (*NewMercuryV4FactoryRequest) ProtoReflect 

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

func (*NewMercuryV4FactoryRequest) Reset 

func (x *NewMercuryV4FactoryRequest) Reset()

func (*NewMercuryV4FactoryRequest) String 

func (x *NewMercuryV4FactoryRequest) String() string

type ObservationRequest 

type ObservationRequest struct {
	ReportTimestamp *pb.ReportTimestamp `protobuf:"bytes,1,opt,name=reportTimestamp,proto3" json:"reportTimestamp,omitempty"`
	PreviousReport  []byte              `protobuf:"bytes,2,opt,name=previousReport,proto3" json:"previousReport,omitempty"`
	// contains filtered or unexported fields
}

ObservationRequest has arguments for github.com/goplugin/plugin-libocr/offchainreporting2plus/types.MercuryPlugin.Observation.

func (*ObservationRequest) Descriptor deprecated 

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

Deprecated: Use ObservationRequest.ProtoReflect.Descriptor instead.

func (*ObservationRequest) GetPreviousReport 

func (x *ObservationRequest) GetPreviousReport() []byte

func (*ObservationRequest) GetReportTimestamp 

func (x *ObservationRequest) GetReportTimestamp() *pb.ReportTimestamp

func (*ObservationRequest) ProtoMessage 

func (*ObservationRequest) ProtoMessage()

func (*ObservationRequest) ProtoReflect 

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

func (*ObservationRequest) Reset 

func (x *ObservationRequest) Reset()

func (*ObservationRequest) String 

func (x *ObservationRequest) String() string

type ObservationResponse 

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

ObservationResponse has return arguments for github.com/goplugin/plugin-libocr/offchainreporting2plus/types.MercuryPlugin.Observation.

func (*ObservationResponse) Descriptor deprecated 

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

Deprecated: Use ObservationResponse.ProtoReflect.Descriptor instead.

func (*ObservationResponse) GetObservation 

func (x *ObservationResponse) GetObservation() []byte

func (*ObservationResponse) ProtoMessage 

func (*ObservationResponse) ProtoMessage()

func (*ObservationResponse) ProtoReflect 

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

func (*ObservationResponse) Reset 

func (x *ObservationResponse) Reset()

func (*ObservationResponse) String 

func (x *ObservationResponse) String() string

type OnchainConfig 

type OnchainConfig struct {
	Min *pb.BigInt `protobuf:"bytes,1,opt,name=min,proto3" json:"min,omitempty"`
	Max *pb.BigInt `protobuf:"bytes,2,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

OnchainConfig is a gRPC adapter for the OnchainConfig struct pkg/types/mercury/OnchainConfig.

func (*OnchainConfig) Descriptor deprecated 

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

Deprecated: Use OnchainConfig.ProtoReflect.Descriptor instead.

func (*OnchainConfig) GetMax 

func (x *OnchainConfig) GetMax() *pb.BigInt

func (*OnchainConfig) GetMin 

func (x *OnchainConfig) GetMin() *pb.BigInt

func (*OnchainConfig) ProtoMessage 

func (*OnchainConfig) ProtoMessage()

func (*OnchainConfig) ProtoReflect 

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

func (*OnchainConfig) Reset 

func (x *OnchainConfig) Reset()

func (*OnchainConfig) String 

func (x *OnchainConfig) String() string

type OnchainConfigCodecClient 

type OnchainConfigCodecClient interface {
	Encode(ctx context.Context, in *EncodeOnchainConfigRequest, opts ...grpc.CallOption) (*EncodeOnchainConfigReply, error)
	Decode(ctx context.Context, in *DecodeOnchainConfigRequest, opts ...grpc.CallOption) (*DecodeOnchainConfigReply, error)
}

OnchainConfigCodecClient is the client API for OnchainConfigCodec 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 NewOnchainConfigCodecClient 

func NewOnchainConfigCodecClient(cc grpc.ClientConnInterface) OnchainConfigCodecClient

type OnchainConfigCodecServer 

type OnchainConfigCodecServer interface {
	Encode(context.Context, *EncodeOnchainConfigRequest) (*EncodeOnchainConfigReply, error)
	Decode(context.Context, *DecodeOnchainConfigRequest) (*DecodeOnchainConfigReply, error)
	// contains filtered or unexported methods
}

OnchainConfigCodecServer is the server API for OnchainConfigCodec service. All implementations must embed UnimplementedOnchainConfigCodecServer for forward compatibility

type ReportCodecV1Client 

type ReportCodecV1Client interface {
	BuildReport(ctx context.Context, in *v1.BuildReportRequest, opts ...grpc.CallOption) (*v1.BuildReportReply, error)
	MaxReportLength(ctx context.Context, in *v1.MaxReportLengthRequest, opts ...grpc.CallOption) (*v1.MaxReportLengthReply, error)
	CurrentBlockNumFromReport(ctx context.Context, in *v1.CurrentBlockNumFromReportRequest, opts ...grpc.CallOption) (*v1.CurrentBlockNumFromReportResponse, error)
}

ReportCodecV1Client is the client API for ReportCodecV1 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 NewReportCodecV1Client 

func NewReportCodecV1Client(cc grpc.ClientConnInterface) ReportCodecV1Client

type ReportCodecV1Server 

type ReportCodecV1Server interface {
	BuildReport(context.Context, *v1.BuildReportRequest) (*v1.BuildReportReply, error)
	MaxReportLength(context.Context, *v1.MaxReportLengthRequest) (*v1.MaxReportLengthReply, error)
	CurrentBlockNumFromReport(context.Context, *v1.CurrentBlockNumFromReportRequest) (*v1.CurrentBlockNumFromReportResponse, error)
	// contains filtered or unexported methods
}

ReportCodecV1Server is the server API for ReportCodecV1 service. All implementations must embed UnimplementedReportCodecV1Server for forward compatibility

type ReportCodecV2Client 

type ReportCodecV2Client interface {
	BuildReport(ctx context.Context, in *v2.BuildReportRequest, opts ...grpc.CallOption) (*v2.BuildReportReply, error)
	MaxReportLength(ctx context.Context, in *v2.MaxReportLengthRequest, opts ...grpc.CallOption) (*v2.MaxReportLengthReply, error)
	ObservationTimestampFromReport(ctx context.Context, in *v2.ObservationTimestampFromReportRequest, opts ...grpc.CallOption) (*v2.ObservationTimestampFromReportReply, error)
}

ReportCodecV2Client is the client API for ReportCodecV2 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 NewReportCodecV2Client 

func NewReportCodecV2Client(cc grpc.ClientConnInterface) ReportCodecV2Client

type ReportCodecV2Server 

type ReportCodecV2Server interface {
	BuildReport(context.Context, *v2.BuildReportRequest) (*v2.BuildReportReply, error)
	MaxReportLength(context.Context, *v2.MaxReportLengthRequest) (*v2.MaxReportLengthReply, error)
	ObservationTimestampFromReport(context.Context, *v2.ObservationTimestampFromReportRequest) (*v2.ObservationTimestampFromReportReply, error)
	// contains filtered or unexported methods
}

ReportCodecV2Server is the server API for ReportCodecV2 service. All implementations must embed UnimplementedReportCodecV2Server for forward compatibility

type ReportCodecV3Client 

type ReportCodecV3Client interface {
	BuildReport(ctx context.Context, in *v3.BuildReportRequest, opts ...grpc.CallOption) (*v3.BuildReportReply, error)
	MaxReportLength(ctx context.Context, in *v3.MaxReportLengthRequest, opts ...grpc.CallOption) (*v3.MaxReportLengthReply, error)
	ObservationTimestampFromReport(ctx context.Context, in *v3.ObservationTimestampFromReportRequest, opts ...grpc.CallOption) (*v3.ObservationTimestampFromReportReply, error)
}

ReportCodecV3Client is the client API for ReportCodecV3 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 NewReportCodecV3Client 

func NewReportCodecV3Client(cc grpc.ClientConnInterface) ReportCodecV3Client

type ReportCodecV3Server 

type ReportCodecV3Server interface {
	BuildReport(context.Context, *v3.BuildReportRequest) (*v3.BuildReportReply, error)
	MaxReportLength(context.Context, *v3.MaxReportLengthRequest) (*v3.MaxReportLengthReply, error)
	ObservationTimestampFromReport(context.Context, *v3.ObservationTimestampFromReportRequest) (*v3.ObservationTimestampFromReportReply, error)
	// contains filtered or unexported methods
}

ReportCodecV3Server is the server API for ReportCodecV3 service. All implementations must embed UnimplementedReportCodecV3Server for forward compatibility

type ReportCodecV4Client 

type ReportCodecV4Client interface {
	BuildReport(ctx context.Context, in *v4.BuildReportRequest, opts ...grpc.CallOption) (*v4.BuildReportReply, error)
	MaxReportLength(ctx context.Context, in *v4.MaxReportLengthRequest, opts ...grpc.CallOption) (*v4.MaxReportLengthReply, error)
	ObservationTimestampFromReport(ctx context.Context, in *v4.ObservationTimestampFromReportRequest, opts ...grpc.CallOption) (*v4.ObservationTimestampFromReportReply, error)
}

ReportCodecV4Client is the client API for ReportCodecV4 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 NewReportCodecV4Client 

func NewReportCodecV4Client(cc grpc.ClientConnInterface) ReportCodecV4Client

type ReportCodecV4Server 

type ReportCodecV4Server interface {
	BuildReport(context.Context, *v4.BuildReportRequest) (*v4.BuildReportReply, error)
	MaxReportLength(context.Context, *v4.MaxReportLengthRequest) (*v4.MaxReportLengthReply, error)
	ObservationTimestampFromReport(context.Context, *v4.ObservationTimestampFromReportRequest) (*v4.ObservationTimestampFromReportReply, error)
	// contains filtered or unexported methods
}

ReportCodecV4Server is the server API for ReportCodecV4 service. All implementations must embed UnimplementedReportCodecV4Server for forward compatibility

type ReportRequest 

type ReportRequest struct {
	ReportTimestamp *pb.ReportTimestamp      `protobuf:"bytes,1,opt,name=reportTimestamp,proto3" json:"reportTimestamp,omitempty"`
	PreviousReport  []byte                   `protobuf:"bytes,2,opt,name=previousReport,proto3" json:"previousReport,omitempty"`
	Observations    []*AttributedObservation `protobuf:"bytes,3,rep,name=observations,proto3" json:"observations,omitempty"`
	// contains filtered or unexported fields
}

ReportRequest has arguments for github.com/goplugin/plugin-libocr/offchainreporting2plus/types.MercuryPlugin.Report.

func (*ReportRequest) Descriptor deprecated 

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

Deprecated: Use ReportRequest.ProtoReflect.Descriptor instead.

func (*ReportRequest) GetObservations 

func (x *ReportRequest) GetObservations() []*AttributedObservation

func (*ReportRequest) GetPreviousReport 

func (x *ReportRequest) GetPreviousReport() []byte

func (*ReportRequest) GetReportTimestamp 

func (x *ReportRequest) GetReportTimestamp() *pb.ReportTimestamp

func (*ReportRequest) ProtoMessage 

func (*ReportRequest) ProtoMessage()

func (*ReportRequest) ProtoReflect 

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

func (*ReportRequest) Reset 

func (x *ReportRequest) Reset()

func (*ReportRequest) String 

func (x *ReportRequest) String() string

type ReportResponse 

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

ReportResponse has return arguments for github.com/goplugin/plugin-libocr/offchainreporting2plus/types.MercuryPlugin.Report.

func (*ReportResponse) Descriptor deprecated 

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

Deprecated: Use ReportResponse.ProtoReflect.Descriptor instead.

func (*ReportResponse) GetReport 

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

func (*ReportResponse) GetShouldReport 

func (x *ReportResponse) GetShouldReport() bool

func (*ReportResponse) ProtoMessage 

func (*ReportResponse) ProtoMessage()

func (*ReportResponse) ProtoReflect 

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

func (*ReportResponse) Reset 

func (x *ReportResponse) Reset()

func (*ReportResponse) String 

func (x *ReportResponse) String() string

type ServerFetcherClient 

type ServerFetcherClient interface {
	FetchInitialMaxFinalizedBlockNumber(ctx context.Context, in *FetchInitialMaxFinalizedBlockNumberRequest, opts ...grpc.CallOption) (*FetchInitialMaxFinalizedBlockNumberReply, error)
	LatestPrice(ctx context.Context, in *LatestPriceRequest, opts ...grpc.CallOption) (*LatestPriceReply, error)
	LatestTimestamp(ctx context.Context, in *LatestTimestampRequest, opts ...grpc.CallOption) (*LatestTimestampReply, error)
}

ServerFetcherClient is the client API for ServerFetcher 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 NewServerFetcherClient 

func NewServerFetcherClient(cc grpc.ClientConnInterface) ServerFetcherClient

type ServerFetcherServer 

type ServerFetcherServer interface {
	FetchInitialMaxFinalizedBlockNumber(context.Context, *FetchInitialMaxFinalizedBlockNumberRequest) (*FetchInitialMaxFinalizedBlockNumberReply, error)
	LatestPrice(context.Context, *LatestPriceRequest) (*LatestPriceReply, error)
	LatestTimestamp(context.Context, *LatestTimestampRequest) (*LatestTimestampReply, error)
	// contains filtered or unexported methods
}

ServerFetcherServer is the server API for ServerFetcher service. All implementations must embed UnimplementedServerFetcherServer for forward compatibility

type UnimplementedMercuryAdapterServer 

type UnimplementedMercuryAdapterServer struct {
}

UnimplementedMercuryAdapterServer must be embedded to have forward compatible implementations.

func (UnimplementedMercuryAdapterServer) NewMercuryV1Factory 

func (UnimplementedMercuryAdapterServer) NewMercuryV1Factory(context.Context, *NewMercuryV1FactoryRequest) (*NewMercuryV1FactoryReply, error)

func (UnimplementedMercuryAdapterServer) NewMercuryV2Factory 

func (UnimplementedMercuryAdapterServer) NewMercuryV2Factory(context.Context, *NewMercuryV2FactoryRequest) (*NewMercuryV2FactoryReply, error)

func (UnimplementedMercuryAdapterServer) NewMercuryV3Factory 

func (UnimplementedMercuryAdapterServer) NewMercuryV3Factory(context.Context, *NewMercuryV3FactoryRequest) (*NewMercuryV3FactoryReply, error)

func (UnimplementedMercuryAdapterServer) NewMercuryV4Factory 

func (UnimplementedMercuryAdapterServer) NewMercuryV4Factory(context.Context, *NewMercuryV4FactoryRequest) (*NewMercuryV4FactoryReply, error)

type UnimplementedMercuryChainReaderServer 

type UnimplementedMercuryChainReaderServer struct {
}

UnimplementedMercuryChainReaderServer must be embedded to have forward compatible implementations.

func (UnimplementedMercuryChainReaderServer) LatestHeads 

func (UnimplementedMercuryChainReaderServer) LatestHeads(context.Context, *LatestHeadsRequest) (*LatestHeadsReply, error)

type UnimplementedMercuryPluginFactoryServer 

type UnimplementedMercuryPluginFactoryServer struct {
}

UnimplementedMercuryPluginFactoryServer must be embedded to have forward compatible implementations.

func (UnimplementedMercuryPluginFactoryServer) NewMercuryPlugin 

func (UnimplementedMercuryPluginFactoryServer) NewMercuryPlugin(context.Context, *NewMercuryPluginRequest) (*NewMercuryPluginResponse, error)

type UnimplementedMercuryPluginServer 

type UnimplementedMercuryPluginServer struct {
}

UnimplementedMercuryPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedMercuryPluginServer) Close 

func (UnimplementedMercuryPluginServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedMercuryPluginServer) Observation 

func (UnimplementedMercuryPluginServer) Observation(context.Context, *ObservationRequest) (*ObservationResponse, error)

func (UnimplementedMercuryPluginServer) Report 

func (UnimplementedMercuryPluginServer) Report(context.Context, *ReportRequest) (*ReportResponse, error)

type UnimplementedOnchainConfigCodecServer 

type UnimplementedOnchainConfigCodecServer struct {
}

UnimplementedOnchainConfigCodecServer must be embedded to have forward compatible implementations.

func (UnimplementedOnchainConfigCodecServer) Decode 

func (UnimplementedOnchainConfigCodecServer) Decode(context.Context, *DecodeOnchainConfigRequest) (*DecodeOnchainConfigReply, error)

func (UnimplementedOnchainConfigCodecServer) Encode 

func (UnimplementedOnchainConfigCodecServer) Encode(context.Context, *EncodeOnchainConfigRequest) (*EncodeOnchainConfigReply, error)

type UnimplementedReportCodecV1Server 

type UnimplementedReportCodecV1Server struct {
}

UnimplementedReportCodecV1Server must be embedded to have forward compatible implementations.

func (UnimplementedReportCodecV1Server) BuildReport 

func (UnimplementedReportCodecV1Server) BuildReport(context.Context, *v1.BuildReportRequest) (*v1.BuildReportReply, error)

func (UnimplementedReportCodecV1Server) CurrentBlockNumFromReport 

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

func (UnimplementedReportCodecV1Server) MaxReportLength 

func (UnimplementedReportCodecV1Server) MaxReportLength(context.Context, *v1.MaxReportLengthRequest) (*v1.MaxReportLengthReply, error)

type UnimplementedReportCodecV2Server 

type UnimplementedReportCodecV2Server struct {
}

UnimplementedReportCodecV2Server must be embedded to have forward compatible implementations.

func (UnimplementedReportCodecV2Server) BuildReport 

func (UnimplementedReportCodecV2Server) BuildReport(context.Context, *v2.BuildReportRequest) (*v2.BuildReportReply, error)

func (UnimplementedReportCodecV2Server) MaxReportLength 

func (UnimplementedReportCodecV2Server) MaxReportLength(context.Context, *v2.MaxReportLengthRequest) (*v2.MaxReportLengthReply, error)

func (UnimplementedReportCodecV2Server) ObservationTimestampFromReport 

func (UnimplementedReportCodecV2Server) ObservationTimestampFromReport(context.Context, *v2.ObservationTimestampFromReportRequest) (*v2.ObservationTimestampFromReportReply, error)

type UnimplementedReportCodecV3Server 

type UnimplementedReportCodecV3Server struct {
}

UnimplementedReportCodecV3Server must be embedded to have forward compatible implementations.

func (UnimplementedReportCodecV3Server) BuildReport 

func (UnimplementedReportCodecV3Server) BuildReport(context.Context, *v3.BuildReportRequest) (*v3.BuildReportReply, error)

func (UnimplementedReportCodecV3Server) MaxReportLength 

func (UnimplementedReportCodecV3Server) MaxReportLength(context.Context, *v3.MaxReportLengthRequest) (*v3.MaxReportLengthReply, error)

func (UnimplementedReportCodecV3Server) ObservationTimestampFromReport 

func (UnimplementedReportCodecV3Server) ObservationTimestampFromReport(context.Context, *v3.ObservationTimestampFromReportRequest) (*v3.ObservationTimestampFromReportReply, error)

type UnimplementedReportCodecV4Server 

type UnimplementedReportCodecV4Server struct {
}

UnimplementedReportCodecV4Server must be embedded to have forward compatible implementations.

func (UnimplementedReportCodecV4Server) BuildReport 

func (UnimplementedReportCodecV4Server) BuildReport(context.Context, *v4.BuildReportRequest) (*v4.BuildReportReply, error)

func (UnimplementedReportCodecV4Server) MaxReportLength 

func (UnimplementedReportCodecV4Server) MaxReportLength(context.Context, *v4.MaxReportLengthRequest) (*v4.MaxReportLengthReply, error)

func (UnimplementedReportCodecV4Server) ObservationTimestampFromReport 

func (UnimplementedReportCodecV4Server) ObservationTimestampFromReport(context.Context, *v4.ObservationTimestampFromReportRequest) (*v4.ObservationTimestampFromReportReply, error)

type UnimplementedServerFetcherServer 

type UnimplementedServerFetcherServer struct {
}

UnimplementedServerFetcherServer must be embedded to have forward compatible implementations.

func (UnimplementedServerFetcherServer) FetchInitialMaxFinalizedBlockNumber 

func (UnimplementedServerFetcherServer) FetchInitialMaxFinalizedBlockNumber(context.Context, *FetchInitialMaxFinalizedBlockNumberRequest) (*FetchInitialMaxFinalizedBlockNumberReply, error)

func (UnimplementedServerFetcherServer) LatestPrice 

func (UnimplementedServerFetcherServer) LatestPrice(context.Context, *LatestPriceRequest) (*LatestPriceReply, error)

func (UnimplementedServerFetcherServer) LatestTimestamp 

func (UnimplementedServerFetcherServer) LatestTimestamp(context.Context, *LatestTimestampRequest) (*LatestTimestampReply, error)

type UnsafeMercuryAdapterServer 

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

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

type UnsafeMercuryChainReaderServer 

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

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

type UnsafeMercuryPluginFactoryServer 

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

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

type UnsafeMercuryPluginServer 

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

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

type UnsafeOnchainConfigCodecServer 

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

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

type UnsafeReportCodecV1Server 

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

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

type UnsafeReportCodecV2Server 

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

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

type UnsafeReportCodecV3Server 

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

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

type UnsafeReportCodecV4Server 

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

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

type UnsafeServerFetcherServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis
NOTE: the relative paths in the proto_path are to ensure we find common utilities, like BigInt
 NOTE: the relative paths in the proto_path are to ensure we find common utilities, like BigInt

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.