pb

package
v0.0.0-...-47b5856 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ChainReader_GetLatestValue_FullMethodName = "/loop.ChainReader/GetLatestValue"
	ChainReader_Bind_FullMethodName           = "/loop.ChainReader/Bind"
)
View Source 
const (
	Codec_GetEncoding_FullMethodName = "/loop.Codec/GetEncoding"
	Codec_GetDecoding_FullMethodName = "/loop.Codec/GetDecoding"
	Codec_GetMaxSize_FullMethodName  = "/loop.Codec/GetMaxSize"
)
View Source 
const (
	ReportCodec_BuildReport_FullMethodName      = "/loop.ReportCodec/BuildReport"
	ReportCodec_MedianFromReport_FullMethodName = "/loop.ReportCodec/MedianFromReport"
	ReportCodec_MaxReportLength_FullMethodName  = "/loop.ReportCodec/MaxReportLength"
)
View Source 
const (
	MedianContract_LatestTransmissionDetails_FullMethodName = "/loop.MedianContract/LatestTransmissionDetails"
	MedianContract_LatestRoundRequested_FullMethodName      = "/loop.MedianContract/LatestRoundRequested"
)
View Source 
const (
	OnchainConfigCodec_Encode_FullMethodName = "/loop.OnchainConfigCodec/Encode"
	OnchainConfigCodec_Decode_FullMethodName = "/loop.OnchainConfigCodec/Decode"
)
View Source 
const (
	Keystore_Accounts_FullMethodName = "/loop.Keystore/Accounts"
	Keystore_Sign_FullMethodName     = "/loop.Keystore/Sign"
)
View Source 
const (
	Relayer_NewConfigProvider_FullMethodName = "/loop.Relayer/NewConfigProvider"
	Relayer_NewPluginProvider_FullMethodName = "/loop.Relayer/NewPluginProvider"
	Relayer_GetChainStatus_FullMethodName    = "/loop.Relayer/GetChainStatus"
	Relayer_ListNodeStatuses_FullMethodName  = "/loop.Relayer/ListNodeStatuses"
	Relayer_Transact_FullMethodName          = "/loop.Relayer/Transact"
)
View Source 
const (
	OffchainConfigDigester_ConfigDigest_FullMethodName       = "/loop.OffchainConfigDigester/ConfigDigest"
	OffchainConfigDigester_ConfigDigestPrefix_FullMethodName = "/loop.OffchainConfigDigester/ConfigDigestPrefix"
)
View Source 
const (
	ContractConfigTracker_LatestConfigDetails_FullMethodName = "/loop.ContractConfigTracker/LatestConfigDetails"
	ContractConfigTracker_LatestConfig_FullMethodName        = "/loop.ContractConfigTracker/LatestConfig"
	ContractConfigTracker_LatestBlockHeight_FullMethodName   = "/loop.ContractConfigTracker/LatestBlockHeight"
)
View Source 
const (
	ContractTransmitter_Transmit_FullMethodName                   = "/loop.ContractTransmitter/Transmit"
	ContractTransmitter_LatestConfigDigestAndEpoch_FullMethodName = "/loop.ContractTransmitter/LatestConfigDigestAndEpoch"
	ContractTransmitter_FromAccount_FullMethodName                = "/loop.ContractTransmitter/FromAccount"
)
View Source 
const (
	Service_Name_FullMethodName         = "/loop.Service/Name"
	Service_Close_FullMethodName        = "/loop.Service/Close"
	Service_Ready_FullMethodName        = "/loop.Service/Ready"
	Service_HealthReport_FullMethodName = "/loop.Service/HealthReport"
)
View Source 
const (
	ReportingPlugin_Query_FullMethodName                        = "/loop.ReportingPlugin/Query"
	ReportingPlugin_Observation_FullMethodName                  = "/loop.ReportingPlugin/Observation"
	ReportingPlugin_Report_FullMethodName                       = "/loop.ReportingPlugin/Report"
	ReportingPlugin_ShouldAcceptFinalizedReport_FullMethodName  = "/loop.ReportingPlugin/ShouldAcceptFinalizedReport"
	ReportingPlugin_ShouldTransmitAcceptedReport_FullMethodName = "/loop.ReportingPlugin/ShouldTransmitAcceptedReport"
	ReportingPlugin_Close_FullMethodName                        = "/loop.ReportingPlugin/Close"
)
View Source 
const (
	DataSource_Observe_FullMethodName = "/loop.DataSource/Observe"
)
View Source 
const (
	ErrorLog_SaveError_FullMethodName = "/loop.ErrorLog/SaveError"
)
View Source 
const (
	PipelineRunnerService_ExecuteRun_FullMethodName = "/loop.PipelineRunnerService/ExecuteRun"
)
View Source 
const (
	PluginMedian_NewMedianFactory_FullMethodName = "/loop.PluginMedian/NewMedianFactory"
)
View Source 
const (
	PluginRelayer_NewRelayer_FullMethodName = "/loop.PluginRelayer/NewRelayer"
)
View Source 
const (
	ReportingPluginFactory_NewReportingPlugin_FullMethodName = "/loop.ReportingPluginFactory/NewReportingPlugin"
)
View Source 
const (
	ReportingPluginService_NewReportingPluginFactory_FullMethodName = "/loop.ReportingPluginService/NewReportingPluginFactory"
)
View Source 
const (
	Telemetry_Send_FullMethodName = "/loop.Telemetry/Send"
)

Variables

View Source 
var ChainReader_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ChainReader",
	HandlerType: (*ChainReaderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetLatestValue",
			Handler:    _ChainReader_GetLatestValue_Handler,
		},
		{
			MethodName: "Bind",
			Handler:    _ChainReader_Bind_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chain_reader.proto",
}

ChainReader_ServiceDesc is the grpc.ServiceDesc for ChainReader 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 Codec_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.Codec",
	HandlerType: (*CodecServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetEncoding",
			Handler:    _Codec_GetEncoding_Handler,
		},
		{
			MethodName: "GetDecoding",
			Handler:    _Codec_GetDecoding_Handler,
		},
		{
			MethodName: "GetMaxSize",
			Handler:    _Codec_GetMaxSize_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "codec.proto",
}

Codec_ServiceDesc is the grpc.ServiceDesc for Codec 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 ContractConfigTracker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ContractConfigTracker",
	HandlerType: (*ContractConfigTrackerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LatestConfigDetails",
			Handler:    _ContractConfigTracker_LatestConfigDetails_Handler,
		},
		{
			MethodName: "LatestConfig",
			Handler:    _ContractConfigTracker_LatestConfig_Handler,
		},
		{
			MethodName: "LatestBlockHeight",
			Handler:    _ContractConfigTracker_LatestBlockHeight_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

ContractConfigTracker_ServiceDesc is the grpc.ServiceDesc for ContractConfigTracker 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 ContractTransmitter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ContractTransmitter",
	HandlerType: (*ContractTransmitterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Transmit",
			Handler:    _ContractTransmitter_Transmit_Handler,
		},
		{
			MethodName: "LatestConfigDigestAndEpoch",
			Handler:    _ContractTransmitter_LatestConfigDigestAndEpoch_Handler,
		},
		{
			MethodName: "FromAccount",
			Handler:    _ContractTransmitter_FromAccount_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

ContractTransmitter_ServiceDesc is the grpc.ServiceDesc for ContractTransmitter 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 DataSource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.DataSource",
	HandlerType: (*DataSourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Observe",
			Handler:    _DataSource_Observe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

DataSource_ServiceDesc is the grpc.ServiceDesc for DataSource 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 ErrorLog_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ErrorLog",
	HandlerType: (*ErrorLogServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SaveError",
			Handler:    _ErrorLog_SaveError_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "median.proto",
}

ErrorLog_ServiceDesc is the grpc.ServiceDesc for ErrorLog 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 File_chain_reader_proto protoreflect.FileDescriptor
View Source 
var File_codec_proto protoreflect.FileDescriptor
View Source 
var File_median_proto protoreflect.FileDescriptor
View Source 
var File_pipeline_runner_proto protoreflect.FileDescriptor
View Source 
var File_relayer_proto protoreflect.FileDescriptor
View Source 
var File_reporting_plugin_service_proto protoreflect.FileDescriptor
View Source 
var File_reporting_proto protoreflect.FileDescriptor
View Source 
var File_telemetry_proto protoreflect.FileDescriptor
View Source 
var Keystore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.Keystore",
	HandlerType: (*KeystoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Accounts",
			Handler:    _Keystore_Accounts_Handler,
		},
		{
			MethodName: "Sign",
			Handler:    _Keystore_Sign_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

Keystore_ServiceDesc is the grpc.ServiceDesc for Keystore 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 MedianContract_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.MedianContract",
	HandlerType: (*MedianContractServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LatestTransmissionDetails",
			Handler:    _MedianContract_LatestTransmissionDetails_Handler,
		},
		{
			MethodName: "LatestRoundRequested",
			Handler:    _MedianContract_LatestRoundRequested_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "median.proto",
}

MedianContract_ServiceDesc is the grpc.ServiceDesc for MedianContract 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 OffchainConfigDigester_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.OffchainConfigDigester",
	HandlerType: (*OffchainConfigDigesterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ConfigDigest",
			Handler:    _OffchainConfigDigester_ConfigDigest_Handler,
		},
		{
			MethodName: "ConfigDigestPrefix",
			Handler:    _OffchainConfigDigester_ConfigDigestPrefix_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

OffchainConfigDigester_ServiceDesc is the grpc.ServiceDesc for OffchainConfigDigester 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.OnchainConfigCodec",
	HandlerType: (*OnchainConfigCodecServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Encode",
			Handler:    _OnchainConfigCodec_Encode_Handler,
		},
		{
			MethodName: "Decode",
			Handler:    _OnchainConfigCodec_Decode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "median.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 PipelineRunnerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.PipelineRunnerService",
	HandlerType: (*PipelineRunnerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecuteRun",
			Handler:    _PipelineRunnerService_ExecuteRun_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pipeline_runner.proto",
}

PipelineRunnerService_ServiceDesc is the grpc.ServiceDesc for PipelineRunnerService 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 PluginMedian_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.PluginMedian",
	HandlerType: (*PluginMedianServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewMedianFactory",
			Handler:    _PluginMedian_NewMedianFactory_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "median.proto",
}

PluginMedian_ServiceDesc is the grpc.ServiceDesc for PluginMedian 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 PluginRelayer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.PluginRelayer",
	HandlerType: (*PluginRelayerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewRelayer",
			Handler:    _PluginRelayer_NewRelayer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

PluginRelayer_ServiceDesc is the grpc.ServiceDesc for PluginRelayer 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 Relayer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.Relayer",
	HandlerType: (*RelayerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewConfigProvider",
			Handler:    _Relayer_NewConfigProvider_Handler,
		},
		{
			MethodName: "NewPluginProvider",
			Handler:    _Relayer_NewPluginProvider_Handler,
		},
		{
			MethodName: "GetChainStatus",
			Handler:    _Relayer_GetChainStatus_Handler,
		},
		{
			MethodName: "ListNodeStatuses",
			Handler:    _Relayer_ListNodeStatuses_Handler,
		},
		{
			MethodName: "Transact",
			Handler:    _Relayer_Transact_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

Relayer_ServiceDesc is the grpc.ServiceDesc for Relayer 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 ReportCodec_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ReportCodec",
	HandlerType: (*ReportCodecServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BuildReport",
			Handler:    _ReportCodec_BuildReport_Handler,
		},
		{
			MethodName: "MedianFromReport",
			Handler:    _ReportCodec_MedianFromReport_Handler,
		},
		{
			MethodName: "MaxReportLength",
			Handler:    _ReportCodec_MaxReportLength_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "median.proto",
}

ReportCodec_ServiceDesc is the grpc.ServiceDesc for ReportCodec 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 ReportingPluginFactory_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ReportingPluginFactory",
	HandlerType: (*ReportingPluginFactoryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewReportingPlugin",
			Handler:    _ReportingPluginFactory_NewReportingPlugin_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "reporting.proto",
}

ReportingPluginFactory_ServiceDesc is the grpc.ServiceDesc for ReportingPluginFactory 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 ReportingPluginService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ReportingPluginService",
	HandlerType: (*ReportingPluginServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewReportingPluginFactory",
			Handler:    _ReportingPluginService_NewReportingPluginFactory_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "reporting_plugin_service.proto",
}

ReportingPluginService_ServiceDesc is the grpc.ServiceDesc for ReportingPluginService 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 ReportingPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ReportingPlugin",
	HandlerType: (*ReportingPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Query",
			Handler:    _ReportingPlugin_Query_Handler,
		},
		{
			MethodName: "Observation",
			Handler:    _ReportingPlugin_Observation_Handler,
		},
		{
			MethodName: "Report",
			Handler:    _ReportingPlugin_Report_Handler,
		},
		{
			MethodName: "ShouldAcceptFinalizedReport",
			Handler:    _ReportingPlugin_ShouldAcceptFinalizedReport_Handler,
		},
		{
			MethodName: "ShouldTransmitAcceptedReport",
			Handler:    _ReportingPlugin_ShouldTransmitAcceptedReport_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _ReportingPlugin_Close_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "reporting.proto",
}

ReportingPlugin_ServiceDesc is the grpc.ServiceDesc for ReportingPlugin 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 Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Name",
			Handler:    _Service_Name_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _Service_Close_Handler,
		},
		{
			MethodName: "Ready",
			Handler:    _Service_Ready_Handler,
		},
		{
			MethodName: "HealthReport",
			Handler:    _Service_HealthReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

Service_ServiceDesc is the grpc.ServiceDesc for Service 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 Telemetry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.Telemetry",
	HandlerType: (*TelemetryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _Telemetry_Send_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "telemetry.proto",
}

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

Functions

func RegisterChainReaderServer 

func RegisterChainReaderServer(s grpc.ServiceRegistrar, srv ChainReaderServer)

func RegisterCodecServer 

func RegisterCodecServer(s grpc.ServiceRegistrar, srv CodecServer)

func RegisterContractConfigTrackerServer 

func RegisterContractConfigTrackerServer(s grpc.ServiceRegistrar, srv ContractConfigTrackerServer)

func RegisterContractTransmitterServer 

func RegisterContractTransmitterServer(s grpc.ServiceRegistrar, srv ContractTransmitterServer)

func RegisterDataSourceServer 

func RegisterDataSourceServer(s grpc.ServiceRegistrar, srv DataSourceServer)

func RegisterErrorLogServer 

func RegisterErrorLogServer(s grpc.ServiceRegistrar, srv ErrorLogServer)

func RegisterKeystoreServer 

func RegisterKeystoreServer(s grpc.ServiceRegistrar, srv KeystoreServer)

func RegisterMedianContractServer 

func RegisterMedianContractServer(s grpc.ServiceRegistrar, srv MedianContractServer)

func RegisterOffchainConfigDigesterServer 

func RegisterOffchainConfigDigesterServer(s grpc.ServiceRegistrar, srv OffchainConfigDigesterServer)

func RegisterOnchainConfigCodecServer 

func RegisterOnchainConfigCodecServer(s grpc.ServiceRegistrar, srv OnchainConfigCodecServer)

func RegisterPipelineRunnerServiceServer 

func RegisterPipelineRunnerServiceServer(s grpc.ServiceRegistrar, srv PipelineRunnerServiceServer)

func RegisterPluginMedianServer 

func RegisterPluginMedianServer(s grpc.ServiceRegistrar, srv PluginMedianServer)

func RegisterPluginRelayerServer 

func RegisterPluginRelayerServer(s grpc.ServiceRegistrar, srv PluginRelayerServer)

func RegisterRelayerServer 

func RegisterRelayerServer(s grpc.ServiceRegistrar, srv RelayerServer)

func RegisterReportCodecServer 

func RegisterReportCodecServer(s grpc.ServiceRegistrar, srv ReportCodecServer)

func RegisterReportingPluginFactoryServer 

func RegisterReportingPluginFactoryServer(s grpc.ServiceRegistrar, srv ReportingPluginFactoryServer)

func RegisterReportingPluginServer 

func RegisterReportingPluginServer(s grpc.ServiceRegistrar, srv ReportingPluginServer)

func RegisterReportingPluginServiceServer 

func RegisterReportingPluginServiceServer(s grpc.ServiceRegistrar, srv ReportingPluginServiceServer)

func RegisterServiceServer 

func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

func RegisterTelemetryServer 

func RegisterTelemetryServer(s grpc.ServiceRegistrar, srv TelemetryServer)

Types

type AccountsReply 

type AccountsReply struct {
	Accounts []string `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountsReply) Descriptor deprecated 

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

Deprecated: Use AccountsReply.ProtoReflect.Descriptor instead.

func (*AccountsReply) GetAccounts 

func (x *AccountsReply) GetAccounts() []string

func (*AccountsReply) ProtoMessage 

func (*AccountsReply) ProtoMessage()

func (*AccountsReply) ProtoReflect 

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

func (*AccountsReply) Reset 

func (x *AccountsReply) Reset()

func (*AccountsReply) String 

func (x *AccountsReply) String() string

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
}

AttributedObservation represents github.com/smartcontractkit/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 AttributedOnchainSignature 

type AttributedOnchainSignature struct {
	Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	Signer    uint32 `protobuf:"varint,2,opt,name=signer,proto3" json:"signer,omitempty"` // uint8
	// contains filtered or unexported fields
}

AttributedOnchainSignature represents github.com/smartcontractkit/libocr/offchainreporting2plus/types.AttributedOnchainSignature.

func (*AttributedOnchainSignature) Descriptor deprecated 

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

Deprecated: Use AttributedOnchainSignature.ProtoReflect.Descriptor instead.

func (*AttributedOnchainSignature) GetSignature 

func (x *AttributedOnchainSignature) GetSignature() []byte

func (*AttributedOnchainSignature) GetSigner 

func (x *AttributedOnchainSignature) GetSigner() uint32

func (*AttributedOnchainSignature) ProtoMessage 

func (*AttributedOnchainSignature) ProtoMessage()

func (*AttributedOnchainSignature) ProtoReflect 

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

func (*AttributedOnchainSignature) Reset 

func (x *AttributedOnchainSignature) Reset()

func (*AttributedOnchainSignature) String 

func (x *AttributedOnchainSignature) String() string

type BigInt 

type BigInt struct {
	Negative bool   `protobuf:"varint,1,opt,name=negative,proto3" json:"negative,omitempty"`
	Value    []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

BigInt represents a big.Int.

func NewBigIntFromInt 

func NewBigIntFromInt(b *big.Int) *BigInt

func (*BigInt) Descriptor deprecated 

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

Deprecated: Use BigInt.ProtoReflect.Descriptor instead.

func (*BigInt) GetNegative 

func (x *BigInt) GetNegative() bool

func (*BigInt) GetValue 

func (x *BigInt) GetValue() []byte

func (*BigInt) Int 

func (b *BigInt) Int() *big.Int

func (*BigInt) ProtoMessage 

func (*BigInt) ProtoMessage()

func (*BigInt) ProtoReflect 

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

func (*BigInt) Reset 

func (x *BigInt) Reset()

func (*BigInt) String 

func (x *BigInt) String() string

type BindRequest 

type BindRequest struct {
	Bindings []*BoundContract `protobuf:"bytes,1,rep,name=bindings,proto3" json:"bindings,omitempty"`
	// contains filtered or unexported fields
}

func (*BindRequest) Descriptor deprecated 

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

Deprecated: Use BindRequest.ProtoReflect.Descriptor instead.

func (*BindRequest) GetBindings 

func (x *BindRequest) GetBindings() []*BoundContract

func (*BindRequest) ProtoMessage 

func (*BindRequest) ProtoMessage()

func (*BindRequest) ProtoReflect 

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

func (*BindRequest) Reset 

func (x *BindRequest) Reset()

func (*BindRequest) String 

func (x *BindRequest) String() string

type BoundContract 

type BoundContract struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Pending bool   `protobuf:"varint,3,opt,name=pending,proto3" json:"pending,omitempty"`
	// contains filtered or unexported fields
}

BoundContract represents a github.com/O1MaGnUmO1/chainlink-common/pkg/types.BoundContract.

func (*BoundContract) Descriptor deprecated 

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

Deprecated: Use BoundContract.ProtoReflect.Descriptor instead.

func (*BoundContract) GetAddress 

func (x *BoundContract) GetAddress() string

func (*BoundContract) GetName 

func (x *BoundContract) GetName() string

func (*BoundContract) GetPending 

func (x *BoundContract) GetPending() bool

func (*BoundContract) ProtoMessage 

func (*BoundContract) ProtoMessage()

func (*BoundContract) ProtoReflect 

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

func (*BoundContract) Reset 

func (x *BoundContract) Reset()

func (*BoundContract) String 

func (x *BoundContract) String() string

type BuildReportReply 

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

BuildReportReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.ReportCodec.BuildReport.

func (*BuildReportReply) Descriptor deprecated 

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

Deprecated: Use BuildReportReply.ProtoReflect.Descriptor instead.

func (*BuildReportReply) GetReport 

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

func (*BuildReportReply) ProtoMessage 

func (*BuildReportReply) ProtoMessage()

func (*BuildReportReply) ProtoReflect 

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

func (*BuildReportReply) Reset 

func (x *BuildReportReply) Reset()

func (*BuildReportReply) String 

func (x *BuildReportReply) String() string

type BuildReportRequest 

type BuildReportRequest struct {
	Observations []*ParsedAttributedObservation `protobuf:"bytes,1,rep,name=observations,proto3" json:"observations,omitempty"`
	// contains filtered or unexported fields
}

BuildReportRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.ReportCodec.BuildReport.

func (*BuildReportRequest) Descriptor deprecated 

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

Deprecated: Use BuildReportRequest.ProtoReflect.Descriptor instead.

func (*BuildReportRequest) GetObservations 

func (x *BuildReportRequest) GetObservations() []*ParsedAttributedObservation

func (*BuildReportRequest) ProtoMessage 

func (*BuildReportRequest) ProtoMessage()

func (*BuildReportRequest) ProtoReflect 

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

func (*BuildReportRequest) Reset 

func (x *BuildReportRequest) Reset()

func (*BuildReportRequest) String 

func (x *BuildReportRequest) String() string

type ChainReaderClient 

type ChainReaderClient interface {
	GetLatestValue(ctx context.Context, in *GetLatestValueRequest, opts ...grpc.CallOption) (*GetLatestValueReply, error)
	Bind(ctx context.Context, in *BindRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ChainReaderClient is the client API for ChainReader 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 NewChainReaderClient 

func NewChainReaderClient(cc grpc.ClientConnInterface) ChainReaderClient

type ChainReaderServer 

type ChainReaderServer interface {
	GetLatestValue(context.Context, *GetLatestValueRequest) (*GetLatestValueReply, error)
	Bind(context.Context, *BindRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ChainReaderServer is the server API for ChainReader service. All implementations must embed UnimplementedChainReaderServer for forward compatibility

type ChainStatus 

type ChainStatus struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Enabled bool   `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Config  string `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` // TOML
	// contains filtered or unexported fields
}

ChainStatus represents github.com/O1MaGnUmO1/chainlink-common/pkg/types.ChainStatus.

func (*ChainStatus) Descriptor deprecated 

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

Deprecated: Use ChainStatus.ProtoReflect.Descriptor instead.

func (*ChainStatus) GetConfig 

func (x *ChainStatus) GetConfig() string

func (*ChainStatus) GetEnabled 

func (x *ChainStatus) GetEnabled() bool

func (*ChainStatus) GetId 

func (x *ChainStatus) GetId() string

func (*ChainStatus) ProtoMessage 

func (*ChainStatus) ProtoMessage()

func (*ChainStatus) ProtoReflect 

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

func (*ChainStatus) Reset 

func (x *ChainStatus) Reset()

func (*ChainStatus) String 

func (x *ChainStatus) String() string

type CodecClient 

type CodecClient interface {
	GetEncoding(ctx context.Context, in *GetEncodingRequest, opts ...grpc.CallOption) (*GetEncodingResponse, error)
	GetDecoding(ctx context.Context, in *GetDecodingRequest, opts ...grpc.CallOption) (*GetDecodingResponse, error)
	GetMaxSize(ctx context.Context, in *GetMaxSizeRequest, opts ...grpc.CallOption) (*GetMaxSizeResponse, error)
}

CodecClient is the client API for Codec 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 NewCodecClient 

func NewCodecClient(cc grpc.ClientConnInterface) CodecClient

type CodecServer 

type CodecServer interface {
	GetEncoding(context.Context, *GetEncodingRequest) (*GetEncodingResponse, error)
	GetDecoding(context.Context, *GetDecodingRequest) (*GetDecodingResponse, error)
	GetMaxSize(context.Context, *GetMaxSizeRequest) (*GetMaxSizeResponse, error)
	// contains filtered or unexported methods
}

CodecServer is the server API for Codec service. All implementations must embed UnimplementedCodecServer for forward compatibility

type ConfigDigestPrefixReply 

type ConfigDigestPrefixReply struct {
	ConfigDigestPrefix uint32 `protobuf:"varint,1,opt,name=configDigestPrefix,proto3" json:"configDigestPrefix,omitempty"` // uint16
	// contains filtered or unexported fields
}

ConfigDigestPrefixReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.OffchainConfigDigester.ConfigDigestPrefix.

func (*ConfigDigestPrefixReply) Descriptor deprecated 

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

Deprecated: Use ConfigDigestPrefixReply.ProtoReflect.Descriptor instead.

func (*ConfigDigestPrefixReply) GetConfigDigestPrefix 

func (x *ConfigDigestPrefixReply) GetConfigDigestPrefix() uint32

func (*ConfigDigestPrefixReply) ProtoMessage 

func (*ConfigDigestPrefixReply) ProtoMessage()

func (*ConfigDigestPrefixReply) ProtoReflect 

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

func (*ConfigDigestPrefixReply) Reset 

func (x *ConfigDigestPrefixReply) Reset()

func (*ConfigDigestPrefixReply) String 

func (x *ConfigDigestPrefixReply) String() string

type ConfigDigestPrefixRequest 

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

func (*ConfigDigestPrefixRequest) Descriptor deprecated 

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

Deprecated: Use ConfigDigestPrefixRequest.ProtoReflect.Descriptor instead.

func (*ConfigDigestPrefixRequest) ProtoMessage 

func (*ConfigDigestPrefixRequest) ProtoMessage()

func (*ConfigDigestPrefixRequest) ProtoReflect 

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

func (*ConfigDigestPrefixRequest) Reset 

func (x *ConfigDigestPrefixRequest) Reset()

func (*ConfigDigestPrefixRequest) String 

func (x *ConfigDigestPrefixRequest) String() string

type ConfigDigestReply 

type ConfigDigestReply struct {
	ConfigDigest []byte `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"` // [32]byte
	// contains filtered or unexported fields
}

ConfigDigestReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.OffchainConfigDigester.ConfigDigest.

func (*ConfigDigestReply) Descriptor deprecated 

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

Deprecated: Use ConfigDigestReply.ProtoReflect.Descriptor instead.

func (*ConfigDigestReply) GetConfigDigest 

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

func (*ConfigDigestReply) ProtoMessage 

func (*ConfigDigestReply) ProtoMessage()

func (*ConfigDigestReply) ProtoReflect 

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

func (*ConfigDigestReply) Reset 

func (x *ConfigDigestReply) Reset()

func (*ConfigDigestReply) String 

func (x *ConfigDigestReply) String() string

type ConfigDigestRequest 

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

ConfigDigestRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.OffchainConfigDigester.ConfigDigest.

func (*ConfigDigestRequest) Descriptor deprecated 

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

Deprecated: Use ConfigDigestRequest.ProtoReflect.Descriptor instead.

func (*ConfigDigestRequest) GetContractConfig 

func (x *ConfigDigestRequest) GetContractConfig() *ContractConfig

func (*ConfigDigestRequest) ProtoMessage 

func (*ConfigDigestRequest) ProtoMessage()

func (*ConfigDigestRequest) ProtoReflect 

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

func (*ConfigDigestRequest) Reset 

func (x *ConfigDigestRequest) Reset()

func (*ConfigDigestRequest) String 

func (x *ConfigDigestRequest) String() string

type ContractConfig 

type ContractConfig struct {
	ConfigDigest          []byte   `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"` // [32]byte
	ConfigCount           uint64   `protobuf:"varint,2,opt,name=configCount,proto3" json:"configCount,omitempty"`
	Signers               [][]byte `protobuf:"bytes,3,rep,name=signers,proto3" json:"signers,omitempty"`           // []OnchainPublicKey
	Transmitters          []string `protobuf:"bytes,4,rep,name=transmitters,proto3" json:"transmitters,omitempty"` // []Account
	F                     uint32   `protobuf:"varint,5,opt,name=F,proto3" json:"F,omitempty"`                      // uint8
	OnchainConfig         []byte   `protobuf:"bytes,6,opt,name=onchainConfig,proto3" json:"onchainConfig,omitempty"`
	OffchainConfigVersion uint64   `protobuf:"varint,7,opt,name=offchainConfigVersion,proto3" json:"offchainConfigVersion,omitempty"`
	OffchainConfig        []byte   `protobuf:"bytes,8,opt,name=offchainConfig,proto3" json:"offchainConfig,omitempty"`
	// contains filtered or unexported fields
}

ContractConfig represents github.com/smartcontractkit/libocr/offchainreporting2plus/types.ContractConfig

func (*ContractConfig) Descriptor deprecated 

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

Deprecated: Use ContractConfig.ProtoReflect.Descriptor instead.

func (*ContractConfig) GetConfigCount 

func (x *ContractConfig) GetConfigCount() uint64

func (*ContractConfig) GetConfigDigest 

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

func (*ContractConfig) GetF 

func (x *ContractConfig) GetF() uint32

func (*ContractConfig) GetOffchainConfig 

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

func (*ContractConfig) GetOffchainConfigVersion 

func (x *ContractConfig) GetOffchainConfigVersion() uint64

func (*ContractConfig) GetOnchainConfig 

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

func (*ContractConfig) GetSigners 

func (x *ContractConfig) GetSigners() [][]byte

func (*ContractConfig) GetTransmitters 

func (x *ContractConfig) GetTransmitters() []string

func (*ContractConfig) ProtoMessage 

func (*ContractConfig) ProtoMessage()

func (*ContractConfig) ProtoReflect 

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

func (*ContractConfig) Reset 

func (x *ContractConfig) Reset()

func (*ContractConfig) String 

func (x *ContractConfig) String() string

type ContractConfigTrackerClient 

type ContractConfigTrackerClient interface {
	LatestConfigDetails(ctx context.Context, in *LatestConfigDetailsRequest, opts ...grpc.CallOption) (*LatestConfigDetailsReply, error)
	LatestConfig(ctx context.Context, in *LatestConfigRequest, opts ...grpc.CallOption) (*LatestConfigReply, error)
	LatestBlockHeight(ctx context.Context, in *LatestBlockHeightRequest, opts ...grpc.CallOption) (*LatestBlockHeightReply, error)
}

ContractConfigTrackerClient is the client API for ContractConfigTracker 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 NewContractConfigTrackerClient 

func NewContractConfigTrackerClient(cc grpc.ClientConnInterface) ContractConfigTrackerClient

type ContractConfigTrackerServer 

type ContractConfigTrackerServer interface {
	LatestConfigDetails(context.Context, *LatestConfigDetailsRequest) (*LatestConfigDetailsReply, error)
	LatestConfig(context.Context, *LatestConfigRequest) (*LatestConfigReply, error)
	LatestBlockHeight(context.Context, *LatestBlockHeightRequest) (*LatestBlockHeightReply, error)
	// contains filtered or unexported methods
}

ContractConfigTrackerServer is the server API for ContractConfigTracker service. All implementations must embed UnimplementedContractConfigTrackerServer for forward compatibility

type ContractTransmitterClient 

type ContractTransmitterClient interface {
	Transmit(ctx context.Context, in *TransmitRequest, opts ...grpc.CallOption) (*TransmitReply, error)
	LatestConfigDigestAndEpoch(ctx context.Context, in *LatestConfigDigestAndEpochRequest, opts ...grpc.CallOption) (*LatestConfigDigestAndEpochReply, error)
	FromAccount(ctx context.Context, in *FromAccountRequest, opts ...grpc.CallOption) (*FromAccountReply, error)
}

ContractTransmitterClient is the client API for ContractTransmitter 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 NewContractTransmitterClient 

func NewContractTransmitterClient(cc grpc.ClientConnInterface) ContractTransmitterClient

type ContractTransmitterServer 

type ContractTransmitterServer interface {
	Transmit(context.Context, *TransmitRequest) (*TransmitReply, error)
	LatestConfigDigestAndEpoch(context.Context, *LatestConfigDigestAndEpochRequest) (*LatestConfigDigestAndEpochReply, error)
	FromAccount(context.Context, *FromAccountRequest) (*FromAccountReply, error)
	// contains filtered or unexported methods
}

ContractTransmitterServer is the server API for ContractTransmitter service. All implementations must embed UnimplementedContractTransmitterServer for forward compatibility

type DataSourceClient 

type DataSourceClient interface {
	Observe(ctx context.Context, in *ObserveRequest, opts ...grpc.CallOption) (*ObserveReply, error)
}

DataSourceClient is the client API for DataSource 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 NewDataSourceClient 

func NewDataSourceClient(cc grpc.ClientConnInterface) DataSourceClient

type DataSourceServer 

type DataSourceServer interface {
	Observe(context.Context, *ObserveRequest) (*ObserveReply, error)
	// contains filtered or unexported methods
}

DataSourceServer is the server API for DataSource service. All implementations must embed UnimplementedDataSourceServer for forward compatibility

type DecodeReply 

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

DecodeReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.OnchainConfigCodec.Decode.

func (*DecodeReply) Descriptor deprecated 

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

Deprecated: Use DecodeReply.ProtoReflect.Descriptor instead.

func (*DecodeReply) GetOnchainConfig 

func (x *DecodeReply) GetOnchainConfig() *OnchainConfig

func (*DecodeReply) ProtoMessage 

func (*DecodeReply) ProtoMessage()

func (*DecodeReply) ProtoReflect 

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

func (*DecodeReply) Reset 

func (x *DecodeReply) Reset()

func (*DecodeReply) String 

func (x *DecodeReply) String() string

type DecodeRequest 

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

DecodeRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.OnchainConfigCodec.Decode.

func (*DecodeRequest) Descriptor deprecated 

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

Deprecated: Use DecodeRequest.ProtoReflect.Descriptor instead.

func (*DecodeRequest) GetEncoded 

func (x *DecodeRequest) GetEncoded() []byte

func (*DecodeRequest) ProtoMessage 

func (*DecodeRequest) ProtoMessage()

func (*DecodeRequest) ProtoReflect 

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

func (*DecodeRequest) Reset 

func (x *DecodeRequest) Reset()

func (*DecodeRequest) String 

func (x *DecodeRequest) String() string

type EncodeReply 

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

EncodeReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.OnchainConfigCodec.Encode.

func (*EncodeReply) Descriptor deprecated 

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

Deprecated: Use EncodeReply.ProtoReflect.Descriptor instead.

func (*EncodeReply) GetEncoded 

func (x *EncodeReply) GetEncoded() []byte

func (*EncodeReply) ProtoMessage 

func (*EncodeReply) ProtoMessage()

func (*EncodeReply) ProtoReflect 

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

func (*EncodeReply) Reset 

func (x *EncodeReply) Reset()

func (*EncodeReply) String 

func (x *EncodeReply) String() string

type EncodeRequest 

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

EncodeRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.OnchainConfigCodec.Encode.

func (*EncodeRequest) Descriptor deprecated 

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

Deprecated: Use EncodeRequest.ProtoReflect.Descriptor instead.

func (*EncodeRequest) GetOnchainConfig 

func (x *EncodeRequest) GetOnchainConfig() *OnchainConfig

func (*EncodeRequest) ProtoMessage 

func (*EncodeRequest) ProtoMessage()

func (*EncodeRequest) ProtoReflect 

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

func (*EncodeRequest) Reset 

func (x *EncodeRequest) Reset()

func (*EncodeRequest) String 

func (x *EncodeRequest) String() string

type ErrorLogClient 

type ErrorLogClient interface {
	SaveError(ctx context.Context, in *SaveErrorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ErrorLogClient is the client API for ErrorLog 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 NewErrorLogClient 

func NewErrorLogClient(cc grpc.ClientConnInterface) ErrorLogClient

type ErrorLogServer 

type ErrorLogServer interface {
	SaveError(context.Context, *SaveErrorRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ErrorLogServer is the server API for ErrorLog service. All implementations must embed UnimplementedErrorLogServer for forward compatibility

type FromAccountReply 

type FromAccountReply struct {
	Account string `protobuf:"bytes,1,opt,name=Account,proto3" json:"Account,omitempty"`
	// contains filtered or unexported fields
}

FromAccountReply has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/types.Service.FromAccount.

func (*FromAccountReply) Descriptor deprecated 

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

Deprecated: Use FromAccountReply.ProtoReflect.Descriptor instead.

func (*FromAccountReply) GetAccount 

func (x *FromAccountReply) GetAccount() string

func (*FromAccountReply) ProtoMessage 

func (*FromAccountReply) ProtoMessage()

func (*FromAccountReply) ProtoReflect 

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

func (*FromAccountReply) Reset 

func (x *FromAccountReply) Reset()

func (*FromAccountReply) String 

func (x *FromAccountReply) String() string

type FromAccountRequest 

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

func (*FromAccountRequest) Descriptor deprecated 

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

Deprecated: Use FromAccountRequest.ProtoReflect.Descriptor instead.

func (*FromAccountRequest) ProtoMessage 

func (*FromAccountRequest) ProtoMessage()

func (*FromAccountRequest) ProtoReflect 

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

func (*FromAccountRequest) Reset 

func (x *FromAccountRequest) Reset()

func (*FromAccountRequest) String 

func (x *FromAccountRequest) String() string

type GetChainStatusReply 

type GetChainStatusReply struct {
	Chain *ChainStatus `protobuf:"bytes,1,opt,name=chain,proto3" json:"chain,omitempty"`
	// contains filtered or unexported fields
}

ChainStatusReply has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.ChainStatus.

func (*GetChainStatusReply) Descriptor deprecated 

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

Deprecated: Use GetChainStatusReply.ProtoReflect.Descriptor instead.

func (*GetChainStatusReply) GetChain 

func (x *GetChainStatusReply) GetChain() *ChainStatus

func (*GetChainStatusReply) ProtoMessage 

func (*GetChainStatusReply) ProtoMessage()

func (*GetChainStatusReply) ProtoReflect 

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

func (*GetChainStatusReply) Reset 

func (x *GetChainStatusReply) Reset()

func (*GetChainStatusReply) String 

func (x *GetChainStatusReply) String() string

type GetChainStatusRequest 

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

func (*GetChainStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetChainStatusRequest.ProtoReflect.Descriptor instead.

func (*GetChainStatusRequest) ProtoMessage 

func (*GetChainStatusRequest) ProtoMessage()

func (*GetChainStatusRequest) ProtoReflect 

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

func (*GetChainStatusRequest) Reset 

func (x *GetChainStatusRequest) Reset()

func (*GetChainStatusRequest) String 

func (x *GetChainStatusRequest) String() string

type GetDecodingRequest 

type GetDecodingRequest struct {
	Encoded             []byte `protobuf:"bytes,1,opt,name=encoded,proto3" json:"encoded,omitempty"`
	ItemType            string `protobuf:"bytes,2,opt,name=itemType,proto3" json:"itemType,omitempty"`
	WireEncodingVersion uint32 `protobuf:"varint,3,opt,name=wireEncodingVersion,proto3" json:"wireEncodingVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDecodingRequest) Descriptor deprecated 

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

Deprecated: Use GetDecodingRequest.ProtoReflect.Descriptor instead.

func (*GetDecodingRequest) GetEncoded 

func (x *GetDecodingRequest) GetEncoded() []byte

func (*GetDecodingRequest) GetItemType 

func (x *GetDecodingRequest) GetItemType() string

func (*GetDecodingRequest) GetWireEncodingVersion 

func (x *GetDecodingRequest) GetWireEncodingVersion() uint32

func (*GetDecodingRequest) ProtoMessage 

func (*GetDecodingRequest) ProtoMessage()

func (*GetDecodingRequest) ProtoReflect 

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

func (*GetDecodingRequest) Reset 

func (x *GetDecodingRequest) Reset()

func (*GetDecodingRequest) String 

func (x *GetDecodingRequest) String() string

type GetDecodingResponse 

type GetDecodingResponse struct {
	RetVal *VersionedBytes `protobuf:"bytes,1,opt,name=retVal,proto3" json:"retVal,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDecodingResponse) Descriptor deprecated 

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

Deprecated: Use GetDecodingResponse.ProtoReflect.Descriptor instead.

func (*GetDecodingResponse) GetRetVal 

func (x *GetDecodingResponse) GetRetVal() *VersionedBytes

func (*GetDecodingResponse) ProtoMessage 

func (*GetDecodingResponse) ProtoMessage()

func (*GetDecodingResponse) ProtoReflect 

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

func (*GetDecodingResponse) Reset 

func (x *GetDecodingResponse) Reset()

func (*GetDecodingResponse) String 

func (x *GetDecodingResponse) String() string

type GetEncodingRequest 

type GetEncodingRequest struct {
	Params   *VersionedBytes `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	ItemType string          `protobuf:"bytes,2,opt,name=itemType,proto3" json:"itemType,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEncodingRequest) Descriptor deprecated 

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

Deprecated: Use GetEncodingRequest.ProtoReflect.Descriptor instead.

func (*GetEncodingRequest) GetItemType 

func (x *GetEncodingRequest) GetItemType() string

func (*GetEncodingRequest) GetParams 

func (x *GetEncodingRequest) GetParams() *VersionedBytes

func (*GetEncodingRequest) ProtoMessage 

func (*GetEncodingRequest) ProtoMessage()

func (*GetEncodingRequest) ProtoReflect 

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

func (*GetEncodingRequest) Reset 

func (x *GetEncodingRequest) Reset()

func (*GetEncodingRequest) String 

func (x *GetEncodingRequest) String() string

type GetEncodingResponse 

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

func (*GetEncodingResponse) Descriptor deprecated 

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

Deprecated: Use GetEncodingResponse.ProtoReflect.Descriptor instead.

func (*GetEncodingResponse) GetRetVal 

func (x *GetEncodingResponse) GetRetVal() []byte

func (*GetEncodingResponse) ProtoMessage 

func (*GetEncodingResponse) ProtoMessage()

func (*GetEncodingResponse) ProtoReflect 

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

func (*GetEncodingResponse) Reset 

func (x *GetEncodingResponse) Reset()

func (*GetEncodingResponse) String 

func (x *GetEncodingResponse) String() string

type GetLatestValueReply 

type GetLatestValueReply struct {
	RetVal *VersionedBytes `protobuf:"bytes,1,opt,name=retVal,proto3" json:"retVal,omitempty"`
	// contains filtered or unexported fields
}

GetLatestValueReply has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/types.ChainReader.GetLatestValue.

func (*GetLatestValueReply) Descriptor deprecated 

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

Deprecated: Use GetLatestValueReply.ProtoReflect.Descriptor instead.

func (*GetLatestValueReply) GetRetVal 

func (x *GetLatestValueReply) GetRetVal() *VersionedBytes

func (*GetLatestValueReply) ProtoMessage 

func (*GetLatestValueReply) ProtoMessage()

func (*GetLatestValueReply) ProtoReflect 

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

func (*GetLatestValueReply) Reset 

func (x *GetLatestValueReply) Reset()

func (*GetLatestValueReply) String 

func (x *GetLatestValueReply) String() string

type GetLatestValueRequest 

type GetLatestValueRequest struct {
	ContractName string          `protobuf:"bytes,1,opt,name=contractName,proto3" json:"contractName,omitempty"`
	Method       string          `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Params       *VersionedBytes `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

GetLatestValueRequest has arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/types.ChainReader.GetLatestValue.

func (*GetLatestValueRequest) Descriptor deprecated 

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

Deprecated: Use GetLatestValueRequest.ProtoReflect.Descriptor instead.

func (*GetLatestValueRequest) GetContractName 

func (x *GetLatestValueRequest) GetContractName() string

func (*GetLatestValueRequest) GetMethod 

func (x *GetLatestValueRequest) GetMethod() string

func (*GetLatestValueRequest) GetParams 

func (x *GetLatestValueRequest) GetParams() *VersionedBytes

func (*GetLatestValueRequest) ProtoMessage 

func (*GetLatestValueRequest) ProtoMessage()

func (*GetLatestValueRequest) ProtoReflect 

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

func (*GetLatestValueRequest) Reset 

func (x *GetLatestValueRequest) Reset()

func (*GetLatestValueRequest) String 

func (x *GetLatestValueRequest) String() string

type GetMaxSizeRequest 

type GetMaxSizeRequest struct {
	N           int32  `protobuf:"varint,1,opt,name=n,proto3" json:"n,omitempty"`
	ItemType    string `protobuf:"bytes,2,opt,name=itemType,proto3" json:"itemType,omitempty"`
	ForEncoding bool   `protobuf:"varint,3,opt,name=forEncoding,proto3" json:"forEncoding,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMaxSizeRequest) Descriptor deprecated 

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

Deprecated: Use GetMaxSizeRequest.ProtoReflect.Descriptor instead.

func (*GetMaxSizeRequest) GetForEncoding 

func (x *GetMaxSizeRequest) GetForEncoding() bool

func (*GetMaxSizeRequest) GetItemType 

func (x *GetMaxSizeRequest) GetItemType() string

func (*GetMaxSizeRequest) GetN 

func (x *GetMaxSizeRequest) GetN() int32

func (*GetMaxSizeRequest) ProtoMessage 

func (*GetMaxSizeRequest) ProtoMessage()

func (*GetMaxSizeRequest) ProtoReflect 

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

func (*GetMaxSizeRequest) Reset 

func (x *GetMaxSizeRequest) Reset()

func (*GetMaxSizeRequest) String 

func (x *GetMaxSizeRequest) String() string

type GetMaxSizeResponse 

type GetMaxSizeResponse struct {
	SizeInBytes int32 `protobuf:"varint,1,opt,name=sizeInBytes,proto3" json:"sizeInBytes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMaxSizeResponse) Descriptor deprecated 

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

Deprecated: Use GetMaxSizeResponse.ProtoReflect.Descriptor instead.

func (*GetMaxSizeResponse) GetSizeInBytes 

func (x *GetMaxSizeResponse) GetSizeInBytes() int32

func (*GetMaxSizeResponse) ProtoMessage 

func (*GetMaxSizeResponse) ProtoMessage()

func (*GetMaxSizeResponse) ProtoReflect 

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

func (*GetMaxSizeResponse) Reset 

func (x *GetMaxSizeResponse) Reset()

func (*GetMaxSizeResponse) String 

func (x *GetMaxSizeResponse) String() string

type HealthReportReply 

type HealthReportReply struct {
	HealthReport map[string]string `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

HealthReportReply has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/types.Service.HealthReport.

func (*HealthReportReply) Descriptor deprecated 

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

Deprecated: Use HealthReportReply.ProtoReflect.Descriptor instead.

func (*HealthReportReply) GetHealthReport 

func (x *HealthReportReply) GetHealthReport() map[string]string

func (*HealthReportReply) ProtoMessage 

func (*HealthReportReply) ProtoMessage()

func (*HealthReportReply) ProtoReflect 

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

func (*HealthReportReply) Reset 

func (x *HealthReportReply) Reset()

func (*HealthReportReply) String 

func (x *HealthReportReply) String() string

type KeystoreClient 

type KeystoreClient interface {
	Accounts(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AccountsReply, error)
	Sign(ctx context.Context, in *SignRequest, opts ...grpc.CallOption) (*SignReply, error)
}

KeystoreClient is the client API for Keystore 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 NewKeystoreClient 

func NewKeystoreClient(cc grpc.ClientConnInterface) KeystoreClient

type KeystoreServer 

type KeystoreServer interface {
	Accounts(context.Context, *emptypb.Empty) (*AccountsReply, error)
	Sign(context.Context, *SignRequest) (*SignReply, error)
	// contains filtered or unexported methods
}

KeystoreServer is the server API for Keystore service. All implementations must embed UnimplementedKeystoreServer for forward compatibility

type LatestBlockHeightReply 

type LatestBlockHeightReply struct {
	BlockHeight uint64 `protobuf:"varint,1,opt,name=blockHeight,proto3" json:"blockHeight,omitempty"`
	// contains filtered or unexported fields
}

LatestBlockHeightReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ContractConfigTracker.LatestBlockHeightReply.

func (*LatestBlockHeightReply) Descriptor deprecated 

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

Deprecated: Use LatestBlockHeightReply.ProtoReflect.Descriptor instead.

func (*LatestBlockHeightReply) GetBlockHeight 

func (x *LatestBlockHeightReply) GetBlockHeight() uint64

func (*LatestBlockHeightReply) ProtoMessage 

func (*LatestBlockHeightReply) ProtoMessage()

func (*LatestBlockHeightReply) ProtoReflect 

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

func (*LatestBlockHeightReply) Reset 

func (x *LatestBlockHeightReply) Reset()

func (*LatestBlockHeightReply) String 

func (x *LatestBlockHeightReply) String() string

type LatestBlockHeightRequest 

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

func (*LatestBlockHeightRequest) Descriptor deprecated 

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

Deprecated: Use LatestBlockHeightRequest.ProtoReflect.Descriptor instead.

func (*LatestBlockHeightRequest) ProtoMessage 

func (*LatestBlockHeightRequest) ProtoMessage()

func (*LatestBlockHeightRequest) ProtoReflect 

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

func (*LatestBlockHeightRequest) Reset 

func (x *LatestBlockHeightRequest) Reset()

func (*LatestBlockHeightRequest) String 

func (x *LatestBlockHeightRequest) String() string

type LatestConfigDetailsReply 

type LatestConfigDetailsReply struct {
	ChangedInBlock uint64 `protobuf:"varint,1,opt,name=changedInBlock,proto3" json:"changedInBlock,omitempty"`
	ConfigDigest   []byte `protobuf:"bytes,2,opt,name=configDigest,proto3" json:"configDigest,omitempty"` // [32]byte
	// contains filtered or unexported fields
}

LatestConfigDetailsReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ContractConfigTracker.LatestConfigDetails.

func (*LatestConfigDetailsReply) Descriptor deprecated 

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

Deprecated: Use LatestConfigDetailsReply.ProtoReflect.Descriptor instead.

func (*LatestConfigDetailsReply) GetChangedInBlock 

func (x *LatestConfigDetailsReply) GetChangedInBlock() uint64

func (*LatestConfigDetailsReply) GetConfigDigest 

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

func (*LatestConfigDetailsReply) ProtoMessage 

func (*LatestConfigDetailsReply) ProtoMessage()

func (*LatestConfigDetailsReply) ProtoReflect 

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

func (*LatestConfigDetailsReply) Reset 

func (x *LatestConfigDetailsReply) Reset()

func (*LatestConfigDetailsReply) String 

func (x *LatestConfigDetailsReply) String() string

type LatestConfigDetailsRequest 

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

func (*LatestConfigDetailsRequest) Descriptor deprecated 

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

Deprecated: Use LatestConfigDetailsRequest.ProtoReflect.Descriptor instead.

func (*LatestConfigDetailsRequest) ProtoMessage 

func (*LatestConfigDetailsRequest) ProtoMessage()

func (*LatestConfigDetailsRequest) ProtoReflect 

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

func (*LatestConfigDetailsRequest) Reset 

func (x *LatestConfigDetailsRequest) Reset()

func (*LatestConfigDetailsRequest) String 

func (x *LatestConfigDetailsRequest) String() string

type LatestConfigDigestAndEpochReply 

type LatestConfigDigestAndEpochReply struct {
	ConfigDigest []byte `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"` // [32]byte
	Epoch        uint32 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

LatestConfigDigestAndEpochReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ContractTransmitter.LatestConfigDigestAndEpoch.

func (*LatestConfigDigestAndEpochReply) Descriptor deprecated 

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

Deprecated: Use LatestConfigDigestAndEpochReply.ProtoReflect.Descriptor instead.

func (*LatestConfigDigestAndEpochReply) GetConfigDigest 

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

func (*LatestConfigDigestAndEpochReply) GetEpoch 

func (x *LatestConfigDigestAndEpochReply) GetEpoch() uint32

func (*LatestConfigDigestAndEpochReply) ProtoMessage 

func (*LatestConfigDigestAndEpochReply) ProtoMessage()

func (*LatestConfigDigestAndEpochReply) ProtoReflect 

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

func (*LatestConfigDigestAndEpochReply) Reset 

func (x *LatestConfigDigestAndEpochReply) Reset()

func (*LatestConfigDigestAndEpochReply) String 

func (x *LatestConfigDigestAndEpochReply) String() string

type LatestConfigDigestAndEpochRequest 

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

func (*LatestConfigDigestAndEpochRequest) Descriptor deprecated 

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

Deprecated: Use LatestConfigDigestAndEpochRequest.ProtoReflect.Descriptor instead.

func (*LatestConfigDigestAndEpochRequest) ProtoMessage 

func (*LatestConfigDigestAndEpochRequest) ProtoMessage()

func (*LatestConfigDigestAndEpochRequest) ProtoReflect 

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

func (*LatestConfigDigestAndEpochRequest) Reset 

func (x *LatestConfigDigestAndEpochRequest) Reset()

func (*LatestConfigDigestAndEpochRequest) String 

func (x *LatestConfigDigestAndEpochRequest) String() string

type LatestConfigReply 

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

LatestConfigReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ContractConfigTracker.LatestConfig.

func (*LatestConfigReply) Descriptor deprecated 

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

Deprecated: Use LatestConfigReply.ProtoReflect.Descriptor instead.

func (*LatestConfigReply) GetContractConfig 

func (x *LatestConfigReply) GetContractConfig() *ContractConfig

func (*LatestConfigReply) ProtoMessage 

func (*LatestConfigReply) ProtoMessage()

func (*LatestConfigReply) ProtoReflect 

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

func (*LatestConfigReply) Reset 

func (x *LatestConfigReply) Reset()

func (*LatestConfigReply) String 

func (x *LatestConfigReply) String() string

type LatestConfigRequest 

type LatestConfigRequest struct {
	ChangedInBlock uint64 `protobuf:"varint,1,opt,name=changedInBlock,proto3" json:"changedInBlock,omitempty"`
	// contains filtered or unexported fields
}

LatestConfigRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ContractConfigTracker.LatestConfig.

func (*LatestConfigRequest) Descriptor deprecated 

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

Deprecated: Use LatestConfigRequest.ProtoReflect.Descriptor instead.

func (*LatestConfigRequest) GetChangedInBlock 

func (x *LatestConfigRequest) GetChangedInBlock() uint64

func (*LatestConfigRequest) ProtoMessage 

func (*LatestConfigRequest) ProtoMessage()

func (*LatestConfigRequest) ProtoReflect 

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

func (*LatestConfigRequest) Reset 

func (x *LatestConfigRequest) Reset()

func (*LatestConfigRequest) String 

func (x *LatestConfigRequest) String() string

type LatestRoundRequestedReply 

type LatestRoundRequestedReply struct {
	ConfigDigest []byte `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"` // [32]byte
	Epoch        uint32 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Round        uint32 `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"` // uint8
	// contains filtered or unexported fields
}

LatestRoundRequestedReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.MedianContract.LatestRoundRequested.

func (*LatestRoundRequestedReply) Descriptor deprecated 

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

Deprecated: Use LatestRoundRequestedReply.ProtoReflect.Descriptor instead.

func (*LatestRoundRequestedReply) GetConfigDigest 

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

func (*LatestRoundRequestedReply) GetEpoch 

func (x *LatestRoundRequestedReply) GetEpoch() uint32

func (*LatestRoundRequestedReply) GetRound 

func (x *LatestRoundRequestedReply) GetRound() uint32

func (*LatestRoundRequestedReply) ProtoMessage 

func (*LatestRoundRequestedReply) ProtoMessage()

func (*LatestRoundRequestedReply) ProtoReflect 

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

func (*LatestRoundRequestedReply) Reset 

func (x *LatestRoundRequestedReply) Reset()

func (*LatestRoundRequestedReply) String 

func (x *LatestRoundRequestedReply) String() string

type LatestRoundRequestedRequest 

type LatestRoundRequestedRequest struct {
	Lookback int64 `protobuf:"varint,1,opt,name=lookback,proto3" json:"lookback,omitempty"` // milliseconds
	// contains filtered or unexported fields
}

LatestRoundRequestedRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.MedianContract.LatestRoundRequested.

func (*LatestRoundRequestedRequest) Descriptor deprecated 

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

Deprecated: Use LatestRoundRequestedRequest.ProtoReflect.Descriptor instead.

func (*LatestRoundRequestedRequest) GetLookback 

func (x *LatestRoundRequestedRequest) GetLookback() int64

func (*LatestRoundRequestedRequest) ProtoMessage 

func (*LatestRoundRequestedRequest) ProtoMessage()

func (*LatestRoundRequestedRequest) ProtoReflect 

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

func (*LatestRoundRequestedRequest) Reset 

func (x *LatestRoundRequestedRequest) Reset()

func (*LatestRoundRequestedRequest) String 

func (x *LatestRoundRequestedRequest) String() string

type LatestTransmissionDetailsReply 

type LatestTransmissionDetailsReply struct {
	ConfigDigest    []byte                 `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"` // [32]byte
	Epoch           uint32                 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Round           uint32                 `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"` // uint8
	LatestAnswer    *BigInt                `protobuf:"bytes,4,opt,name=latestAnswer,proto3" json:"latestAnswer,omitempty"`
	LatestTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=latestTimestamp,proto3" json:"latestTimestamp,omitempty"`
	// contains filtered or unexported fields
}

LatestTransmissionDetailsReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.MedianContract.LatestTransmissionDetails.

func (*LatestTransmissionDetailsReply) Descriptor deprecated 

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

Deprecated: Use LatestTransmissionDetailsReply.ProtoReflect.Descriptor instead.

func (*LatestTransmissionDetailsReply) GetConfigDigest 

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

func (*LatestTransmissionDetailsReply) GetEpoch 

func (x *LatestTransmissionDetailsReply) GetEpoch() uint32

func (*LatestTransmissionDetailsReply) GetLatestAnswer 

func (x *LatestTransmissionDetailsReply) GetLatestAnswer() *BigInt

func (*LatestTransmissionDetailsReply) GetLatestTimestamp 

func (x *LatestTransmissionDetailsReply) GetLatestTimestamp() *timestamppb.Timestamp

func (*LatestTransmissionDetailsReply) GetRound 

func (x *LatestTransmissionDetailsReply) GetRound() uint32

func (*LatestTransmissionDetailsReply) ProtoMessage 

func (*LatestTransmissionDetailsReply) ProtoMessage()

func (*LatestTransmissionDetailsReply) ProtoReflect 

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

func (*LatestTransmissionDetailsReply) Reset 

func (x *LatestTransmissionDetailsReply) Reset()

func (*LatestTransmissionDetailsReply) String 

func (x *LatestTransmissionDetailsReply) String() string

type LatestTransmissionDetailsRequest 

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

func (*LatestTransmissionDetailsRequest) Descriptor deprecated 

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

Deprecated: Use LatestTransmissionDetailsRequest.ProtoReflect.Descriptor instead.

func (*LatestTransmissionDetailsRequest) ProtoMessage 

func (*LatestTransmissionDetailsRequest) ProtoMessage()

func (*LatestTransmissionDetailsRequest) ProtoReflect 

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

func (*LatestTransmissionDetailsRequest) Reset 

func (x *LatestTransmissionDetailsRequest) Reset()

func (*LatestTransmissionDetailsRequest) String 

func (x *LatestTransmissionDetailsRequest) String() string

type ListNodeStatusesReply 

type ListNodeStatusesReply struct {
	Nodes         []*NodeStatus `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Total         int32         `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` // total count of nodes
	NextPageToken string        `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

ListNodeStatusesReply is a pagination response for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.ListNodeStatuses.

func (*ListNodeStatusesReply) Descriptor deprecated 

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

Deprecated: Use ListNodeStatusesReply.ProtoReflect.Descriptor instead.

func (*ListNodeStatusesReply) GetNextPageToken 

func (x *ListNodeStatusesReply) GetNextPageToken() string

func (*ListNodeStatusesReply) GetNodes 

func (x *ListNodeStatusesReply) GetNodes() []*NodeStatus

func (*ListNodeStatusesReply) GetTotal 

func (x *ListNodeStatusesReply) GetTotal() int32

func (*ListNodeStatusesReply) ProtoMessage 

func (*ListNodeStatusesReply) ProtoMessage()

func (*ListNodeStatusesReply) ProtoReflect 

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

func (*ListNodeStatusesReply) Reset 

func (x *ListNodeStatusesReply) Reset()

func (*ListNodeStatusesReply) String 

func (x *ListNodeStatusesReply) String() string

type ListNodeStatusesRequest 

type ListNodeStatusesRequest struct {
	PageSize  int32  `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

ListNodeStatusesRequest has arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.ListNodeStatuses.

func (*ListNodeStatusesRequest) Descriptor deprecated 

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

Deprecated: Use ListNodeStatusesRequest.ProtoReflect.Descriptor instead.

func (*ListNodeStatusesRequest) GetPageSize 

func (x *ListNodeStatusesRequest) GetPageSize() int32

func (*ListNodeStatusesRequest) GetPageToken 

func (x *ListNodeStatusesRequest) GetPageToken() string

func (*ListNodeStatusesRequest) ProtoMessage 

func (*ListNodeStatusesRequest) ProtoMessage()

func (*ListNodeStatusesRequest) ProtoReflect 

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

func (*ListNodeStatusesRequest) Reset 

func (x *ListNodeStatusesRequest) Reset()

func (*ListNodeStatusesRequest) String 

func (x *ListNodeStatusesRequest) String() string

type MaxReportLengthReply 

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

MaxReportLengthReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.ReportCodec.MaxReportLength.

func (*MaxReportLengthReply) Descriptor deprecated 

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

Deprecated: Use MaxReportLengthReply.ProtoReflect.Descriptor instead.

func (*MaxReportLengthReply) GetMax 

func (x *MaxReportLengthReply) GetMax() int64

func (*MaxReportLengthReply) ProtoMessage 

func (*MaxReportLengthReply) ProtoMessage()

func (*MaxReportLengthReply) ProtoReflect 

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

func (*MaxReportLengthReply) Reset 

func (x *MaxReportLengthReply) Reset()

func (*MaxReportLengthReply) String 

func (x *MaxReportLengthReply) String() string

type MaxReportLengthRequest 

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

MaxReportLengthRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.ReportCodec.MaxReportLength.

func (*MaxReportLengthRequest) Descriptor deprecated 

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

Deprecated: Use MaxReportLengthRequest.ProtoReflect.Descriptor instead.

func (*MaxReportLengthRequest) GetN 

func (x *MaxReportLengthRequest) GetN() int64

func (*MaxReportLengthRequest) ProtoMessage 

func (*MaxReportLengthRequest) ProtoMessage()

func (*MaxReportLengthRequest) ProtoReflect 

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

func (*MaxReportLengthRequest) Reset 

func (x *MaxReportLengthRequest) Reset()

func (*MaxReportLengthRequest) String 

func (x *MaxReportLengthRequest) String() string

type MedianContractClient 

type MedianContractClient interface {
	LatestTransmissionDetails(ctx context.Context, in *LatestTransmissionDetailsRequest, opts ...grpc.CallOption) (*LatestTransmissionDetailsReply, error)
	LatestRoundRequested(ctx context.Context, in *LatestRoundRequestedRequest, opts ...grpc.CallOption) (*LatestRoundRequestedReply, error)
}

MedianContractClient is the client API for MedianContract 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 NewMedianContractClient 

func NewMedianContractClient(cc grpc.ClientConnInterface) MedianContractClient

type MedianContractServer 

type MedianContractServer interface {
	LatestTransmissionDetails(context.Context, *LatestTransmissionDetailsRequest) (*LatestTransmissionDetailsReply, error)
	LatestRoundRequested(context.Context, *LatestRoundRequestedRequest) (*LatestRoundRequestedReply, error)
	// contains filtered or unexported methods
}

MedianContractServer is the server API for MedianContract service. All implementations must embed UnimplementedMedianContractServer for forward compatibility

type MedianFromReportReply 

type MedianFromReportReply struct {
	Median *BigInt `protobuf:"bytes,1,opt,name=median,proto3" json:"median,omitempty"`
	// contains filtered or unexported fields
}

MedianFromReportReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.ReportCodec.MedianFromReport.

func (*MedianFromReportReply) Descriptor deprecated 

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

Deprecated: Use MedianFromReportReply.ProtoReflect.Descriptor instead.

func (*MedianFromReportReply) GetMedian 

func (x *MedianFromReportReply) GetMedian() *BigInt

func (*MedianFromReportReply) ProtoMessage 

func (*MedianFromReportReply) ProtoMessage()

func (*MedianFromReportReply) ProtoReflect 

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

func (*MedianFromReportReply) Reset 

func (x *MedianFromReportReply) Reset()

func (*MedianFromReportReply) String 

func (x *MedianFromReportReply) String() string

type MedianFromReportRequest 

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

MedianFromReportRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.ReportCodec.MedianFromReport.

func (*MedianFromReportRequest) Descriptor deprecated 

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

Deprecated: Use MedianFromReportRequest.ProtoReflect.Descriptor instead.

func (*MedianFromReportRequest) GetReport 

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

func (*MedianFromReportRequest) ProtoMessage 

func (*MedianFromReportRequest) ProtoMessage()

func (*MedianFromReportRequest) ProtoReflect 

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

func (*MedianFromReportRequest) Reset 

func (x *MedianFromReportRequest) Reset()

func (*MedianFromReportRequest) String 

func (x *MedianFromReportRequest) String() string

type NameReply 

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

NameReply has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/types.Service.Name.

func (*NameReply) Descriptor deprecated 

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

Deprecated: Use NameReply.ProtoReflect.Descriptor instead.

func (*NameReply) GetName 

func (x *NameReply) GetName() string

func (*NameReply) ProtoMessage 

func (*NameReply) ProtoMessage()

func (*NameReply) ProtoReflect 

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

func (*NameReply) Reset 

func (x *NameReply) Reset()

func (*NameReply) String 

func (x *NameReply) String() string

type NewConfigProviderReply 

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

NewConfigProviderReply has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.NewConfigProvider.

func (*NewConfigProviderReply) Descriptor deprecated 

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

Deprecated: Use NewConfigProviderReply.ProtoReflect.Descriptor instead.

func (*NewConfigProviderReply) GetConfigProviderID 

func (x *NewConfigProviderReply) GetConfigProviderID() uint32

func (*NewConfigProviderReply) ProtoMessage 

func (*NewConfigProviderReply) ProtoMessage()

func (*NewConfigProviderReply) ProtoReflect 

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

func (*NewConfigProviderReply) Reset 

func (x *NewConfigProviderReply) Reset()

func (*NewConfigProviderReply) String 

func (x *NewConfigProviderReply) String() string

type NewConfigProviderRequest 

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

NewConfigProviderRequest has arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.NewConfigProvider.

func (*NewConfigProviderRequest) Descriptor deprecated 

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

Deprecated: Use NewConfigProviderRequest.ProtoReflect.Descriptor instead.

func (*NewConfigProviderRequest) GetRelayArgs 

func (x *NewConfigProviderRequest) GetRelayArgs() *RelayArgs

func (*NewConfigProviderRequest) ProtoMessage 

func (*NewConfigProviderRequest) ProtoMessage()

func (*NewConfigProviderRequest) ProtoReflect 

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

func (*NewConfigProviderRequest) Reset 

func (x *NewConfigProviderRequest) Reset()

func (*NewConfigProviderRequest) String 

func (x *NewConfigProviderRequest) String() string

type NewMedianFactoryReply 

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

NewMedianFactoryRequest has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.NewMedianFactory.

func (*NewMedianFactoryReply) Descriptor deprecated 

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

Deprecated: Use NewMedianFactoryReply.ProtoReflect.Descriptor instead.

func (*NewMedianFactoryReply) GetReportingPluginFactoryID 

func (x *NewMedianFactoryReply) GetReportingPluginFactoryID() uint32

func (*NewMedianFactoryReply) ProtoMessage 

func (*NewMedianFactoryReply) ProtoMessage()

func (*NewMedianFactoryReply) ProtoReflect 

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

func (*NewMedianFactoryReply) Reset 

func (x *NewMedianFactoryReply) Reset()

func (*NewMedianFactoryReply) String 

func (x *NewMedianFactoryReply) String() string

type NewMedianFactoryRequest 

type NewMedianFactoryRequest struct {
	MedianProviderID            uint32 `protobuf:"varint,1,opt,name=medianProviderID,proto3" json:"medianProviderID,omitempty"`
	DataSourceID                uint32 `protobuf:"varint,2,opt,name=dataSourceID,proto3" json:"dataSourceID,omitempty"`
	JuelsPerFeeCoinDataSourceID uint32 `protobuf:"varint,3,opt,name=juelsPerFeeCoinDataSourceID,proto3" json:"juelsPerFeeCoinDataSourceID,omitempty"`
	ErrorLogID                  uint32 `protobuf:"varint,4,opt,name=errorLogID,proto3" json:"errorLogID,omitempty"`
	// contains filtered or unexported fields
}

NewMedianFactoryRequest has arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.NewMedianFactory.

func (*NewMedianFactoryRequest) Descriptor deprecated 

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

Deprecated: Use NewMedianFactoryRequest.ProtoReflect.Descriptor instead.

func (*NewMedianFactoryRequest) GetDataSourceID 

func (x *NewMedianFactoryRequest) GetDataSourceID() uint32

func (*NewMedianFactoryRequest) GetErrorLogID 

func (x *NewMedianFactoryRequest) GetErrorLogID() uint32

func (*NewMedianFactoryRequest) GetJuelsPerFeeCoinDataSourceID 

func (x *NewMedianFactoryRequest) GetJuelsPerFeeCoinDataSourceID() uint32

func (*NewMedianFactoryRequest) GetMedianProviderID 

func (x *NewMedianFactoryRequest) GetMedianProviderID() uint32

func (*NewMedianFactoryRequest) ProtoMessage 

func (*NewMedianFactoryRequest) ProtoMessage()

func (*NewMedianFactoryRequest) ProtoReflect 

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

func (*NewMedianFactoryRequest) Reset 

func (x *NewMedianFactoryRequest) Reset()

func (*NewMedianFactoryRequest) String 

func (x *NewMedianFactoryRequest) String() string

type NewPluginProviderReply 

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

NewPluginProviderReply has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.NewPluginProvider.

func (*NewPluginProviderReply) Descriptor deprecated 

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

Deprecated: Use NewPluginProviderReply.ProtoReflect.Descriptor instead.

func (*NewPluginProviderReply) GetPluginProviderID 

func (x *NewPluginProviderReply) GetPluginProviderID() uint32

func (*NewPluginProviderReply) ProtoMessage 

func (*NewPluginProviderReply) ProtoMessage()

func (*NewPluginProviderReply) ProtoReflect 

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

func (*NewPluginProviderReply) Reset 

func (x *NewPluginProviderReply) Reset()

func (*NewPluginProviderReply) String 

func (x *NewPluginProviderReply) String() string

type NewPluginProviderRequest 

type NewPluginProviderRequest struct {
	RelayArgs  *RelayArgs  `protobuf:"bytes,1,opt,name=relayArgs,proto3" json:"relayArgs,omitempty"`
	PluginArgs *PluginArgs `protobuf:"bytes,2,opt,name=pluginArgs,proto3" json:"pluginArgs,omitempty"`
	// contains filtered or unexported fields
}

NewPluginProviderRequest has arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.NewPluginProvider.

func (*NewPluginProviderRequest) Descriptor deprecated 

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

Deprecated: Use NewPluginProviderRequest.ProtoReflect.Descriptor instead.

func (*NewPluginProviderRequest) GetPluginArgs 

func (x *NewPluginProviderRequest) GetPluginArgs() *PluginArgs

func (*NewPluginProviderRequest) GetRelayArgs 

func (x *NewPluginProviderRequest) GetRelayArgs() *RelayArgs

func (*NewPluginProviderRequest) ProtoMessage 

func (*NewPluginProviderRequest) ProtoMessage()

func (*NewPluginProviderRequest) ProtoReflect 

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

func (*NewPluginProviderRequest) Reset 

func (x *NewPluginProviderRequest) Reset()

func (*NewPluginProviderRequest) String 

func (x *NewPluginProviderRequest) String() string

type NewRelayerReply 

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

func (*NewRelayerReply) Descriptor deprecated 

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

Deprecated: Use NewRelayerReply.ProtoReflect.Descriptor instead.

func (*NewRelayerReply) GetRelayerID 

func (x *NewRelayerReply) GetRelayerID() uint32

func (*NewRelayerReply) ProtoMessage 

func (*NewRelayerReply) ProtoMessage()

func (*NewRelayerReply) ProtoReflect 

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

func (*NewRelayerReply) Reset 

func (x *NewRelayerReply) Reset()

func (*NewRelayerReply) String 

func (x *NewRelayerReply) String() string

type NewRelayerRequest 

type NewRelayerRequest struct {
	Config     string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` // toml (is chain instance config enough?)
	KeystoreID uint32 `protobuf:"varint,2,opt,name=keystoreID,proto3" json:"keystoreID,omitempty"`
	// contains filtered or unexported fields
}

func (*NewRelayerRequest) Descriptor deprecated 

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

Deprecated: Use NewRelayerRequest.ProtoReflect.Descriptor instead.

func (*NewRelayerRequest) GetConfig 

func (x *NewRelayerRequest) GetConfig() string

func (*NewRelayerRequest) GetKeystoreID 

func (x *NewRelayerRequest) GetKeystoreID() uint32

func (*NewRelayerRequest) ProtoMessage 

func (*NewRelayerRequest) ProtoMessage()

func (*NewRelayerRequest) ProtoReflect 

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

func (*NewRelayerRequest) Reset 

func (x *NewRelayerRequest) Reset()

func (*NewRelayerRequest) String 

func (x *NewRelayerRequest) String() string

type NewReportingPluginFactoryReply 

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

NewReportingPluginFactoryReply has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop/reporting_plugins/LOOPPService.NewReportingPluginFactory.

func (*NewReportingPluginFactoryReply) Descriptor deprecated 

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

Deprecated: Use NewReportingPluginFactoryReply.ProtoReflect.Descriptor instead.

func (*NewReportingPluginFactoryReply) GetID 

func (x *NewReportingPluginFactoryReply) GetID() uint32

func (*NewReportingPluginFactoryReply) ProtoMessage 

func (*NewReportingPluginFactoryReply) ProtoMessage()

func (*NewReportingPluginFactoryReply) ProtoReflect 

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

func (*NewReportingPluginFactoryReply) Reset 

func (x *NewReportingPluginFactoryReply) Reset()

func (*NewReportingPluginFactoryReply) String 

func (x *NewReportingPluginFactoryReply) String() string

type NewReportingPluginFactoryRequest 

type NewReportingPluginFactoryRequest struct {
	ProviderID                   uint32                        `protobuf:"varint,1,opt,name=providerID,proto3" json:"providerID,omitempty"`
	ErrorLogID                   uint32                        `protobuf:"varint,2,opt,name=errorLogID,proto3" json:"errorLogID,omitempty"`
	PipelineRunnerID             uint32                        `protobuf:"varint,3,opt,name=pipelineRunnerID,proto3" json:"pipelineRunnerID,omitempty"`
	TelemetryID                  uint32                        `protobuf:"varint,4,opt,name=telemetryID,proto3" json:"telemetryID,omitempty"`
	ReportingPluginServiceConfig *ReportingPluginServiceConfig `protobuf:"bytes,5,opt,name=ReportingPluginServiceConfig,proto3" json:"ReportingPluginServiceConfig,omitempty"`
	// contains filtered or unexported fields
}

NewReportingPluginFactoryRequest has arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop/reporting_plugins/LOOPPService.NewReportingPluginFactory.

func (*NewReportingPluginFactoryRequest) Descriptor deprecated 

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

Deprecated: Use NewReportingPluginFactoryRequest.ProtoReflect.Descriptor instead.

func (*NewReportingPluginFactoryRequest) GetErrorLogID 

func (x *NewReportingPluginFactoryRequest) GetErrorLogID() uint32

func (*NewReportingPluginFactoryRequest) GetPipelineRunnerID 

func (x *NewReportingPluginFactoryRequest) GetPipelineRunnerID() uint32

func (*NewReportingPluginFactoryRequest) GetProviderID 

func (x *NewReportingPluginFactoryRequest) GetProviderID() uint32

func (*NewReportingPluginFactoryRequest) GetReportingPluginServiceConfig 

func (x *NewReportingPluginFactoryRequest) GetReportingPluginServiceConfig() *ReportingPluginServiceConfig

func (*NewReportingPluginFactoryRequest) GetTelemetryID 

func (x *NewReportingPluginFactoryRequest) GetTelemetryID() uint32

func (*NewReportingPluginFactoryRequest) ProtoMessage 

func (*NewReportingPluginFactoryRequest) ProtoMessage()

func (*NewReportingPluginFactoryRequest) ProtoReflect 

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

func (*NewReportingPluginFactoryRequest) Reset 

func (x *NewReportingPluginFactoryRequest) Reset()

func (*NewReportingPluginFactoryRequest) String 

func (x *NewReportingPluginFactoryRequest) String() string

type NewReportingPluginReply 

type NewReportingPluginReply struct {
	ReportingPluginID   uint32               `protobuf:"varint,1,opt,name=reportingPluginID,proto3" json:"reportingPluginID,omitempty"`
	ReportingPluginInfo *ReportingPluginInfo `protobuf:"bytes,2,opt,name=reportingPluginInfo,proto3" json:"reportingPluginInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*NewReportingPluginReply) Descriptor deprecated 

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

Deprecated: Use NewReportingPluginReply.ProtoReflect.Descriptor instead.

func (*NewReportingPluginReply) GetReportingPluginID 

func (x *NewReportingPluginReply) GetReportingPluginID() uint32

func (*NewReportingPluginReply) GetReportingPluginInfo 

func (x *NewReportingPluginReply) GetReportingPluginInfo() *ReportingPluginInfo

func (*NewReportingPluginReply) ProtoMessage 

func (*NewReportingPluginReply) ProtoMessage()

func (*NewReportingPluginReply) ProtoReflect 

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

func (*NewReportingPluginReply) Reset 

func (x *NewReportingPluginReply) Reset()

func (*NewReportingPluginReply) String 

func (x *NewReportingPluginReply) String() string

type NewReportingPluginRequest 

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

func (*NewReportingPluginRequest) Descriptor deprecated 

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

Deprecated: Use NewReportingPluginRequest.ProtoReflect.Descriptor instead.

func (*NewReportingPluginRequest) GetReportingPluginConfig 

func (x *NewReportingPluginRequest) GetReportingPluginConfig() *ReportingPluginConfig

func (*NewReportingPluginRequest) ProtoMessage 

func (*NewReportingPluginRequest) ProtoMessage()

func (*NewReportingPluginRequest) ProtoReflect 

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

func (*NewReportingPluginRequest) Reset 

func (x *NewReportingPluginRequest) Reset()

func (*NewReportingPluginRequest) String 

func (x *NewReportingPluginRequest) String() string

type NodeStatus 

type NodeStatus struct {
	ChainID string `protobuf:"bytes,1,opt,name=chainID,proto3" json:"chainID,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Config  string `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` // TOML
	State   string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

NodeStatus represents github.com/O1MaGnUmO1/chainlink-common/pkg/types.NodeStatus.

func (*NodeStatus) Descriptor deprecated 

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

Deprecated: Use NodeStatus.ProtoReflect.Descriptor instead.

func (*NodeStatus) GetChainID 

func (x *NodeStatus) GetChainID() string

func (*NodeStatus) GetConfig 

func (x *NodeStatus) GetConfig() string

func (*NodeStatus) GetName 

func (x *NodeStatus) GetName() string

func (*NodeStatus) GetState 

func (x *NodeStatus) GetState() string

func (*NodeStatus) ProtoMessage 

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) ProtoReflect 

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

func (*NodeStatus) Reset 

func (x *NodeStatus) Reset()

func (*NodeStatus) String 

func (x *NodeStatus) String() string

type ObservationReply 

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

ObservationReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.Observation.

func (*ObservationReply) Descriptor deprecated 

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

Deprecated: Use ObservationReply.ProtoReflect.Descriptor instead.

func (*ObservationReply) GetObservation 

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

func (*ObservationReply) ProtoMessage 

func (*ObservationReply) ProtoMessage()

func (*ObservationReply) ProtoReflect 

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

func (*ObservationReply) Reset 

func (x *ObservationReply) Reset()

func (*ObservationReply) String 

func (x *ObservationReply) String() string

type ObservationRequest 

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

ObservationRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.Observation.

func (*ObservationRequest) Descriptor deprecated 

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

Deprecated: Use ObservationRequest.ProtoReflect.Descriptor instead.

func (*ObservationRequest) GetQuery 

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

func (*ObservationRequest) GetReportTimestamp 

func (x *ObservationRequest) GetReportTimestamp() *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 ObserveReply 

type ObserveReply struct {
	Value *BigInt `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

ObserveReply has return arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.DataSource.Observe.

func (*ObserveReply) Descriptor deprecated 

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

Deprecated: Use ObserveReply.ProtoReflect.Descriptor instead.

func (*ObserveReply) GetValue 

func (x *ObserveReply) GetValue() *BigInt

func (*ObserveReply) ProtoMessage 

func (*ObserveReply) ProtoMessage()

func (*ObserveReply) ProtoReflect 

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

func (*ObserveReply) Reset 

func (x *ObserveReply) Reset()

func (*ObserveReply) String 

func (x *ObserveReply) String() string

type ObserveRequest 

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

ObserveRequest has arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.DataSource.Observe.

func (*ObserveRequest) Descriptor deprecated 

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

Deprecated: Use ObserveRequest.ProtoReflect.Descriptor instead.

func (*ObserveRequest) GetReportTimestamp 

func (x *ObserveRequest) GetReportTimestamp() *ReportTimestamp

func (*ObserveRequest) ProtoMessage 

func (*ObserveRequest) ProtoMessage()

func (*ObserveRequest) ProtoReflect 

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

func (*ObserveRequest) Reset 

func (x *ObserveRequest) Reset()

func (*ObserveRequest) String 

func (x *ObserveRequest) String() string

type OffchainConfigDigesterClient 

type OffchainConfigDigesterClient interface {
	ConfigDigest(ctx context.Context, in *ConfigDigestRequest, opts ...grpc.CallOption) (*ConfigDigestReply, error)
	ConfigDigestPrefix(ctx context.Context, in *ConfigDigestPrefixRequest, opts ...grpc.CallOption) (*ConfigDigestPrefixReply, error)
}

OffchainConfigDigesterClient is the client API for OffchainConfigDigester 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 NewOffchainConfigDigesterClient 

func NewOffchainConfigDigesterClient(cc grpc.ClientConnInterface) OffchainConfigDigesterClient

type OffchainConfigDigesterServer 

type OffchainConfigDigesterServer interface {
	ConfigDigest(context.Context, *ConfigDigestRequest) (*ConfigDigestReply, error)
	ConfigDigestPrefix(context.Context, *ConfigDigestPrefixRequest) (*ConfigDigestPrefixReply, error)
	// contains filtered or unexported methods
}

OffchainConfigDigesterServer is the server API for OffchainConfigDigester service. All implementations must embed UnimplementedOffchainConfigDigesterServer for forward compatibility

type OnchainConfig 

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

OnchainConfig represents github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.OnchainConfig.

func (*OnchainConfig) Descriptor deprecated 

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

Deprecated: Use OnchainConfig.ProtoReflect.Descriptor instead.

func (*OnchainConfig) GetMax 

func (x *OnchainConfig) GetMax() *BigInt

func (*OnchainConfig) GetMin 

func (x *OnchainConfig) GetMin() *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 *EncodeRequest, opts ...grpc.CallOption) (*EncodeReply, error)
	Decode(ctx context.Context, in *DecodeRequest, opts ...grpc.CallOption) (*DecodeReply, 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, *EncodeRequest) (*EncodeReply, error)
	Decode(context.Context, *DecodeRequest) (*DecodeReply, error)
	// contains filtered or unexported methods
}

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

type Options 

type Options struct {
	MaxTaskDuration *durationpb.Duration `protobuf:"bytes,2,opt,name=max_task_duration,json=maxTaskDuration,proto3" json:"max_task_duration,omitempty"`
	// contains filtered or unexported fields
}

func (*Options) Descriptor deprecated 

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetMaxTaskDuration 

func (x *Options) GetMaxTaskDuration() *durationpb.Duration

func (*Options) ProtoMessage 

func (*Options) ProtoMessage()

func (*Options) ProtoReflect 

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

func (*Options) Reset 

func (x *Options) Reset()

func (*Options) String 

func (x *Options) String() string

type ParsedAttributedObservation 

type ParsedAttributedObservation struct {
	Timestamp       uint32  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value           *BigInt `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	JulesPerFeeCoin *BigInt `protobuf:"bytes,3,opt,name=julesPerFeeCoin,proto3" json:"julesPerFeeCoin,omitempty"`
	Observer        uint32  `protobuf:"varint,4,opt,name=observer,proto3" json:"observer,omitempty"` // uint8
	// contains filtered or unexported fields
}

ParsedAttributedObservation represents github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.ParsedAttributedObservation.

func (*ParsedAttributedObservation) Descriptor deprecated 

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

Deprecated: Use ParsedAttributedObservation.ProtoReflect.Descriptor instead.

func (*ParsedAttributedObservation) GetJulesPerFeeCoin 

func (x *ParsedAttributedObservation) GetJulesPerFeeCoin() *BigInt

func (*ParsedAttributedObservation) GetObserver 

func (x *ParsedAttributedObservation) GetObserver() uint32

func (*ParsedAttributedObservation) GetTimestamp 

func (x *ParsedAttributedObservation) GetTimestamp() uint32

func (*ParsedAttributedObservation) GetValue 

func (x *ParsedAttributedObservation) GetValue() *BigInt

func (*ParsedAttributedObservation) ProtoMessage 

func (*ParsedAttributedObservation) ProtoMessage()

func (*ParsedAttributedObservation) ProtoReflect 

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

func (*ParsedAttributedObservation) Reset 

func (x *ParsedAttributedObservation) Reset()

func (*ParsedAttributedObservation) String 

func (x *ParsedAttributedObservation) String() string

type PipelineRunnerServiceClient 

type PipelineRunnerServiceClient interface {
	ExecuteRun(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
}

PipelineRunnerServiceClient is the client API for PipelineRunnerService 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 NewPipelineRunnerServiceClient 

func NewPipelineRunnerServiceClient(cc grpc.ClientConnInterface) PipelineRunnerServiceClient

type PipelineRunnerServiceServer 

type PipelineRunnerServiceServer interface {
	ExecuteRun(context.Context, *RunRequest) (*RunResponse, error)
	// contains filtered or unexported methods
}

PipelineRunnerServiceServer is the server API for PipelineRunnerService service. All implementations must embed UnimplementedPipelineRunnerServiceServer for forward compatibility

type PluginArgs 

type PluginArgs struct {
	TransmitterID string `protobuf:"bytes,1,opt,name=transmitterID,proto3" json:"transmitterID,omitempty"`
	PluginConfig  []byte `protobuf:"bytes,2,opt,name=pluginConfig,proto3" json:"pluginConfig,omitempty"`
	// contains filtered or unexported fields
}

RelayArgs represents github.com/O1MaGnUmO1/chainlink-common/pkg/types.PluginArgs.

func (*PluginArgs) Descriptor deprecated 

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

Deprecated: Use PluginArgs.ProtoReflect.Descriptor instead.

func (*PluginArgs) GetPluginConfig 

func (x *PluginArgs) GetPluginConfig() []byte

func (*PluginArgs) GetTransmitterID 

func (x *PluginArgs) GetTransmitterID() string

func (*PluginArgs) ProtoMessage 

func (*PluginArgs) ProtoMessage()

func (*PluginArgs) ProtoReflect 

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

func (*PluginArgs) Reset 

func (x *PluginArgs) Reset()

func (*PluginArgs) String 

func (x *PluginArgs) String() string

type PluginMedianClient 

type PluginMedianClient interface {
	NewMedianFactory(ctx context.Context, in *NewMedianFactoryRequest, opts ...grpc.CallOption) (*NewMedianFactoryReply, error)
}

PluginMedianClient is the client API for PluginMedian 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 NewPluginMedianClient 

func NewPluginMedianClient(cc grpc.ClientConnInterface) PluginMedianClient

type PluginMedianServer 

type PluginMedianServer interface {
	NewMedianFactory(context.Context, *NewMedianFactoryRequest) (*NewMedianFactoryReply, error)
	// contains filtered or unexported methods
}

PluginMedianServer is the server API for PluginMedian service. All implementations must embed UnimplementedPluginMedianServer for forward compatibility

type PluginRelayerClient 

type PluginRelayerClient interface {
	NewRelayer(ctx context.Context, in *NewRelayerRequest, opts ...grpc.CallOption) (*NewRelayerReply, error)
}

PluginRelayerClient is the client API for PluginRelayer 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 NewPluginRelayerClient 

func NewPluginRelayerClient(cc grpc.ClientConnInterface) PluginRelayerClient

type PluginRelayerServer 

type PluginRelayerServer interface {
	NewRelayer(context.Context, *NewRelayerRequest) (*NewRelayerReply, error)
	// contains filtered or unexported methods
}

PluginRelayerServer is the server API for PluginRelayer service. All implementations must embed UnimplementedPluginRelayerServer for forward compatibility

type QueryReply 

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

QueryReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.Query.

func (*QueryReply) Descriptor deprecated 

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

Deprecated: Use QueryReply.ProtoReflect.Descriptor instead.

func (*QueryReply) GetQuery 

func (x *QueryReply) GetQuery() []byte

func (*QueryReply) ProtoMessage 

func (*QueryReply) ProtoMessage()

func (*QueryReply) ProtoReflect 

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

func (*QueryReply) Reset 

func (x *QueryReply) Reset()

func (*QueryReply) String 

func (x *QueryReply) String() string

type QueryRequest 

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

QueryRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.Query.

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetReportTimestamp 

func (x *QueryRequest) GetReportTimestamp() *ReportTimestamp

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type RelayArgs 

type RelayArgs struct {
	ExternalJobID []byte `protobuf:"bytes,1,opt,name=externalJobID,proto3" json:"externalJobID,omitempty"` // [32]byte
	JobID         int32  `protobuf:"varint,2,opt,name=jobID,proto3" json:"jobID,omitempty"`
	ContractID    string `protobuf:"bytes,3,opt,name=contractID,proto3" json:"contractID,omitempty"`
	New           bool   `protobuf:"varint,4,opt,name=new,proto3" json:"new,omitempty"`
	RelayConfig   []byte `protobuf:"bytes,5,opt,name=relayConfig,proto3" json:"relayConfig,omitempty"`
	ProviderType  string `protobuf:"bytes,6,opt,name=providerType,proto3" json:"providerType,omitempty"`
	// contains filtered or unexported fields
}

RelayArgs represents github.com/O1MaGnUmO1/chainlink-common/pkg/types.RelayArgs.

func (*RelayArgs) Descriptor deprecated 

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

Deprecated: Use RelayArgs.ProtoReflect.Descriptor instead.

func (*RelayArgs) GetContractID 

func (x *RelayArgs) GetContractID() string

func (*RelayArgs) GetExternalJobID 

func (x *RelayArgs) GetExternalJobID() []byte

func (*RelayArgs) GetJobID 

func (x *RelayArgs) GetJobID() int32

func (*RelayArgs) GetNew 

func (x *RelayArgs) GetNew() bool

func (*RelayArgs) GetProviderType 

func (x *RelayArgs) GetProviderType() string

func (*RelayArgs) GetRelayConfig 

func (x *RelayArgs) GetRelayConfig() []byte

func (*RelayArgs) ProtoMessage 

func (*RelayArgs) ProtoMessage()

func (*RelayArgs) ProtoReflect 

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

func (*RelayArgs) Reset 

func (x *RelayArgs) Reset()

func (*RelayArgs) String 

func (x *RelayArgs) String() string

type RelayID 

type RelayID struct {
	Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	ChainId string `protobuf:"bytes,2,opt,name=chainId,proto3" json:"chainId,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayID) Descriptor deprecated 

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

Deprecated: Use RelayID.ProtoReflect.Descriptor instead.

func (*RelayID) GetChainId 

func (x *RelayID) GetChainId() string

func (*RelayID) GetNetwork 

func (x *RelayID) GetNetwork() string

func (*RelayID) ProtoMessage 

func (*RelayID) ProtoMessage()

func (*RelayID) ProtoReflect 

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

func (*RelayID) Reset 

func (x *RelayID) Reset()

func (*RelayID) String 

func (x *RelayID) String() string

type RelayerClient 

type RelayerClient interface {
	NewConfigProvider(ctx context.Context, in *NewConfigProviderRequest, opts ...grpc.CallOption) (*NewConfigProviderReply, error)
	NewPluginProvider(ctx context.Context, in *NewPluginProviderRequest, opts ...grpc.CallOption) (*NewPluginProviderReply, error)
	GetChainStatus(ctx context.Context, in *GetChainStatusRequest, opts ...grpc.CallOption) (*GetChainStatusReply, error)
	ListNodeStatuses(ctx context.Context, in *ListNodeStatusesRequest, opts ...grpc.CallOption) (*ListNodeStatusesReply, error)
	Transact(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RelayerClient is the client API for Relayer 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 NewRelayerClient 

func NewRelayerClient(cc grpc.ClientConnInterface) RelayerClient

type RelayerServer 

type RelayerServer interface {
	NewConfigProvider(context.Context, *NewConfigProviderRequest) (*NewConfigProviderReply, error)
	NewPluginProvider(context.Context, *NewPluginProviderRequest) (*NewPluginProviderReply, error)
	GetChainStatus(context.Context, *GetChainStatusRequest) (*GetChainStatusReply, error)
	ListNodeStatuses(context.Context, *ListNodeStatusesRequest) (*ListNodeStatusesReply, error)
	Transact(context.Context, *TransactionRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

RelayerServer is the server API for Relayer service. All implementations must embed UnimplementedRelayerServer for forward compatibility

type ReportCodecClient 

type ReportCodecClient interface {
	BuildReport(ctx context.Context, in *BuildReportRequest, opts ...grpc.CallOption) (*BuildReportReply, error)
	MedianFromReport(ctx context.Context, in *MedianFromReportRequest, opts ...grpc.CallOption) (*MedianFromReportReply, error)
	MaxReportLength(ctx context.Context, in *MaxReportLengthRequest, opts ...grpc.CallOption) (*MaxReportLengthReply, error)
}

ReportCodecClient is the client API for ReportCodec 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 NewReportCodecClient 

func NewReportCodecClient(cc grpc.ClientConnInterface) ReportCodecClient

type ReportCodecServer 

type ReportCodecServer interface {
	BuildReport(context.Context, *BuildReportRequest) (*BuildReportReply, error)
	MedianFromReport(context.Context, *MedianFromReportRequest) (*MedianFromReportReply, error)
	MaxReportLength(context.Context, *MaxReportLengthRequest) (*MaxReportLengthReply, error)
	// contains filtered or unexported methods
}

ReportCodecServer is the server API for ReportCodec service. All implementations must embed UnimplementedReportCodecServer for forward compatibility

type ReportContext 

type ReportContext struct {
	ReportTimestamp *ReportTimestamp `protobuf:"bytes,1,opt,name=reportTimestamp,proto3" json:"reportTimestamp,omitempty"`
	ExtraHash       []byte           `protobuf:"bytes,2,opt,name=extraHash,proto3" json:"extraHash,omitempty"` // [32]byte
	// contains filtered or unexported fields
}

ReportContext represents github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportContext.

func (*ReportContext) Descriptor deprecated 

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

Deprecated: Use ReportContext.ProtoReflect.Descriptor instead.

func (*ReportContext) GetExtraHash 

func (x *ReportContext) GetExtraHash() []byte

func (*ReportContext) GetReportTimestamp 

func (x *ReportContext) GetReportTimestamp() *ReportTimestamp

func (*ReportContext) ProtoMessage 

func (*ReportContext) ProtoMessage()

func (*ReportContext) ProtoReflect 

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

func (*ReportContext) Reset 

func (x *ReportContext) Reset()

func (*ReportContext) String 

func (x *ReportContext) String() string

type ReportReply 

type ReportReply 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
}

ReportReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.Report.

func (*ReportReply) Descriptor deprecated 

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

Deprecated: Use ReportReply.ProtoReflect.Descriptor instead.

func (*ReportReply) GetReport 

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

func (*ReportReply) GetShouldReport 

func (x *ReportReply) GetShouldReport() bool

func (*ReportReply) ProtoMessage 

func (*ReportReply) ProtoMessage()

func (*ReportReply) ProtoReflect 

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

func (*ReportReply) Reset 

func (x *ReportReply) Reset()

func (*ReportReply) String 

func (x *ReportReply) String() string

type ReportRequest 

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

ReportRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.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) GetQuery 

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

func (*ReportRequest) GetReportTimestamp 

func (x *ReportRequest) GetReportTimestamp() *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 ReportTimestamp 

type ReportTimestamp struct {
	ConfigDigest []byte `protobuf:"bytes,1,opt,name=configDigest,proto3" json:"configDigest,omitempty"` // [32]byte
	Epoch        uint32 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Round        uint32 `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"` // uint8
	// contains filtered or unexported fields
}

ReportTimestamp represents github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportTimestamp.

func (*ReportTimestamp) Descriptor deprecated 

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

Deprecated: Use ReportTimestamp.ProtoReflect.Descriptor instead.

func (*ReportTimestamp) GetConfigDigest 

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

func (*ReportTimestamp) GetEpoch 

func (x *ReportTimestamp) GetEpoch() uint32

func (*ReportTimestamp) GetRound 

func (x *ReportTimestamp) GetRound() uint32

func (*ReportTimestamp) ProtoMessage 

func (*ReportTimestamp) ProtoMessage()

func (*ReportTimestamp) ProtoReflect 

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

func (*ReportTimestamp) Reset 

func (x *ReportTimestamp) Reset()

func (*ReportTimestamp) String 

func (x *ReportTimestamp) String() string

type ReportingPluginClient 

type ReportingPluginClient interface {
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryReply, error)
	Observation(ctx context.Context, in *ObservationRequest, opts ...grpc.CallOption) (*ObservationReply, error)
	Report(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportReply, error)
	ShouldAcceptFinalizedReport(ctx context.Context, in *ShouldAcceptFinalizedReportRequest, opts ...grpc.CallOption) (*ShouldAcceptFinalizedReportReply, error)
	ShouldTransmitAcceptedReport(ctx context.Context, in *ShouldTransmitAcceptedReportRequest, opts ...grpc.CallOption) (*ShouldTransmitAcceptedReportReply, error)
	Close(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ReportingPluginClient is the client API for ReportingPlugin 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 NewReportingPluginClient 

func NewReportingPluginClient(cc grpc.ClientConnInterface) ReportingPluginClient

type ReportingPluginConfig 

type ReportingPluginConfig 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"`
	MaxDurationQuery                        int64  `protobuf:"varint,8,opt,name=maxDurationQuery,proto3" json:"maxDurationQuery,omitempty"`
	MaxDurationObservation                  int64  `protobuf:"varint,9,opt,name=maxDurationObservation,proto3" json:"maxDurationObservation,omitempty"`
	MaxDurationReport                       int64  `protobuf:"varint,10,opt,name=maxDurationReport,proto3" json:"maxDurationReport,omitempty"`
	MaxDurationShouldAcceptFinalizedReport  int64  `` /* 131-byte string literal not displayed */
	MaxDurationShouldTransmitAcceptedReport int64  `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

ReportingPluginConfig represents github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPluginConfig

func (*ReportingPluginConfig) Descriptor deprecated 

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

Deprecated: Use ReportingPluginConfig.ProtoReflect.Descriptor instead.

func (*ReportingPluginConfig) GetConfigDigest 

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

func (*ReportingPluginConfig) GetEstimatedRoundInterval 

func (x *ReportingPluginConfig) GetEstimatedRoundInterval() int64

func (*ReportingPluginConfig) GetF 

func (x *ReportingPluginConfig) GetF() uint32

func (*ReportingPluginConfig) GetMaxDurationObservation 

func (x *ReportingPluginConfig) GetMaxDurationObservation() int64

func (*ReportingPluginConfig) GetMaxDurationQuery 

func (x *ReportingPluginConfig) GetMaxDurationQuery() int64

func (*ReportingPluginConfig) GetMaxDurationReport 

func (x *ReportingPluginConfig) GetMaxDurationReport() int64

func (*ReportingPluginConfig) GetMaxDurationShouldAcceptFinalizedReport 

func (x *ReportingPluginConfig) GetMaxDurationShouldAcceptFinalizedReport() int64

func (*ReportingPluginConfig) GetMaxDurationShouldTransmitAcceptedReport 

func (x *ReportingPluginConfig) GetMaxDurationShouldTransmitAcceptedReport() int64

func (*ReportingPluginConfig) GetN 

func (x *ReportingPluginConfig) GetN() uint32

func (*ReportingPluginConfig) GetOffchainConfig 

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

func (*ReportingPluginConfig) GetOnchainConfig 

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

func (*ReportingPluginConfig) GetOracleID 

func (x *ReportingPluginConfig) GetOracleID() uint32

func (*ReportingPluginConfig) ProtoMessage 

func (*ReportingPluginConfig) ProtoMessage()

func (*ReportingPluginConfig) ProtoReflect 

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

func (*ReportingPluginConfig) Reset 

func (x *ReportingPluginConfig) Reset()

func (*ReportingPluginConfig) String 

func (x *ReportingPluginConfig) String() string

type ReportingPluginFactoryClient 

type ReportingPluginFactoryClient interface {
	NewReportingPlugin(ctx context.Context, in *NewReportingPluginRequest, opts ...grpc.CallOption) (*NewReportingPluginReply, error)
}

ReportingPluginFactoryClient is the client API for ReportingPluginFactory 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 NewReportingPluginFactoryClient 

func NewReportingPluginFactoryClient(cc grpc.ClientConnInterface) ReportingPluginFactoryClient

type ReportingPluginFactoryServer 

type ReportingPluginFactoryServer interface {
	NewReportingPlugin(context.Context, *NewReportingPluginRequest) (*NewReportingPluginReply, error)
	// contains filtered or unexported methods
}

ReportingPluginFactoryServer is the server API for ReportingPluginFactory service. All implementations must embed UnimplementedReportingPluginFactoryServer for forward compatibility

type ReportingPluginInfo 

type ReportingPluginInfo struct {
	Name                  string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UniqueReports         bool                   `protobuf:"varint,2,opt,name=uniqueReports,proto3" json:"uniqueReports,omitempty"`
	ReportingPluginLimits *ReportingPluginLimits `protobuf:"bytes,3,opt,name=reportingPluginLimits,proto3" json:"reportingPluginLimits,omitempty"`
	// contains filtered or unexported fields
}

ReportingPluginInfo represents github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPluginInfo

func (*ReportingPluginInfo) Descriptor deprecated 

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

Deprecated: Use ReportingPluginInfo.ProtoReflect.Descriptor instead.

func (*ReportingPluginInfo) GetName 

func (x *ReportingPluginInfo) GetName() string

func (*ReportingPluginInfo) GetReportingPluginLimits 

func (x *ReportingPluginInfo) GetReportingPluginLimits() *ReportingPluginLimits

func (*ReportingPluginInfo) GetUniqueReports 

func (x *ReportingPluginInfo) GetUniqueReports() bool

func (*ReportingPluginInfo) ProtoMessage 

func (*ReportingPluginInfo) ProtoMessage()

func (*ReportingPluginInfo) ProtoReflect 

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

func (*ReportingPluginInfo) Reset 

func (x *ReportingPluginInfo) Reset()

func (*ReportingPluginInfo) String 

func (x *ReportingPluginInfo) String() string

type ReportingPluginLimits 

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

ReportingPluginLimits represents github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPluginLimits

func (*ReportingPluginLimits) Descriptor deprecated 

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

Deprecated: Use ReportingPluginLimits.ProtoReflect.Descriptor instead.

func (*ReportingPluginLimits) GetMaxObservationLength 

func (x *ReportingPluginLimits) GetMaxObservationLength() uint64

func (*ReportingPluginLimits) GetMaxQueryLength 

func (x *ReportingPluginLimits) GetMaxQueryLength() uint64

func (*ReportingPluginLimits) GetMaxReportLength 

func (x *ReportingPluginLimits) GetMaxReportLength() uint64

func (*ReportingPluginLimits) ProtoMessage 

func (*ReportingPluginLimits) ProtoMessage()

func (*ReportingPluginLimits) ProtoReflect 

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

func (*ReportingPluginLimits) Reset 

func (x *ReportingPluginLimits) Reset()

func (*ReportingPluginLimits) String 

func (x *ReportingPluginLimits) String() string

type ReportingPluginServer 

type ReportingPluginServer interface {
	Query(context.Context, *QueryRequest) (*QueryReply, error)
	Observation(context.Context, *ObservationRequest) (*ObservationReply, error)
	Report(context.Context, *ReportRequest) (*ReportReply, error)
	ShouldAcceptFinalizedReport(context.Context, *ShouldAcceptFinalizedReportRequest) (*ShouldAcceptFinalizedReportReply, error)
	ShouldTransmitAcceptedReport(context.Context, *ShouldTransmitAcceptedReportRequest) (*ShouldTransmitAcceptedReportReply, error)
	Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ReportingPluginServer is the server API for ReportingPlugin service. All implementations must embed UnimplementedReportingPluginServer for forward compatibility

type ReportingPluginServiceClient 

type ReportingPluginServiceClient interface {
	NewReportingPluginFactory(ctx context.Context, in *NewReportingPluginFactoryRequest, opts ...grpc.CallOption) (*NewReportingPluginFactoryReply, error)
}

ReportingPluginServiceClient is the client API for ReportingPluginService 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 NewReportingPluginServiceClient 

func NewReportingPluginServiceClient(cc grpc.ClientConnInterface) ReportingPluginServiceClient

type ReportingPluginServiceConfig 

type ReportingPluginServiceConfig struct {
	ProviderType  string `protobuf:"bytes,1,opt,name=providerType,proto3" json:"providerType,omitempty"`
	Command       string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	PluginName    string `protobuf:"bytes,3,opt,name=pluginName,proto3" json:"pluginName,omitempty"`
	PluginConfig  string `protobuf:"bytes,4,opt,name=pluginConfig,proto3" json:"pluginConfig,omitempty"`
	TelemetryType string `protobuf:"bytes,5,opt,name=telemetryType,proto3" json:"telemetryType,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportingPluginServiceConfig) Descriptor deprecated 

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

Deprecated: Use ReportingPluginServiceConfig.ProtoReflect.Descriptor instead.

func (*ReportingPluginServiceConfig) GetCommand 

func (x *ReportingPluginServiceConfig) GetCommand() string

func (*ReportingPluginServiceConfig) GetPluginConfig 

func (x *ReportingPluginServiceConfig) GetPluginConfig() string

func (*ReportingPluginServiceConfig) GetPluginName 

func (x *ReportingPluginServiceConfig) GetPluginName() string

func (*ReportingPluginServiceConfig) GetProviderType 

func (x *ReportingPluginServiceConfig) GetProviderType() string

func (*ReportingPluginServiceConfig) GetTelemetryType 

func (x *ReportingPluginServiceConfig) GetTelemetryType() string

func (*ReportingPluginServiceConfig) ProtoMessage 

func (*ReportingPluginServiceConfig) ProtoMessage()

func (*ReportingPluginServiceConfig) ProtoReflect 

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

func (*ReportingPluginServiceConfig) Reset 

func (x *ReportingPluginServiceConfig) Reset()

func (*ReportingPluginServiceConfig) String 

func (x *ReportingPluginServiceConfig) String() string

type ReportingPluginServiceServer 

type ReportingPluginServiceServer interface {
	NewReportingPluginFactory(context.Context, *NewReportingPluginFactoryRequest) (*NewReportingPluginFactoryReply, error)
	// contains filtered or unexported methods
}

ReportingPluginServiceServer is the server API for ReportingPluginService service. All implementations must embed UnimplementedReportingPluginServiceServer for forward compatibility

type RunRequest 

type RunRequest struct {
	Spec    string           `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Vars    *structpb.Struct `protobuf:"bytes,2,opt,name=vars,proto3" json:"vars,omitempty"`
	Options *Options         `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor deprecated 

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

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetOptions 

func (x *RunRequest) GetOptions() *Options

func (*RunRequest) GetSpec 

func (x *RunRequest) GetSpec() string

func (*RunRequest) GetVars 

func (x *RunRequest) GetVars() *structpb.Struct

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect 

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

func (*RunRequest) Reset 

func (x *RunRequest) Reset()

func (*RunRequest) String 

func (x *RunRequest) String() string

type RunResponse 

type RunResponse struct {
	Results []*TaskResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*RunResponse) Descriptor deprecated 

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

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) GetResults 

func (x *RunResponse) GetResults() []*TaskResult

func (*RunResponse) ProtoMessage 

func (*RunResponse) ProtoMessage()

func (*RunResponse) ProtoReflect 

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

func (*RunResponse) Reset 

func (x *RunResponse) Reset()

func (*RunResponse) String 

func (x *RunResponse) String() string

type SaveErrorRequest 

type SaveErrorRequest struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

SaveErrorRequest has arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.ErrorLog.SaveErrorRequest.

func (*SaveErrorRequest) Descriptor deprecated 

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

Deprecated: Use SaveErrorRequest.ProtoReflect.Descriptor instead.

func (*SaveErrorRequest) GetMessage 

func (x *SaveErrorRequest) GetMessage() string

func (*SaveErrorRequest) ProtoMessage 

func (*SaveErrorRequest) ProtoMessage()

func (*SaveErrorRequest) ProtoReflect 

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

func (*SaveErrorRequest) Reset 

func (x *SaveErrorRequest) Reset()

func (*SaveErrorRequest) String 

func (x *SaveErrorRequest) String() string

type ServiceClient 

type ServiceClient interface {
	Name(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NameReply, error)
	Close(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Ready(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	HealthReport(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthReportReply, error)
}

ServiceClient is the client API for Service 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 NewServiceClient 

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer 

type ServiceServer interface {
	Name(context.Context, *emptypb.Empty) (*NameReply, error)
	Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	Ready(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	HealthReport(context.Context, *emptypb.Empty) (*HealthReportReply, error)
	// contains filtered or unexported methods
}

ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility

type ShouldAcceptFinalizedReportReply 

type ShouldAcceptFinalizedReportReply struct {
	ShouldAccept bool `protobuf:"varint,1,opt,name=shouldAccept,proto3" json:"shouldAccept,omitempty"`
	// contains filtered or unexported fields
}

ShouldAcceptFinalizedReportReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.ShouldAcceptFinalizedReport.

func (*ShouldAcceptFinalizedReportReply) Descriptor deprecated 

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

Deprecated: Use ShouldAcceptFinalizedReportReply.ProtoReflect.Descriptor instead.

func (*ShouldAcceptFinalizedReportReply) GetShouldAccept 

func (x *ShouldAcceptFinalizedReportReply) GetShouldAccept() bool

func (*ShouldAcceptFinalizedReportReply) ProtoMessage 

func (*ShouldAcceptFinalizedReportReply) ProtoMessage()

func (*ShouldAcceptFinalizedReportReply) ProtoReflect 

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

func (*ShouldAcceptFinalizedReportReply) Reset 

func (x *ShouldAcceptFinalizedReportReply) Reset()

func (*ShouldAcceptFinalizedReportReply) String 

func (x *ShouldAcceptFinalizedReportReply) String() string

type ShouldAcceptFinalizedReportRequest 

type ShouldAcceptFinalizedReportRequest struct {
	ReportTimestamp *ReportTimestamp `protobuf:"bytes,1,opt,name=reportTimestamp,proto3" json:"reportTimestamp,omitempty"`
	Report          []byte           `protobuf:"bytes,2,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

ShouldAcceptFinalizedReportRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.ShouldAcceptFinalizedReport.

func (*ShouldAcceptFinalizedReportRequest) Descriptor deprecated 

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

Deprecated: Use ShouldAcceptFinalizedReportRequest.ProtoReflect.Descriptor instead.

func (*ShouldAcceptFinalizedReportRequest) GetReport 

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

func (*ShouldAcceptFinalizedReportRequest) GetReportTimestamp 

func (x *ShouldAcceptFinalizedReportRequest) GetReportTimestamp() *ReportTimestamp

func (*ShouldAcceptFinalizedReportRequest) ProtoMessage 

func (*ShouldAcceptFinalizedReportRequest) ProtoMessage()

func (*ShouldAcceptFinalizedReportRequest) ProtoReflect 

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

func (*ShouldAcceptFinalizedReportRequest) Reset 

func (x *ShouldAcceptFinalizedReportRequest) Reset()

func (*ShouldAcceptFinalizedReportRequest) String 

func (x *ShouldAcceptFinalizedReportRequest) String() string

type ShouldTransmitAcceptedReportReply 

type ShouldTransmitAcceptedReportReply struct {
	ShouldTransmit bool `protobuf:"varint,1,opt,name=shouldTransmit,proto3" json:"shouldTransmit,omitempty"`
	// contains filtered or unexported fields
}

ShouldTransmitAcceptedReportReply has return arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.ShouldTransmitAcceptedReport.

func (*ShouldTransmitAcceptedReportReply) Descriptor deprecated 

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

Deprecated: Use ShouldTransmitAcceptedReportReply.ProtoReflect.Descriptor instead.

func (*ShouldTransmitAcceptedReportReply) GetShouldTransmit 

func (x *ShouldTransmitAcceptedReportReply) GetShouldTransmit() bool

func (*ShouldTransmitAcceptedReportReply) ProtoMessage 

func (*ShouldTransmitAcceptedReportReply) ProtoMessage()

func (*ShouldTransmitAcceptedReportReply) ProtoReflect 

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

func (*ShouldTransmitAcceptedReportReply) Reset 

func (x *ShouldTransmitAcceptedReportReply) Reset()

func (*ShouldTransmitAcceptedReportReply) String 

func (x *ShouldTransmitAcceptedReportReply) String() string

type ShouldTransmitAcceptedReportRequest 

type ShouldTransmitAcceptedReportRequest struct {
	ReportTimestamp *ReportTimestamp `protobuf:"bytes,1,opt,name=reportTimestamp,proto3" json:"reportTimestamp,omitempty"`
	Report          []byte           `protobuf:"bytes,2,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

ShouldTransmitAcceptedReportRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ReportingPlugin.ShouldTransmitAcceptedReport.

func (*ShouldTransmitAcceptedReportRequest) Descriptor deprecated 

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

Deprecated: Use ShouldTransmitAcceptedReportRequest.ProtoReflect.Descriptor instead.

func (*ShouldTransmitAcceptedReportRequest) GetReport 

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

func (*ShouldTransmitAcceptedReportRequest) GetReportTimestamp 

func (x *ShouldTransmitAcceptedReportRequest) GetReportTimestamp() *ReportTimestamp

func (*ShouldTransmitAcceptedReportRequest) ProtoMessage 

func (*ShouldTransmitAcceptedReportRequest) ProtoMessage()

func (*ShouldTransmitAcceptedReportRequest) ProtoReflect 

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

func (*ShouldTransmitAcceptedReportRequest) Reset 

func (x *ShouldTransmitAcceptedReportRequest) Reset()

func (*ShouldTransmitAcceptedReportRequest) String 

func (x *ShouldTransmitAcceptedReportRequest) String() string

type SignReply 

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

func (*SignReply) Descriptor deprecated 

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

Deprecated: Use SignReply.ProtoReflect.Descriptor instead.

func (*SignReply) GetSignedData 

func (x *SignReply) GetSignedData() []byte

func (*SignReply) ProtoMessage 

func (*SignReply) ProtoMessage()

func (*SignReply) ProtoReflect 

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

func (*SignReply) Reset 

func (x *SignReply) Reset()

func (*SignReply) String 

func (x *SignReply) String() string

type SignRequest 

type SignRequest struct {
	Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Data    []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SignRequest) Descriptor deprecated 

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

Deprecated: Use SignRequest.ProtoReflect.Descriptor instead.

func (*SignRequest) GetAccount 

func (x *SignRequest) GetAccount() string

func (*SignRequest) GetData 

func (x *SignRequest) GetData() []byte

func (*SignRequest) ProtoMessage 

func (*SignRequest) ProtoMessage()

func (*SignRequest) ProtoReflect 

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

func (*SignRequest) Reset 

func (x *SignRequest) Reset()

func (*SignRequest) String 

func (x *SignRequest) String() string

type StarknetMessageHash 

type StarknetMessageHash struct {
	Hash *BigInt `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*StarknetMessageHash) Descriptor deprecated 

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

Deprecated: Use StarknetMessageHash.ProtoReflect.Descriptor instead.

func (*StarknetMessageHash) GetHash 

func (x *StarknetMessageHash) GetHash() *BigInt

func (*StarknetMessageHash) ProtoMessage 

func (*StarknetMessageHash) ProtoMessage()

func (*StarknetMessageHash) ProtoReflect 

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

func (*StarknetMessageHash) Reset 

func (x *StarknetMessageHash) Reset()

func (*StarknetMessageHash) String 

func (x *StarknetMessageHash) String() string

type StarknetSignature 

type StarknetSignature struct {
	X *BigInt `protobuf:"bytes,1,opt,name=x,proto3" json:"x,omitempty"`
	Y *BigInt `protobuf:"bytes,2,opt,name=y,proto3" json:"y,omitempty"`
	// contains filtered or unexported fields
}

func (*StarknetSignature) Descriptor deprecated 

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

Deprecated: Use StarknetSignature.ProtoReflect.Descriptor instead.

func (*StarknetSignature) GetX 

func (x *StarknetSignature) GetX() *BigInt

func (*StarknetSignature) GetY 

func (x *StarknetSignature) GetY() *BigInt

func (*StarknetSignature) ProtoMessage 

func (*StarknetSignature) ProtoMessage()

func (*StarknetSignature) ProtoReflect 

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

func (*StarknetSignature) Reset 

func (x *StarknetSignature) Reset()

func (*StarknetSignature) String 

func (x *StarknetSignature) String() string

type TaskResult 

type TaskResult struct {
	Id         string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type       string          `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Value      *structpb.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Error      string          `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	HasError   bool            `protobuf:"varint,5,opt,name=has_error,json=hasError,proto3" json:"has_error,omitempty"`
	IsTerminal bool            `protobuf:"varint,6,opt,name=is_terminal,json=isTerminal,proto3" json:"is_terminal,omitempty"`
	Index      int32           `protobuf:"varint,7,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResult) Descriptor deprecated 

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

Deprecated: Use TaskResult.ProtoReflect.Descriptor instead.

func (*TaskResult) GetError 

func (x *TaskResult) GetError() string

func (*TaskResult) GetHasError 

func (x *TaskResult) GetHasError() bool

func (*TaskResult) GetId 

func (x *TaskResult) GetId() string

func (*TaskResult) GetIndex 

func (x *TaskResult) GetIndex() int32

func (*TaskResult) GetIsTerminal 

func (x *TaskResult) GetIsTerminal() bool

func (*TaskResult) GetType 

func (x *TaskResult) GetType() string

func (*TaskResult) GetValue 

func (x *TaskResult) GetValue() *structpb.Value

func (*TaskResult) ProtoMessage 

func (*TaskResult) ProtoMessage()

func (*TaskResult) ProtoReflect 

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

func (*TaskResult) Reset 

func (x *TaskResult) Reset()

func (*TaskResult) String 

func (x *TaskResult) String() string

type TelemetryClient 

type TelemetryClient interface {
	Send(ctx context.Context, in *TelemetryMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

TelemetryClient is the client API for Telemetry 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 NewTelemetryClient 

func NewTelemetryClient(cc grpc.ClientConnInterface) TelemetryClient

type TelemetryMessage 

type TelemetryMessage struct {
	RelayID       *RelayID `protobuf:"bytes,1,opt,name=relayID,proto3" json:"relayID,omitempty"`
	ContractID    string   `protobuf:"bytes,2,opt,name=contractID,proto3" json:"contractID,omitempty"`
	TelemetryType string   `protobuf:"bytes,3,opt,name=telemetryType,proto3" json:"telemetryType,omitempty"`
	Payload       []byte   `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*TelemetryMessage) Descriptor deprecated 

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

Deprecated: Use TelemetryMessage.ProtoReflect.Descriptor instead.

func (*TelemetryMessage) GetContractID 

func (x *TelemetryMessage) GetContractID() string

func (*TelemetryMessage) GetPayload 

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

func (*TelemetryMessage) GetRelayID 

func (x *TelemetryMessage) GetRelayID() *RelayID

func (*TelemetryMessage) GetTelemetryType 

func (x *TelemetryMessage) GetTelemetryType() string

func (*TelemetryMessage) ProtoMessage 

func (*TelemetryMessage) ProtoMessage()

func (*TelemetryMessage) ProtoReflect 

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

func (*TelemetryMessage) Reset 

func (x *TelemetryMessage) Reset()

func (*TelemetryMessage) String 

func (x *TelemetryMessage) String() string

type TelemetryServer 

type TelemetryServer interface {
	Send(context.Context, *TelemetryMessage) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

TelemetryServer is the server API for Telemetry service. All implementations must embed UnimplementedTelemetryServer for forward compatibility

type TransactionRequest 

type TransactionRequest struct {
	From         string  `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To           string  `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	Amount       *BigInt `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
	BalanceCheck bool    `protobuf:"varint,4,opt,name=balanceCheck,proto3" json:"balanceCheck,omitempty"`
	// contains filtered or unexported fields
}

SendTxRequest has arguments for github.com/O1MaGnUmO1/chainlink-common/pkg/loop.Relayer.SendTx.

func (*TransactionRequest) Descriptor deprecated 

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

Deprecated: Use TransactionRequest.ProtoReflect.Descriptor instead.

func (*TransactionRequest) GetAmount 

func (x *TransactionRequest) GetAmount() *BigInt

func (*TransactionRequest) GetBalanceCheck 

func (x *TransactionRequest) GetBalanceCheck() bool

func (*TransactionRequest) GetFrom 

func (x *TransactionRequest) GetFrom() string

func (*TransactionRequest) GetTo 

func (x *TransactionRequest) GetTo() string

func (*TransactionRequest) ProtoMessage 

func (*TransactionRequest) ProtoMessage()

func (*TransactionRequest) ProtoReflect 

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

func (*TransactionRequest) Reset 

func (x *TransactionRequest) Reset()

func (*TransactionRequest) String 

func (x *TransactionRequest) String() string

type TransmitReply 

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

func (*TransmitReply) Descriptor deprecated 

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

Deprecated: Use TransmitReply.ProtoReflect.Descriptor instead.

func (*TransmitReply) ProtoMessage 

func (*TransmitReply) ProtoMessage()

func (*TransmitReply) ProtoReflect 

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

func (*TransmitReply) Reset 

func (x *TransmitReply) Reset()

func (*TransmitReply) String 

func (x *TransmitReply) String() string

type TransmitRequest 

type TransmitRequest struct {
	ReportContext               *ReportContext                `protobuf:"bytes,1,opt,name=reportContext,proto3" json:"reportContext,omitempty"`
	Report                      []byte                        `protobuf:"bytes,2,opt,name=report,proto3" json:"report,omitempty"`
	AttributedOnchainSignatures []*AttributedOnchainSignature `protobuf:"bytes,3,rep,name=attributedOnchainSignatures,proto3" json:"attributedOnchainSignatures,omitempty"`
	// contains filtered or unexported fields
}

TransmitRequest has arguments for github.com/smartcontractkit/libocr/offchainreporting2plus/types.ContractTransmitter.Transmit.

func (*TransmitRequest) Descriptor deprecated 

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

Deprecated: Use TransmitRequest.ProtoReflect.Descriptor instead.

func (*TransmitRequest) GetAttributedOnchainSignatures 

func (x *TransmitRequest) GetAttributedOnchainSignatures() []*AttributedOnchainSignature

func (*TransmitRequest) GetReport 

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

func (*TransmitRequest) GetReportContext 

func (x *TransmitRequest) GetReportContext() *ReportContext

func (*TransmitRequest) ProtoMessage 

func (*TransmitRequest) ProtoMessage()

func (*TransmitRequest) ProtoReflect 

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

func (*TransmitRequest) Reset 

func (x *TransmitRequest) Reset()

func (*TransmitRequest) String 

func (x *TransmitRequest) String() string

type UnimplementedChainReaderServer 

type UnimplementedChainReaderServer struct {
}

UnimplementedChainReaderServer must be embedded to have forward compatible implementations.

func (UnimplementedChainReaderServer) Bind 

func (UnimplementedChainReaderServer) Bind(context.Context, *BindRequest) (*emptypb.Empty, error)

func (UnimplementedChainReaderServer) GetLatestValue 

func (UnimplementedChainReaderServer) GetLatestValue(context.Context, *GetLatestValueRequest) (*GetLatestValueReply, error)

type UnimplementedCodecServer 

type UnimplementedCodecServer struct {
}

UnimplementedCodecServer must be embedded to have forward compatible implementations.

func (UnimplementedCodecServer) GetDecoding 

func (UnimplementedCodecServer) GetDecoding(context.Context, *GetDecodingRequest) (*GetDecodingResponse, error)

func (UnimplementedCodecServer) GetEncoding 

func (UnimplementedCodecServer) GetEncoding(context.Context, *GetEncodingRequest) (*GetEncodingResponse, error)

func (UnimplementedCodecServer) GetMaxSize 

func (UnimplementedCodecServer) GetMaxSize(context.Context, *GetMaxSizeRequest) (*GetMaxSizeResponse, error)

type UnimplementedContractConfigTrackerServer 

type UnimplementedContractConfigTrackerServer struct {
}

UnimplementedContractConfigTrackerServer must be embedded to have forward compatible implementations.

func (UnimplementedContractConfigTrackerServer) LatestBlockHeight 

func (UnimplementedContractConfigTrackerServer) LatestBlockHeight(context.Context, *LatestBlockHeightRequest) (*LatestBlockHeightReply, error)

func (UnimplementedContractConfigTrackerServer) LatestConfig 

func (UnimplementedContractConfigTrackerServer) LatestConfig(context.Context, *LatestConfigRequest) (*LatestConfigReply, error)

func (UnimplementedContractConfigTrackerServer) LatestConfigDetails 

func (UnimplementedContractConfigTrackerServer) LatestConfigDetails(context.Context, *LatestConfigDetailsRequest) (*LatestConfigDetailsReply, error)

type UnimplementedContractTransmitterServer 

type UnimplementedContractTransmitterServer struct {
}

UnimplementedContractTransmitterServer must be embedded to have forward compatible implementations.

func (UnimplementedContractTransmitterServer) FromAccount 

func (UnimplementedContractTransmitterServer) FromAccount(context.Context, *FromAccountRequest) (*FromAccountReply, error)

func (UnimplementedContractTransmitterServer) LatestConfigDigestAndEpoch 

func (UnimplementedContractTransmitterServer) LatestConfigDigestAndEpoch(context.Context, *LatestConfigDigestAndEpochRequest) (*LatestConfigDigestAndEpochReply, error)

func (UnimplementedContractTransmitterServer) Transmit 

func (UnimplementedContractTransmitterServer) Transmit(context.Context, *TransmitRequest) (*TransmitReply, error)

type UnimplementedDataSourceServer 

type UnimplementedDataSourceServer struct {
}

UnimplementedDataSourceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataSourceServer) Observe 

func (UnimplementedDataSourceServer) Observe(context.Context, *ObserveRequest) (*ObserveReply, error)

type UnimplementedErrorLogServer 

type UnimplementedErrorLogServer struct {
}

UnimplementedErrorLogServer must be embedded to have forward compatible implementations.

func (UnimplementedErrorLogServer) SaveError 

func (UnimplementedErrorLogServer) SaveError(context.Context, *SaveErrorRequest) (*emptypb.Empty, error)

type UnimplementedKeystoreServer 

type UnimplementedKeystoreServer struct {
}

UnimplementedKeystoreServer must be embedded to have forward compatible implementations.

func (UnimplementedKeystoreServer) Accounts 

func (UnimplementedKeystoreServer) Accounts(context.Context, *emptypb.Empty) (*AccountsReply, error)

func (UnimplementedKeystoreServer) Sign 

func (UnimplementedKeystoreServer) Sign(context.Context, *SignRequest) (*SignReply, error)

type UnimplementedMedianContractServer 

type UnimplementedMedianContractServer struct {
}

UnimplementedMedianContractServer must be embedded to have forward compatible implementations.

func (UnimplementedMedianContractServer) LatestRoundRequested 

func (UnimplementedMedianContractServer) LatestRoundRequested(context.Context, *LatestRoundRequestedRequest) (*LatestRoundRequestedReply, error)

func (UnimplementedMedianContractServer) LatestTransmissionDetails 

func (UnimplementedMedianContractServer) LatestTransmissionDetails(context.Context, *LatestTransmissionDetailsRequest) (*LatestTransmissionDetailsReply, error)

type UnimplementedOffchainConfigDigesterServer 

type UnimplementedOffchainConfigDigesterServer struct {
}

UnimplementedOffchainConfigDigesterServer must be embedded to have forward compatible implementations.

func (UnimplementedOffchainConfigDigesterServer) ConfigDigest 

func (UnimplementedOffchainConfigDigesterServer) ConfigDigest(context.Context, *ConfigDigestRequest) (*ConfigDigestReply, error)

func (UnimplementedOffchainConfigDigesterServer) ConfigDigestPrefix 

func (UnimplementedOffchainConfigDigesterServer) ConfigDigestPrefix(context.Context, *ConfigDigestPrefixRequest) (*ConfigDigestPrefixReply, error)

type UnimplementedOnchainConfigCodecServer 

type UnimplementedOnchainConfigCodecServer struct {
}

UnimplementedOnchainConfigCodecServer must be embedded to have forward compatible implementations.

func (UnimplementedOnchainConfigCodecServer) Decode 

func (UnimplementedOnchainConfigCodecServer) Decode(context.Context, *DecodeRequest) (*DecodeReply, error)

func (UnimplementedOnchainConfigCodecServer) Encode 

func (UnimplementedOnchainConfigCodecServer) Encode(context.Context, *EncodeRequest) (*EncodeReply, error)

type UnimplementedPipelineRunnerServiceServer 

type UnimplementedPipelineRunnerServiceServer struct {
}

UnimplementedPipelineRunnerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPipelineRunnerServiceServer) ExecuteRun 

func (UnimplementedPipelineRunnerServiceServer) ExecuteRun(context.Context, *RunRequest) (*RunResponse, error)

type UnimplementedPluginMedianServer 

type UnimplementedPluginMedianServer struct {
}

UnimplementedPluginMedianServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginMedianServer) NewMedianFactory 

func (UnimplementedPluginMedianServer) NewMedianFactory(context.Context, *NewMedianFactoryRequest) (*NewMedianFactoryReply, error)

type UnimplementedPluginRelayerServer 

type UnimplementedPluginRelayerServer struct {
}

UnimplementedPluginRelayerServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginRelayerServer) NewRelayer 

func (UnimplementedPluginRelayerServer) NewRelayer(context.Context, *NewRelayerRequest) (*NewRelayerReply, error)

type UnimplementedRelayerServer 

type UnimplementedRelayerServer struct {
}

UnimplementedRelayerServer must be embedded to have forward compatible implementations.

func (UnimplementedRelayerServer) GetChainStatus 

func (UnimplementedRelayerServer) GetChainStatus(context.Context, *GetChainStatusRequest) (*GetChainStatusReply, error)

func (UnimplementedRelayerServer) ListNodeStatuses 

func (UnimplementedRelayerServer) ListNodeStatuses(context.Context, *ListNodeStatusesRequest) (*ListNodeStatusesReply, error)

func (UnimplementedRelayerServer) NewConfigProvider 

func (UnimplementedRelayerServer) NewConfigProvider(context.Context, *NewConfigProviderRequest) (*NewConfigProviderReply, error)

func (UnimplementedRelayerServer) NewPluginProvider 

func (UnimplementedRelayerServer) NewPluginProvider(context.Context, *NewPluginProviderRequest) (*NewPluginProviderReply, error)

func (UnimplementedRelayerServer) Transact 

func (UnimplementedRelayerServer) Transact(context.Context, *TransactionRequest) (*emptypb.Empty, error)

type UnimplementedReportCodecServer 

type UnimplementedReportCodecServer struct {
}

UnimplementedReportCodecServer must be embedded to have forward compatible implementations.

func (UnimplementedReportCodecServer) BuildReport 

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

func (UnimplementedReportCodecServer) MaxReportLength 

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

func (UnimplementedReportCodecServer) MedianFromReport 

func (UnimplementedReportCodecServer) MedianFromReport(context.Context, *MedianFromReportRequest) (*MedianFromReportReply, error)

type UnimplementedReportingPluginFactoryServer 

type UnimplementedReportingPluginFactoryServer struct {
}

UnimplementedReportingPluginFactoryServer must be embedded to have forward compatible implementations.

func (UnimplementedReportingPluginFactoryServer) NewReportingPlugin 

func (UnimplementedReportingPluginFactoryServer) NewReportingPlugin(context.Context, *NewReportingPluginRequest) (*NewReportingPluginReply, error)

type UnimplementedReportingPluginServer 

type UnimplementedReportingPluginServer struct {
}

UnimplementedReportingPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedReportingPluginServer) Close 

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

func (UnimplementedReportingPluginServer) Observation 

func (UnimplementedReportingPluginServer) Observation(context.Context, *ObservationRequest) (*ObservationReply, error)

func (UnimplementedReportingPluginServer) Query 

func (UnimplementedReportingPluginServer) Query(context.Context, *QueryRequest) (*QueryReply, error)

func (UnimplementedReportingPluginServer) Report 

func (UnimplementedReportingPluginServer) Report(context.Context, *ReportRequest) (*ReportReply, error)

func (UnimplementedReportingPluginServer) ShouldAcceptFinalizedReport 

func (UnimplementedReportingPluginServer) ShouldAcceptFinalizedReport(context.Context, *ShouldAcceptFinalizedReportRequest) (*ShouldAcceptFinalizedReportReply, error)

func (UnimplementedReportingPluginServer) ShouldTransmitAcceptedReport 

func (UnimplementedReportingPluginServer) ShouldTransmitAcceptedReport(context.Context, *ShouldTransmitAcceptedReportRequest) (*ShouldTransmitAcceptedReportReply, error)

type UnimplementedReportingPluginServiceServer 

type UnimplementedReportingPluginServiceServer struct {
}

UnimplementedReportingPluginServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedReportingPluginServiceServer) NewReportingPluginFactory 

func (UnimplementedReportingPluginServiceServer) NewReportingPluginFactory(context.Context, *NewReportingPluginFactoryRequest) (*NewReportingPluginFactoryReply, error)

type UnimplementedServiceServer 

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceServer) Close 

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

func (UnimplementedServiceServer) HealthReport 

func (UnimplementedServiceServer) HealthReport(context.Context, *emptypb.Empty) (*HealthReportReply, error)

func (UnimplementedServiceServer) Name 

func (UnimplementedServiceServer) Name(context.Context, *emptypb.Empty) (*NameReply, error)

func (UnimplementedServiceServer) Ready 

func (UnimplementedServiceServer) Ready(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type UnimplementedTelemetryServer 

type UnimplementedTelemetryServer struct {
}

UnimplementedTelemetryServer must be embedded to have forward compatible implementations.

func (UnimplementedTelemetryServer) Send 

func (UnimplementedTelemetryServer) Send(context.Context, *TelemetryMessage) (*emptypb.Empty, error)

type UnsafeChainReaderServer 

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

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

type UnsafeCodecServer 

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

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

type UnsafeContractConfigTrackerServer 

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

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

type UnsafeContractTransmitterServer 

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

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

type UnsafeDataSourceServer 

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

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

type UnsafeErrorLogServer 

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

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

type UnsafeKeystoreServer 

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

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

type UnsafeMedianContractServer 

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

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

type UnsafeOffchainConfigDigesterServer 

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

UnsafeOffchainConfigDigesterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OffchainConfigDigesterServer 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 UnsafePipelineRunnerServiceServer 

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

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

type UnsafePluginMedianServer 

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

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

type UnsafePluginRelayerServer 

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

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

type UnsafeRelayerServer 

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

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

type UnsafeReportCodecServer 

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

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

type UnsafeReportingPluginFactoryServer 

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

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

type UnsafeReportingPluginServer 

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

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

type UnsafeReportingPluginServiceServer 

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

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

type UnsafeServiceServer 

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

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

type UnsafeTelemetryServer 

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

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

type VersionedBytes 

type VersionedBytes struct {
	Version uint32 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Data    []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionedBytes) Descriptor deprecated 

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

Deprecated: Use VersionedBytes.ProtoReflect.Descriptor instead.

func (*VersionedBytes) GetData 

func (x *VersionedBytes) GetData() []byte

func (*VersionedBytes) GetVersion 

func (x *VersionedBytes) GetVersion() uint32

func (*VersionedBytes) ProtoMessage 

func (*VersionedBytes) ProtoMessage()

func (*VersionedBytes) ProtoReflect 

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

func (*VersionedBytes) Reset 

func (x *VersionedBytes) Reset()

func (*VersionedBytes) String 

func (x *VersionedBytes) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.