pb

package
v0.9.4 Latest Latest
Warning

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

 Go to latest Published: Sep 2, 2025 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CapabilitiesRegistry_LocalNode_FullMethodName           = "/loop.CapabilitiesRegistry/LocalNode"
	CapabilitiesRegistry_NodeByPeerID_FullMethodName        = "/loop.CapabilitiesRegistry/NodeByPeerID"
	CapabilitiesRegistry_ConfigForCapability_FullMethodName = "/loop.CapabilitiesRegistry/ConfigForCapability"
	CapabilitiesRegistry_DONsForCapability_FullMethodName   = "/loop.CapabilitiesRegistry/DONsForCapability"
	CapabilitiesRegistry_Get_FullMethodName                 = "/loop.CapabilitiesRegistry/Get"
	CapabilitiesRegistry_GetTrigger_FullMethodName          = "/loop.CapabilitiesRegistry/GetTrigger"
	CapabilitiesRegistry_GetExecutable_FullMethodName       = "/loop.CapabilitiesRegistry/GetExecutable"
	CapabilitiesRegistry_List_FullMethodName                = "/loop.CapabilitiesRegistry/List"
	CapabilitiesRegistry_Add_FullMethodName                 = "/loop.CapabilitiesRegistry/Add"
	CapabilitiesRegistry_Remove_FullMethodName              = "/loop.CapabilitiesRegistry/Remove"
)
View Source 
const (
	ContractReader_GetLatestValue_FullMethodName             = "/loop.ContractReader/GetLatestValue"
	ContractReader_GetLatestValueWithHeadData_FullMethodName = "/loop.ContractReader/GetLatestValueWithHeadData"
	ContractReader_BatchGetLatestValues_FullMethodName       = "/loop.ContractReader/BatchGetLatestValues"
	ContractReader_QueryKey_FullMethodName                   = "/loop.ContractReader/QueryKey"
	ContractReader_QueryKeys_FullMethodName                  = "/loop.ContractReader/QueryKeys"
	ContractReader_Bind_FullMethodName                       = "/loop.ContractReader/Bind"
	ContractReader_Unbind_FullMethodName                     = "/loop.ContractReader/Unbind"
)
View Source 
const (
	ContractWriter_SubmitTransaction_FullMethodName    = "/loop.ContractWriter/SubmitTransaction"
	ContractWriter_GetTransactionStatus_FullMethodName = "/loop.ContractWriter/GetTransactionStatus"
	ContractWriter_GetFeeComponents_FullMethodName     = "/loop.ContractWriter/GetFeeComponents"
	ContractWriter_GetEstimateFee_FullMethodName       = "/loop.ContractWriter/GetEstimateFee"
)
View Source 
const (
	Keystore_Accounts_FullMethodName = "/loop.Keystore/Accounts"
	Keystore_Sign_FullMethodName     = "/loop.Keystore/Sign"
	Keystore_Decrypt_FullMethodName  = "/loop.Keystore/Decrypt"
)
View Source 
const (
	KeyValueStore_StoreKeyValue_FullMethodName       = "/loop.KeyValueStore/StoreKeyValue"
	KeyValueStore_GetValueForKey_FullMethodName      = "/loop.KeyValueStore/GetValueForKey"
	KeyValueStore_PruneExpiredEntries_FullMethodName = "/loop.KeyValueStore/PruneExpiredEntries"
)
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 (
	Relayer_NewContractWriter_FullMethodName = "/loop.Relayer/NewContractWriter"
	Relayer_NewContractReader_FullMethodName = "/loop.Relayer/NewContractReader"
	Relayer_NewConfigProvider_FullMethodName = "/loop.Relayer/NewConfigProvider"
	Relayer_NewPluginProvider_FullMethodName = "/loop.Relayer/NewPluginProvider"
	Relayer_NewCCIPProvider_FullMethodName   = "/loop.Relayer/NewCCIPProvider"
	Relayer_LatestHead_FullMethodName        = "/loop.Relayer/LatestHead"
	Relayer_GetChainStatus_FullMethodName    = "/loop.Relayer/GetChainStatus"
	Relayer_GetChainInfo_FullMethodName      = "/loop.Relayer/GetChainInfo"
	Relayer_ListNodeStatuses_FullMethodName  = "/loop.Relayer/ListNodeStatuses"
	Relayer_Transact_FullMethodName          = "/loop.Relayer/Transact"
	Relayer_Replay_FullMethodName            = "/loop.Relayer/Replay"
)
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 (
	ReportingPluginService_NewReportingPluginFactory_FullMethodName = "/loop.ReportingPluginService/NewReportingPluginFactory"
	ReportingPluginService_NewValidationService_FullMethodName      = "/loop.ReportingPluginService/NewValidationService"
)
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 (
	Telemetry_Send_FullMethodName = "/loop.Telemetry/Send"
)
View Source 
const (
	ValidationService_ValidateConfig_FullMethodName = "/loop.ValidationService/ValidateConfig"
)

Variables

View Source 
var (
	ExecuteAPIType_name = map[int32]string{
		0: "EXECUTE_API_TYPE_UNKNOWN",
		1: "EXECUTE_API_TYPE_TRIGGER",
		2: "EXECUTE_API_TYPE_EXECUTE",
		3: "EXECUTE_API_TYPE_COMBINED",
	}
	ExecuteAPIType_value = map[string]int32{
		"EXECUTE_API_TYPE_UNKNOWN":  0,
		"EXECUTE_API_TYPE_TRIGGER":  1,
		"EXECUTE_API_TYPE_EXECUTE":  2,
		"EXECUTE_API_TYPE_COMBINED": 3,
	}
)

Enum value maps for ExecuteAPIType.

View Source 
var CapabilitiesRegistry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.CapabilitiesRegistry",
	HandlerType: (*CapabilitiesRegistryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LocalNode",
			Handler:    _CapabilitiesRegistry_LocalNode_Handler,
		},
		{
			MethodName: "NodeByPeerID",
			Handler:    _CapabilitiesRegistry_NodeByPeerID_Handler,
		},
		{
			MethodName: "ConfigForCapability",
			Handler:    _CapabilitiesRegistry_ConfigForCapability_Handler,
		},
		{
			MethodName: "DONsForCapability",
			Handler:    _CapabilitiesRegistry_DONsForCapability_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _CapabilitiesRegistry_Get_Handler,
		},
		{
			MethodName: "GetTrigger",
			Handler:    _CapabilitiesRegistry_GetTrigger_Handler,
		},
		{
			MethodName: "GetExecutable",
			Handler:    _CapabilitiesRegistry_GetExecutable_Handler,
		},
		{
			MethodName: "List",
			Handler:    _CapabilitiesRegistry_List_Handler,
		},
		{
			MethodName: "Add",
			Handler:    _CapabilitiesRegistry_Add_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _CapabilitiesRegistry_Remove_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "capabilities_registry.proto",
}

CapabilitiesRegistry_ServiceDesc is the grpc.ServiceDesc for CapabilitiesRegistry 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: "loop/internal/pb/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 ContractReader_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ContractReader",
	HandlerType: (*ContractReaderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetLatestValue",
			Handler:    _ContractReader_GetLatestValue_Handler,
		},
		{
			MethodName: "GetLatestValueWithHeadData",
			Handler:    _ContractReader_GetLatestValueWithHeadData_Handler,
		},
		{
			MethodName: "BatchGetLatestValues",
			Handler:    _ContractReader_BatchGetLatestValues_Handler,
		},
		{
			MethodName: "QueryKey",
			Handler:    _ContractReader_QueryKey_Handler,
		},
		{
			MethodName: "QueryKeys",
			Handler:    _ContractReader_QueryKeys_Handler,
		},
		{
			MethodName: "Bind",
			Handler:    _ContractReader_Bind_Handler,
		},
		{
			MethodName: "Unbind",
			Handler:    _ContractReader_Unbind_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "loop/internal/pb/contract_reader.proto",
}

ContractReader_ServiceDesc is the grpc.ServiceDesc for ContractReader 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: "loop/internal/pb/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 ContractWriter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ContractWriter",
	HandlerType: (*ContractWriterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitTransaction",
			Handler:    _ContractWriter_SubmitTransaction_Handler,
		},
		{
			MethodName: "GetTransactionStatus",
			Handler:    _ContractWriter_GetTransactionStatus_Handler,
		},
		{
			MethodName: "GetFeeComponents",
			Handler:    _ContractWriter_GetFeeComponents_Handler,
		},
		{
			MethodName: "GetEstimateFee",
			Handler:    _ContractWriter_GetEstimateFee_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "contract_writer.proto",
}

ContractWriter_ServiceDesc is the grpc.ServiceDesc for ContractWriter 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: "loop/internal/pb/median_datasource.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: "loop/internal/pb/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_capabilities_registry_proto protoreflect.FileDescriptor
View Source 
var File_contract_writer_proto protoreflect.FileDescriptor
View Source 
var File_keyvalue_store_proto protoreflect.FileDescriptor
View Source 
var File_loop_internal_pb_contract_reader_proto protoreflect.FileDescriptor
View Source 
var File_loop_internal_pb_keystore_proto protoreflect.FileDescriptor
View Source 
var File_loop_internal_pb_median_datasource_proto protoreflect.FileDescriptor
View Source 
var File_loop_internal_pb_median_proto protoreflect.FileDescriptor
View Source 
var File_loop_internal_pb_relayer_proto protoreflect.FileDescriptor
View Source 
var File_loop_internal_pb_reporting_proto protoreflect.FileDescriptor
View Source 
var File_pipeline_runner_proto protoreflect.FileDescriptor
View Source 
var File_reporting_plugin_service_proto protoreflect.FileDescriptor
View Source 
var File_telemetry_proto protoreflect.FileDescriptor
View Source 
var File_validate_config_proto protoreflect.FileDescriptor
View Source 
var KeyValueStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.KeyValueStore",
	HandlerType: (*KeyValueStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StoreKeyValue",
			Handler:    _KeyValueStore_StoreKeyValue_Handler,
		},
		{
			MethodName: "GetValueForKey",
			Handler:    _KeyValueStore_GetValueForKey_Handler,
		},
		{
			MethodName: "PruneExpiredEntries",
			Handler:    _KeyValueStore_PruneExpiredEntries_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "keyvalue_store.proto",
}

KeyValueStore_ServiceDesc is the grpc.ServiceDesc for KeyValueStore 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 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,
		},
		{
			MethodName: "Decrypt",
			Handler:    _Keystore_Decrypt_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "loop/internal/pb/keystore.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: "loop/internal/pb/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: "loop/internal/pb/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: "loop/internal/pb/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: "loop/internal/pb/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: "loop/internal/pb/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: "NewContractWriter",
			Handler:    _Relayer_NewContractWriter_Handler,
		},
		{
			MethodName: "NewContractReader",
			Handler:    _Relayer_NewContractReader_Handler,
		},
		{
			MethodName: "NewConfigProvider",
			Handler:    _Relayer_NewConfigProvider_Handler,
		},
		{
			MethodName: "NewPluginProvider",
			Handler:    _Relayer_NewPluginProvider_Handler,
		},
		{
			MethodName: "NewCCIPProvider",
			Handler:    _Relayer_NewCCIPProvider_Handler,
		},
		{
			MethodName: "LatestHead",
			Handler:    _Relayer_LatestHead_Handler,
		},
		{
			MethodName: "GetChainStatus",
			Handler:    _Relayer_GetChainStatus_Handler,
		},
		{
			MethodName: "GetChainInfo",
			Handler:    _Relayer_GetChainInfo_Handler,
		},
		{
			MethodName: "ListNodeStatuses",
			Handler:    _Relayer_ListNodeStatuses_Handler,
		},
		{
			MethodName: "Transact",
			Handler:    _Relayer_Transact_Handler,
		},
		{
			MethodName: "Replay",
			Handler:    _Relayer_Replay_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "loop/internal/pb/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: "loop/internal/pb/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: "loop/internal/pb/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,
		},
		{
			MethodName: "NewValidationService",
			Handler:    _ReportingPluginService_NewValidationService_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: "loop/internal/pb/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: "loop/internal/pb/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)

View Source 
var ValidationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ValidationService",
	HandlerType: (*ValidationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ValidateConfig",
			Handler:    _ValidationService_ValidateConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "validate_config.proto",
}

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

Functions

func RegisterCapabilitiesRegistryServer 

func RegisterCapabilitiesRegistryServer(s grpc.ServiceRegistrar, srv CapabilitiesRegistryServer)

func RegisterContractConfigTrackerServer 

func RegisterContractConfigTrackerServer(s grpc.ServiceRegistrar, srv ContractConfigTrackerServer)

func RegisterContractReaderServer added in v0.2.2 

func RegisterContractReaderServer(s grpc.ServiceRegistrar, srv ContractReaderServer)

func RegisterContractTransmitterServer 

func RegisterContractTransmitterServer(s grpc.ServiceRegistrar, srv ContractTransmitterServer)

func RegisterContractWriterServer added in v0.4.0 

func RegisterContractWriterServer(s grpc.ServiceRegistrar, srv ContractWriterServer)

func RegisterDataSourceServer 

func RegisterDataSourceServer(s grpc.ServiceRegistrar, srv DataSourceServer)

func RegisterErrorLogServer 

func RegisterErrorLogServer(s grpc.ServiceRegistrar, srv ErrorLogServer)

func RegisterKeyValueStoreServer 

func RegisterKeyValueStoreServer(s grpc.ServiceRegistrar, srv KeyValueStoreServer)

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)

func RegisterValidationServiceServer 

func RegisterValidationServiceServer(s grpc.ServiceRegistrar, srv ValidationServiceServer)

func ReportTimestampFromPb 

func ReportTimestampFromPb(ts *ReportTimestamp) (r libocr.ReportTimestamp, err error)

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 AddRequest 

type AddRequest struct {
	CapabilityID uint32         `protobuf:"varint,1,opt,name=capabilityID,proto3" json:"capabilityID,omitempty"`
	Type         ExecuteAPIType `protobuf:"varint,2,opt,name=type,proto3,enum=loop.ExecuteAPIType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Add has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.Add.

func (*AddRequest) Descriptor deprecated 

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

Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.

func (*AddRequest) GetCapabilityID 

func (x *AddRequest) GetCapabilityID() uint32

func (*AddRequest) GetType 

func (x *AddRequest) GetType() ExecuteAPIType

func (*AddRequest) ProtoMessage 

func (*AddRequest) ProtoMessage()

func (*AddRequest) ProtoReflect 

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

func (*AddRequest) Reset 

func (x *AddRequest) Reset()

func (*AddRequest) String 

func (x *AddRequest) 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 BatchGetLatestValuesReply 

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

BatchGetLatestValuesReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.BatchGetLatestValues.

func (*BatchGetLatestValuesReply) Descriptor deprecated 

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

Deprecated: Use BatchGetLatestValuesReply.ProtoReflect.Descriptor instead.

func (*BatchGetLatestValuesReply) GetResults 

func (x *BatchGetLatestValuesReply) GetResults() []*ContractBatchResult

func (*BatchGetLatestValuesReply) ProtoMessage 

func (*BatchGetLatestValuesReply) ProtoMessage()

func (*BatchGetLatestValuesReply) ProtoReflect 

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

func (*BatchGetLatestValuesReply) Reset 

func (x *BatchGetLatestValuesReply) Reset()

func (*BatchGetLatestValuesReply) String 

func (x *BatchGetLatestValuesReply) String() string

type BatchGetLatestValuesRequest 

type BatchGetLatestValuesRequest struct {
	Requests []*ContractBatch `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

BatchGetLatestValuesRequest has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.BatchGetLatestValues.

func (*BatchGetLatestValuesRequest) Descriptor deprecated 

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

Deprecated: Use BatchGetLatestValuesRequest.ProtoReflect.Descriptor instead.

func (*BatchGetLatestValuesRequest) GetRequests 

func (x *BatchGetLatestValuesRequest) GetRequests() []*ContractBatch

func (*BatchGetLatestValuesRequest) ProtoMessage 

func (*BatchGetLatestValuesRequest) ProtoMessage()

func (*BatchGetLatestValuesRequest) ProtoReflect 

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

func (*BatchGetLatestValuesRequest) Reset 

func (x *BatchGetLatestValuesRequest) Reset()

func (*BatchGetLatestValuesRequest) String 

func (x *BatchGetLatestValuesRequest) String() string

type BatchRead 

type BatchRead struct {
	ReadName  string                `protobuf:"bytes,1,opt,name=read_name,json=readName,proto3" json:"read_name,omitempty"`
	Params    *codec.VersionedBytes `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	ReturnVal *codec.VersionedBytes `protobuf:"bytes,3,opt,name=return_val,json=returnVal,proto3" json:"return_val,omitempty"`
	// contains filtered or unexported fields
}

BatchCall is gRPC adapter for the GetLatestValueRequest struct github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.BatchCall.

func (*BatchRead) Descriptor deprecated 

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

Deprecated: Use BatchRead.ProtoReflect.Descriptor instead.

func (*BatchRead) GetParams 

func (x *BatchRead) GetParams() *codec.VersionedBytes

func (*BatchRead) GetReadName 

func (x *BatchRead) GetReadName() string

func (*BatchRead) GetReturnVal 

func (x *BatchRead) GetReturnVal() *codec.VersionedBytes

func (*BatchRead) ProtoMessage 

func (*BatchRead) ProtoMessage()

func (*BatchRead) ProtoReflect 

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

func (*BatchRead) Reset 

func (x *BatchRead) Reset()

func (*BatchRead) String 

func (x *BatchRead) String() string

type BatchReadResult 

type BatchReadResult struct {
	ReadName  string                `protobuf:"bytes,1,opt,name=read_name,json=readName,proto3" json:"read_name,omitempty"`
	ReturnVal *codec.VersionedBytes `protobuf:"bytes,2,opt,name=return_val,json=returnVal,proto3" json:"return_val,omitempty"`
	Error     string                `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

BatchCallResult is part of return arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.BatchGetLatestValues.

func (*BatchReadResult) Descriptor deprecated 

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

Deprecated: Use BatchReadResult.ProtoReflect.Descriptor instead.

func (*BatchReadResult) GetError 

func (x *BatchReadResult) GetError() string

func (*BatchReadResult) GetReadName 

func (x *BatchReadResult) GetReadName() string

func (*BatchReadResult) GetReturnVal 

func (x *BatchReadResult) GetReturnVal() *codec.VersionedBytes

func (*BatchReadResult) ProtoMessage 

func (*BatchReadResult) ProtoMessage()

func (*BatchReadResult) ProtoReflect 

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

func (*BatchReadResult) Reset 

func (x *BatchReadResult) Reset()

func (*BatchReadResult) String 

func (x *BatchReadResult) 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
}

BindRequest has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.Bind.

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"`
	// contains filtered or unexported fields
}

BoundContract represents a github.com/smartcontractkit/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) 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 CapabilitiesRegistryClient 

type CapabilitiesRegistryClient interface {
	LocalNode(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NodeReply, error)
	NodeByPeerID(ctx context.Context, in *NodeRequest, opts ...grpc.CallOption) (*NodeReply, error)
	ConfigForCapability(ctx context.Context, in *ConfigForCapabilityRequest, opts ...grpc.CallOption) (*ConfigForCapabilityReply, error)
	DONsForCapability(ctx context.Context, in *DONForCapabilityRequest, opts ...grpc.CallOption) (*DONForCapabilityReply, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
	GetTrigger(ctx context.Context, in *GetTriggerRequest, opts ...grpc.CallOption) (*GetTriggerReply, error)
	GetExecutable(ctx context.Context, in *GetExecutableRequest, opts ...grpc.CallOption) (*GetExecutableReply, error)
	List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListReply, error)
	Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

CapabilitiesRegistryClient is the client API for CapabilitiesRegistry 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 NewCapabilitiesRegistryClient 

func NewCapabilitiesRegistryClient(cc grpc.ClientConnInterface) CapabilitiesRegistryClient

type CapabilitiesRegistryServer 

type CapabilitiesRegistryServer interface {
	LocalNode(context.Context, *emptypb.Empty) (*NodeReply, error)
	NodeByPeerID(context.Context, *NodeRequest) (*NodeReply, error)
	ConfigForCapability(context.Context, *ConfigForCapabilityRequest) (*ConfigForCapabilityReply, error)
	DONsForCapability(context.Context, *DONForCapabilityRequest) (*DONForCapabilityReply, error)
	Get(context.Context, *GetRequest) (*GetReply, error)
	GetTrigger(context.Context, *GetTriggerRequest) (*GetTriggerReply, error)
	GetExecutable(context.Context, *GetExecutableRequest) (*GetExecutableReply, error)
	List(context.Context, *emptypb.Empty) (*ListReply, error)
	Add(context.Context, *AddRequest) (*emptypb.Empty, error)
	Remove(context.Context, *RemoveRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

CapabilitiesRegistryServer is the server API for CapabilitiesRegistry service. All implementations must embed UnimplementedCapabilitiesRegistryServer for forward compatibility.

type ChainInfo added in v0.7.1 

type ChainInfo struct {
	FamilyName      string `protobuf:"bytes,1,opt,name=family_name,json=familyName,proto3" json:"family_name,omitempty"`
	ChainId         string `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	NetworkName     string `protobuf:"bytes,3,opt,name=network_name,json=networkName,proto3" json:"network_name,omitempty"`
	NetworkNameFull string `protobuf:"bytes,4,opt,name=network_name_full,json=networkNameFull,proto3" json:"network_name_full,omitempty"`
	// contains filtered or unexported fields
}

ChainInfo represents github.com/smartcontractkit/chainlink-common/pkg/types.ChainInfo.

func (*ChainInfo) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use ChainInfo.ProtoReflect.Descriptor instead.

func (*ChainInfo) GetChainId added in v0.7.1 

func (x *ChainInfo) GetChainId() string

func (*ChainInfo) GetFamilyName added in v0.7.1 

func (x *ChainInfo) GetFamilyName() string

func (*ChainInfo) GetNetworkName added in v0.7.1 

func (x *ChainInfo) GetNetworkName() string

func (*ChainInfo) GetNetworkNameFull added in v0.7.1 

func (x *ChainInfo) GetNetworkNameFull() string

func (*ChainInfo) ProtoMessage added in v0.7.1 

func (*ChainInfo) ProtoMessage()

func (*ChainInfo) ProtoReflect added in v0.7.1 

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

func (*ChainInfo) Reset added in v0.7.1 

func (x *ChainInfo) Reset()

func (*ChainInfo) String added in v0.7.1 

func (x *ChainInfo) String() string

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/smartcontractkit/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 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 ConfigForCapabilityReply added in v0.2.2 

type ConfigForCapabilityReply struct {
	CapabilityConfig *pb.CapabilityConfig `protobuf:"bytes,1,opt,name=capability_config,json=capabilityConfig,proto3" json:"capability_config,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigForCapabilityReply) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use ConfigForCapabilityReply.ProtoReflect.Descriptor instead.

func (*ConfigForCapabilityReply) GetCapabilityConfig added in v0.2.2 

func (x *ConfigForCapabilityReply) GetCapabilityConfig() *pb.CapabilityConfig

func (*ConfigForCapabilityReply) ProtoMessage added in v0.2.2 

func (*ConfigForCapabilityReply) ProtoMessage()

func (*ConfigForCapabilityReply) ProtoReflect added in v0.2.2 

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

func (*ConfigForCapabilityReply) Reset added in v0.2.2 

func (x *ConfigForCapabilityReply) Reset()

func (*ConfigForCapabilityReply) String added in v0.2.2 

func (x *ConfigForCapabilityReply) String() string

type ConfigForCapabilityRequest added in v0.2.2 

type ConfigForCapabilityRequest struct {
	CapabilityID string `protobuf:"bytes,1,opt,name=capabilityID,proto3" json:"capabilityID,omitempty"`
	DonID        uint32 `protobuf:"varint,2,opt,name=donID,proto3" json:"donID,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigForCapabilityRequest) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use ConfigForCapabilityRequest.ProtoReflect.Descriptor instead.

func (*ConfigForCapabilityRequest) GetCapabilityID added in v0.2.2 

func (x *ConfigForCapabilityRequest) GetCapabilityID() string

func (*ConfigForCapabilityRequest) GetDonID added in v0.2.2 

func (x *ConfigForCapabilityRequest) GetDonID() uint32

func (*ConfigForCapabilityRequest) ProtoMessage added in v0.2.2 

func (*ConfigForCapabilityRequest) ProtoMessage()

func (*ConfigForCapabilityRequest) ProtoReflect added in v0.2.2 

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

func (*ConfigForCapabilityRequest) Reset added in v0.2.2 

func (x *ConfigForCapabilityRequest) Reset()

func (*ConfigForCapabilityRequest) String added in v0.2.2 

func (x *ConfigForCapabilityRequest) String() string

type ContractBatch 

type ContractBatch struct {
	Contract *BoundContract `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty"`
	Reads    []*BatchRead   `protobuf:"bytes,2,rep,name=reads,proto3" json:"reads,omitempty"`
	// contains filtered or unexported fields
}

ContractBatch is gRPC adapter for the BatchGetLatestValuesRequest struct map value github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.BatchGetLatestValuesRequest.

func (*ContractBatch) Descriptor deprecated 

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

Deprecated: Use ContractBatch.ProtoReflect.Descriptor instead.

func (*ContractBatch) GetContract added in v0.2.2 

func (x *ContractBatch) GetContract() *BoundContract

func (*ContractBatch) GetReads 

func (x *ContractBatch) GetReads() []*BatchRead

func (*ContractBatch) ProtoMessage 

func (*ContractBatch) ProtoMessage()

func (*ContractBatch) ProtoReflect 

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

func (*ContractBatch) Reset 

func (x *ContractBatch) Reset()

func (*ContractBatch) String 

func (x *ContractBatch) String() string

type ContractBatchResult 

type ContractBatchResult struct {
	Contract *BoundContract     `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty"`
	Results  []*BatchReadResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

ContractBatchResult is part of return arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.BatchGetLatestValues.

func (*ContractBatchResult) Descriptor deprecated 

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

Deprecated: Use ContractBatchResult.ProtoReflect.Descriptor instead.

func (*ContractBatchResult) GetContract added in v0.2.2 

func (x *ContractBatchResult) GetContract() *BoundContract

func (*ContractBatchResult) GetResults 

func (x *ContractBatchResult) GetResults() []*BatchReadResult

func (*ContractBatchResult) ProtoMessage 

func (*ContractBatchResult) ProtoMessage()

func (*ContractBatchResult) ProtoReflect 

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

func (*ContractBatchResult) Reset 

func (x *ContractBatchResult) Reset()

func (*ContractBatchResult) String 

func (x *ContractBatchResult) 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 ContractKeyFilter added in v0.4.0 

type ContractKeyFilter struct {
	Contract    *BoundContract  `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty"`
	Filter      *QueryKeyFilter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	AsValueType bool            `protobuf:"varint,4,opt,name=as_value_type,json=asValueType,proto3" json:"as_value_type,omitempty"`
	// contains filtered or unexported fields
}

func (*ContractKeyFilter) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use ContractKeyFilter.ProtoReflect.Descriptor instead.

func (*ContractKeyFilter) GetAsValueType added in v0.4.0 

func (x *ContractKeyFilter) GetAsValueType() bool

func (*ContractKeyFilter) GetContract added in v0.4.0 

func (x *ContractKeyFilter) GetContract() *BoundContract

func (*ContractKeyFilter) GetFilter added in v0.4.0 

func (x *ContractKeyFilter) GetFilter() *QueryKeyFilter

func (*ContractKeyFilter) ProtoMessage added in v0.4.0 

func (*ContractKeyFilter) ProtoMessage()

func (*ContractKeyFilter) ProtoReflect added in v0.4.0 

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

func (*ContractKeyFilter) Reset added in v0.4.0 

func (x *ContractKeyFilter) Reset()

func (*ContractKeyFilter) String added in v0.4.0 

func (x *ContractKeyFilter) String() string

type ContractReaderClient added in v0.2.2 

type ContractReaderClient interface {
	GetLatestValue(ctx context.Context, in *GetLatestValueRequest, opts ...grpc.CallOption) (*GetLatestValueReply, error)
	GetLatestValueWithHeadData(ctx context.Context, in *GetLatestValueRequest, opts ...grpc.CallOption) (*GetLatestValueWithHeadDataReply, error)
	BatchGetLatestValues(ctx context.Context, in *BatchGetLatestValuesRequest, opts ...grpc.CallOption) (*BatchGetLatestValuesReply, error)
	QueryKey(ctx context.Context, in *QueryKeyRequest, opts ...grpc.CallOption) (*QueryKeyReply, error)
	QueryKeys(ctx context.Context, in *QueryKeysRequest, opts ...grpc.CallOption) (*QueryKeysReply, error)
	Bind(ctx context.Context, in *BindRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Unbind(ctx context.Context, in *UnbindRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ContractReaderClient is the client API for ContractReader 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 NewContractReaderClient added in v0.2.2 

func NewContractReaderClient(cc grpc.ClientConnInterface) ContractReaderClient

type ContractReaderServer added in v0.2.2 

type ContractReaderServer interface {
	GetLatestValue(context.Context, *GetLatestValueRequest) (*GetLatestValueReply, error)
	GetLatestValueWithHeadData(context.Context, *GetLatestValueRequest) (*GetLatestValueWithHeadDataReply, error)
	BatchGetLatestValues(context.Context, *BatchGetLatestValuesRequest) (*BatchGetLatestValuesReply, error)
	QueryKey(context.Context, *QueryKeyRequest) (*QueryKeyReply, error)
	QueryKeys(context.Context, *QueryKeysRequest) (*QueryKeysReply, error)
	Bind(context.Context, *BindRequest) (*emptypb.Empty, error)
	Unbind(context.Context, *UnbindRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ContractReaderServer is the server API for ContractReader service. All implementations must embed UnimplementedContractReaderServer 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 ContractWriterClient added in v0.4.0 

type ContractWriterClient interface {
	SubmitTransaction(ctx context.Context, in *SubmitTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetTransactionStatus(ctx context.Context, in *evm.GetTransactionStatusRequest, opts ...grpc.CallOption) (*evm.GetTransactionStatusReply, error)
	GetFeeComponents(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetFeeComponentsReply, error)
	GetEstimateFee(ctx context.Context, in *GetEstimateFeeRequest, opts ...grpc.CallOption) (*GetEstimateFeeReply, error)
}

ContractWriterClient is the client API for ContractWriter 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 NewContractWriterClient added in v0.4.0 

func NewContractWriterClient(cc grpc.ClientConnInterface) ContractWriterClient

type ContractWriterServer added in v0.4.0 

type ContractWriterServer interface {
	SubmitTransaction(context.Context, *SubmitTransactionRequest) (*emptypb.Empty, error)
	GetTransactionStatus(context.Context, *evm.GetTransactionStatusRequest) (*evm.GetTransactionStatusReply, error)
	GetFeeComponents(context.Context, *emptypb.Empty) (*GetFeeComponentsReply, error)
	GetEstimateFee(context.Context, *GetEstimateFeeRequest) (*GetEstimateFeeReply, error)
	// contains filtered or unexported methods
}

ContractWriterServer is the server API for ContractWriter service. All implementations must embed UnimplementedContractWriterServer for forward compatibility.

type DON 

type DON struct {
	Id            uint32   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Members       [][]byte `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"` // [n][32]byte where n is the number of members
	F             uint32   `protobuf:"varint,3,opt,name=f,proto3" json:"f,omitempty"`            // uint8
	ConfigVersion uint32   `protobuf:"varint,4,opt,name=configVersion,proto3" json:"configVersion,omitempty"`
	Name          string   `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	Families      []string `protobuf:"bytes,6,rep,name=families,proto3" json:"families,omitempty"` // [n]string where n is the number of DON families
	Config        []byte   `protobuf:"bytes,7,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

DON has arguments for github.com/smartcontractkit/chainlink-common/pkg/capabilities.DON.

func (*DON) Descriptor deprecated 

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

Deprecated: Use DON.ProtoReflect.Descriptor instead.

func (*DON) GetConfig added in v0.9.0 

func (x *DON) GetConfig() []byte

func (*DON) GetConfigVersion 

func (x *DON) GetConfigVersion() uint32

func (*DON) GetF 

func (x *DON) GetF() uint32

func (*DON) GetFamilies added in v0.9.0 

func (x *DON) GetFamilies() []string

func (*DON) GetId 

func (x *DON) GetId() uint32

func (*DON) GetMembers 

func (x *DON) GetMembers() [][]byte

func (*DON) GetName added in v0.9.0 

func (x *DON) GetName() string

func (*DON) ProtoMessage 

func (*DON) ProtoMessage()

func (*DON) ProtoReflect 

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

func (*DON) Reset 

func (x *DON) Reset()

func (*DON) String 

func (x *DON) String() string

type DONForCapabilityReply added in v0.9.4 

type DONForCapabilityReply struct {
	Dons []*DONWithNodes `protobuf:"bytes,1,rep,name=dons,proto3" json:"dons,omitempty"`
	// contains filtered or unexported fields
}

func (*DONForCapabilityReply) Descriptor deprecated added in v0.9.4 

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

Deprecated: Use DONForCapabilityReply.ProtoReflect.Descriptor instead.

func (*DONForCapabilityReply) GetDons added in v0.9.4 

func (x *DONForCapabilityReply) GetDons() []*DONWithNodes

func (*DONForCapabilityReply) ProtoMessage added in v0.9.4 

func (*DONForCapabilityReply) ProtoMessage()

func (*DONForCapabilityReply) ProtoReflect added in v0.9.4 

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

func (*DONForCapabilityReply) Reset added in v0.9.4 

func (x *DONForCapabilityReply) Reset()

func (*DONForCapabilityReply) String added in v0.9.4 

func (x *DONForCapabilityReply) String() string

type DONForCapabilityRequest added in v0.9.4 

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

func (*DONForCapabilityRequest) Descriptor deprecated added in v0.9.4 

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

Deprecated: Use DONForCapabilityRequest.ProtoReflect.Descriptor instead.

func (*DONForCapabilityRequest) GetCapabilityID added in v0.9.4 

func (x *DONForCapabilityRequest) GetCapabilityID() string

func (*DONForCapabilityRequest) ProtoMessage added in v0.9.4 

func (*DONForCapabilityRequest) ProtoMessage()

func (*DONForCapabilityRequest) ProtoReflect added in v0.9.4 

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

func (*DONForCapabilityRequest) Reset added in v0.9.4 

func (x *DONForCapabilityRequest) Reset()

func (*DONForCapabilityRequest) String added in v0.9.4 

func (x *DONForCapabilityRequest) String() string

type DONWithNodes added in v0.9.4 

type DONWithNodes struct {
	Don   *DON         `protobuf:"bytes,1,opt,name=don,proto3" json:"don,omitempty"`
	Nodes []*NodeReply `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*DONWithNodes) Descriptor deprecated added in v0.9.4 

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

Deprecated: Use DONWithNodes.ProtoReflect.Descriptor instead.

func (*DONWithNodes) GetDon added in v0.9.4 

func (x *DONWithNodes) GetDon() *DON

func (*DONWithNodes) GetNodes added in v0.9.4 

func (x *DONWithNodes) GetNodes() []*NodeReply

func (*DONWithNodes) ProtoMessage added in v0.9.4 

func (*DONWithNodes) ProtoMessage()

func (*DONWithNodes) ProtoReflect added in v0.9.4 

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

func (*DONWithNodes) Reset added in v0.9.4 

func (x *DONWithNodes) Reset()

func (*DONWithNodes) String added in v0.9.4 

func (x *DONWithNodes) String() string

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 DecryptReply added in v0.9.3 

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

func (*DecryptReply) Descriptor deprecated added in v0.9.3 

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

Deprecated: Use DecryptReply.ProtoReflect.Descriptor instead.

func (*DecryptReply) GetDecryptedData added in v0.9.3 

func (x *DecryptReply) GetDecryptedData() []byte

func (*DecryptReply) ProtoMessage added in v0.9.3 

func (*DecryptReply) ProtoMessage()

func (*DecryptReply) ProtoReflect added in v0.9.3 

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

func (*DecryptReply) Reset added in v0.9.3 

func (x *DecryptReply) Reset()

func (*DecryptReply) String added in v0.9.3 

func (x *DecryptReply) String() string

type DecryptRequest added in v0.9.3 

type DecryptRequest 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 (*DecryptRequest) Descriptor deprecated added in v0.9.3 

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

Deprecated: Use DecryptRequest.ProtoReflect.Descriptor instead.

func (*DecryptRequest) GetAccount added in v0.9.3 

func (x *DecryptRequest) GetAccount() string

func (*DecryptRequest) GetData added in v0.9.3 

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

func (*DecryptRequest) ProtoMessage added in v0.9.3 

func (*DecryptRequest) ProtoMessage()

func (*DecryptRequest) ProtoReflect added in v0.9.3 

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

func (*DecryptRequest) Reset added in v0.9.3 

func (x *DecryptRequest) Reset()

func (*DecryptRequest) String added in v0.9.3 

func (x *DecryptRequest) 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 ErrConfigDigestLen 

type ErrConfigDigestLen int

func (ErrConfigDigestLen) Error 

func (e ErrConfigDigestLen) Error() string

type ErrUint8Bounds 

type ErrUint8Bounds struct {
	U    uint32
	Name string
}

func (ErrUint8Bounds) Error 

func (e ErrUint8Bounds) Error() 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 ExecuteAPIType 

type ExecuteAPIType int32
const (
	ExecuteAPIType_EXECUTE_API_TYPE_UNKNOWN  ExecuteAPIType = 0
	ExecuteAPIType_EXECUTE_API_TYPE_TRIGGER  ExecuteAPIType = 1
	ExecuteAPIType_EXECUTE_API_TYPE_EXECUTE  ExecuteAPIType = 2
	ExecuteAPIType_EXECUTE_API_TYPE_COMBINED ExecuteAPIType = 3
)

func (ExecuteAPIType) Descriptor 

func (ExecuteAPIType) Descriptor() protoreflect.EnumDescriptor

func (ExecuteAPIType) Enum 

func (x ExecuteAPIType) Enum() *ExecuteAPIType

func (ExecuteAPIType) EnumDescriptor deprecated 

func (ExecuteAPIType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecuteAPIType.Descriptor instead.

func (ExecuteAPIType) Number 

func (x ExecuteAPIType) Number() protoreflect.EnumNumber

func (ExecuteAPIType) String 

func (x ExecuteAPIType) String() string

func (ExecuteAPIType) Type 

func (ExecuteAPIType) Type() protoreflect.EnumType

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/smartcontractkit/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 GetChainInfoReply added in v0.7.1 

type GetChainInfoReply struct {
	ChainInfo *ChainInfo `protobuf:"bytes,1,opt,name=chain_info,json=chainInfo,proto3" json:"chain_info,omitempty"`
	// contains filtered or unexported fields
}

GetChainInfoReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/loop.Relayer.GetChainInfo.

func (*GetChainInfoReply) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use GetChainInfoReply.ProtoReflect.Descriptor instead.

func (*GetChainInfoReply) GetChainInfo added in v0.7.1 

func (x *GetChainInfoReply) GetChainInfo() *ChainInfo

func (*GetChainInfoReply) ProtoMessage added in v0.7.1 

func (*GetChainInfoReply) ProtoMessage()

func (*GetChainInfoReply) ProtoReflect added in v0.7.1 

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

func (*GetChainInfoReply) Reset added in v0.7.1 

func (x *GetChainInfoReply) Reset()

func (*GetChainInfoReply) String added in v0.7.1 

func (x *GetChainInfoReply) String() string

type GetChainInfoRequest added in v0.7.1 

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

func (*GetChainInfoRequest) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use GetChainInfoRequest.ProtoReflect.Descriptor instead.

func (*GetChainInfoRequest) ProtoMessage added in v0.7.1 

func (*GetChainInfoRequest) ProtoMessage()

func (*GetChainInfoRequest) ProtoReflect added in v0.7.1 

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

func (*GetChainInfoRequest) Reset added in v0.7.1 

func (x *GetChainInfoRequest) Reset()

func (*GetChainInfoRequest) String added in v0.7.1 

func (x *GetChainInfoRequest) 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/smartcontractkit/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 GetEstimateFeeReply added in v0.7.1 

type GetEstimateFeeReply struct {
	Fee      *BigInt `protobuf:"bytes,1,opt,name=fee,proto3" json:"fee,omitempty"`
	Decimals uint32  `protobuf:"varint,2,opt,name=decimals,proto3" json:"decimals,omitempty"`
	// contains filtered or unexported fields
}

GetEstimateFeeReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractWriter.GetEstimateFee.

func (*GetEstimateFeeReply) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use GetEstimateFeeReply.ProtoReflect.Descriptor instead.

func (*GetEstimateFeeReply) GetDecimals added in v0.7.1 

func (x *GetEstimateFeeReply) GetDecimals() uint32

func (*GetEstimateFeeReply) GetFee added in v0.7.1 

func (x *GetEstimateFeeReply) GetFee() *BigInt

func (*GetEstimateFeeReply) ProtoMessage added in v0.7.1 

func (*GetEstimateFeeReply) ProtoMessage()

func (*GetEstimateFeeReply) ProtoReflect added in v0.7.1 

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

func (*GetEstimateFeeReply) Reset added in v0.7.1 

func (x *GetEstimateFeeReply) Reset()

func (*GetEstimateFeeReply) String added in v0.7.1 

func (x *GetEstimateFeeReply) String() string

type GetEstimateFeeRequest added in v0.7.1 

type GetEstimateFeeRequest struct {
	ContractName string                `protobuf:"bytes,1,opt,name=contract_name,json=contractName,proto3" json:"contract_name,omitempty"`
	Method       string                `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Params       *codec.VersionedBytes `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	ToAddress    string                `protobuf:"bytes,4,opt,name=to_address,json=toAddress,proto3" json:"to_address,omitempty"`
	Meta         *TransactionMeta      `protobuf:"bytes,5,opt,name=meta,proto3" json:"meta,omitempty"`
	Value        *BigInt               `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

GetEstimateFeeReply has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractWriter.GetEstimateFee.

func (*GetEstimateFeeRequest) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use GetEstimateFeeRequest.ProtoReflect.Descriptor instead.

func (*GetEstimateFeeRequest) GetContractName added in v0.7.1 

func (x *GetEstimateFeeRequest) GetContractName() string

func (*GetEstimateFeeRequest) GetMeta added in v0.7.1 

func (x *GetEstimateFeeRequest) GetMeta() *TransactionMeta

func (*GetEstimateFeeRequest) GetMethod added in v0.7.1 

func (x *GetEstimateFeeRequest) GetMethod() string

func (*GetEstimateFeeRequest) GetParams added in v0.7.1 

func (x *GetEstimateFeeRequest) GetParams() *codec.VersionedBytes

func (*GetEstimateFeeRequest) GetToAddress added in v0.7.1 

func (x *GetEstimateFeeRequest) GetToAddress() string

func (*GetEstimateFeeRequest) GetValue added in v0.7.1 

func (x *GetEstimateFeeRequest) GetValue() *BigInt

func (*GetEstimateFeeRequest) ProtoMessage added in v0.7.1 

func (*GetEstimateFeeRequest) ProtoMessage()

func (*GetEstimateFeeRequest) ProtoReflect added in v0.7.1 

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

func (*GetEstimateFeeRequest) Reset added in v0.7.1 

func (x *GetEstimateFeeRequest) Reset()

func (*GetEstimateFeeRequest) String added in v0.7.1 

func (x *GetEstimateFeeRequest) String() string

type GetExecutableReply added in v0.7.1 

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

GetExecutableReply has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.GetExecutable, expressed as a capabilityID (this is a GRPC connectionID internal to go-hashicorp-plugin).

func (*GetExecutableReply) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use GetExecutableReply.ProtoReflect.Descriptor instead.

func (*GetExecutableReply) GetCapabilityID added in v0.7.1 

func (x *GetExecutableReply) GetCapabilityID() uint32

func (*GetExecutableReply) ProtoMessage added in v0.7.1 

func (*GetExecutableReply) ProtoMessage()

func (*GetExecutableReply) ProtoReflect added in v0.7.1 

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

func (*GetExecutableReply) Reset added in v0.7.1 

func (x *GetExecutableReply) Reset()

func (*GetExecutableReply) String added in v0.7.1 

func (x *GetExecutableReply) String() string

type GetExecutableRequest added in v0.7.1 

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

GetExecutableRequest has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.GetExecutable.

func (*GetExecutableRequest) Descriptor deprecated added in v0.7.1 

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

Deprecated: Use GetExecutableRequest.ProtoReflect.Descriptor instead.

func (*GetExecutableRequest) GetId added in v0.7.1 

func (x *GetExecutableRequest) GetId() string

func (*GetExecutableRequest) ProtoMessage added in v0.7.1 

func (*GetExecutableRequest) ProtoMessage()

func (*GetExecutableRequest) ProtoReflect added in v0.7.1 

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

func (*GetExecutableRequest) Reset added in v0.7.1 

func (x *GetExecutableRequest) Reset()

func (*GetExecutableRequest) String added in v0.7.1 

func (x *GetExecutableRequest) String() string

type GetFeeComponentsReply 

type GetFeeComponentsReply struct {
	ExecutionFee        *BigInt `protobuf:"bytes,1,opt,name=execution_fee,json=executionFee,proto3" json:"execution_fee,omitempty"`
	DataAvailabilityFee *BigInt `protobuf:"bytes,2,opt,name=data_availability_fee,json=dataAvailabilityFee,proto3" json:"data_availability_fee,omitempty"`
	// contains filtered or unexported fields
}

GetFeeComponentsReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractWriter.GetFeeComponents.

func (*GetFeeComponentsReply) Descriptor deprecated 

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

Deprecated: Use GetFeeComponentsReply.ProtoReflect.Descriptor instead.

func (*GetFeeComponentsReply) GetDataAvailabilityFee 

func (x *GetFeeComponentsReply) GetDataAvailabilityFee() *BigInt

func (*GetFeeComponentsReply) GetExecutionFee 

func (x *GetFeeComponentsReply) GetExecutionFee() *BigInt

func (*GetFeeComponentsReply) ProtoMessage 

func (*GetFeeComponentsReply) ProtoMessage()

func (*GetFeeComponentsReply) ProtoReflect 

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

func (*GetFeeComponentsReply) Reset 

func (x *GetFeeComponentsReply) Reset()

func (*GetFeeComponentsReply) String 

func (x *GetFeeComponentsReply) String() string

type GetLatestValueReply 

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

GetLatestValueReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.GetLatestValue.

func (*GetLatestValueReply) Descriptor deprecated 

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

Deprecated: Use GetLatestValueReply.ProtoReflect.Descriptor instead.

func (*GetLatestValueReply) GetRetVal 

func (x *GetLatestValueReply) GetRetVal() *codec.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 {
	ReadIdentifier string                  `protobuf:"bytes,1,opt,name=read_identifier,json=readIdentifier,proto3" json:"read_identifier,omitempty"`
	Confidence     chain_common.Confidence `protobuf:"varint,2,opt,name=confidence,proto3,enum=loop.chain.common.Confidence" json:"confidence,omitempty"`
	Params         *codec.VersionedBytes   `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	AsValueType    bool                    `protobuf:"varint,4,opt,name=as_value_type,json=asValueType,proto3" json:"as_value_type,omitempty"`
	// contains filtered or unexported fields
}

GetLatestValueRequest has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.GetLatestValue.

func (*GetLatestValueRequest) Descriptor deprecated 

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

Deprecated: Use GetLatestValueRequest.ProtoReflect.Descriptor instead.

func (*GetLatestValueRequest) GetAsValueType added in v0.3.0 

func (x *GetLatestValueRequest) GetAsValueType() bool

func (*GetLatestValueRequest) GetConfidence 

func (x *GetLatestValueRequest) GetConfidence() chain_common.Confidence

func (*GetLatestValueRequest) GetParams 

func (x *GetLatestValueRequest) GetParams() *codec.VersionedBytes

func (*GetLatestValueRequest) GetReadIdentifier added in v0.2.2 

func (x *GetLatestValueRequest) GetReadIdentifier() string

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 GetLatestValueWithHeadDataReply added in v0.4.0 

type GetLatestValueWithHeadDataReply struct {
	RetVal   *codec.VersionedBytes `protobuf:"bytes,1,opt,name=ret_val,json=retVal,proto3" json:"ret_val,omitempty"`
	HeadData *Head                 `protobuf:"bytes,2,opt,name=head_data,json=headData,proto3" json:"head_data,omitempty"`
	// contains filtered or unexported fields
}

GetLatestValueWithHeadDataReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.GetLatestValueWithHeadData.

func (*GetLatestValueWithHeadDataReply) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use GetLatestValueWithHeadDataReply.ProtoReflect.Descriptor instead.

func (*GetLatestValueWithHeadDataReply) GetHeadData added in v0.4.0 

func (x *GetLatestValueWithHeadDataReply) GetHeadData() *Head

func (*GetLatestValueWithHeadDataReply) GetRetVal added in v0.4.0 

func (x *GetLatestValueWithHeadDataReply) GetRetVal() *codec.VersionedBytes

func (*GetLatestValueWithHeadDataReply) ProtoMessage added in v0.4.0 

func (*GetLatestValueWithHeadDataReply) ProtoMessage()

func (*GetLatestValueWithHeadDataReply) ProtoReflect added in v0.4.0 

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

func (*GetLatestValueWithHeadDataReply) Reset added in v0.4.0 

func (x *GetLatestValueWithHeadDataReply) Reset()

func (*GetLatestValueWithHeadDataReply) String added in v0.4.0 

func (x *GetLatestValueWithHeadDataReply) String() string

type GetReply 

type GetReply struct {
	CapabilityID uint32         `protobuf:"varint,1,opt,name=capabilityID,proto3" json:"capabilityID,omitempty"`
	Type         ExecuteAPIType `protobuf:"varint,2,opt,name=type,proto3,enum=loop.ExecuteAPIType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

GetReply has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.Get, expressed as a capabilityID (this is a GRPC connectionID internal to go-hashicorp-plugin) and type indicating client wrapper that we need to use on the client side.

func (*GetReply) Descriptor deprecated 

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

Deprecated: Use GetReply.ProtoReflect.Descriptor instead.

func (*GetReply) GetCapabilityID 

func (x *GetReply) GetCapabilityID() uint32

func (*GetReply) GetType 

func (x *GetReply) GetType() ExecuteAPIType

func (*GetReply) ProtoMessage 

func (*GetReply) ProtoMessage()

func (*GetReply) ProtoReflect 

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

func (*GetReply) Reset 

func (x *GetReply) Reset()

func (*GetReply) String 

func (x *GetReply) String() string

type GetRequest 

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

Get has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.Get.

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetId 

func (x *GetRequest) GetId() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetTargetReply 

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

GetTargetReply has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.GetTrigger, expressed as a capabilityID (this is a GRPC connectionID internal to go-hashicorp-plugin).

func (*GetTargetReply) Descriptor deprecated 

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

Deprecated: Use GetTargetReply.ProtoReflect.Descriptor instead.

func (*GetTargetReply) GetCapabilityID 

func (x *GetTargetReply) GetCapabilityID() uint32

func (*GetTargetReply) ProtoMessage 

func (*GetTargetReply) ProtoMessage()

func (*GetTargetReply) ProtoReflect 

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

func (*GetTargetReply) Reset 

func (x *GetTargetReply) Reset()

func (*GetTargetReply) String 

func (x *GetTargetReply) String() string

type GetTriggerReply 

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

GetTriggerReply has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.GetTrigger, expressed as a capabilityID (this is a GRPC connectionID internal to go-hashicorp-plugin).

func (*GetTriggerReply) Descriptor deprecated 

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

Deprecated: Use GetTriggerReply.ProtoReflect.Descriptor instead.

func (*GetTriggerReply) GetCapabilityID 

func (x *GetTriggerReply) GetCapabilityID() uint32

func (*GetTriggerReply) ProtoMessage 

func (*GetTriggerReply) ProtoMessage()

func (*GetTriggerReply) ProtoReflect 

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

func (*GetTriggerReply) Reset 

func (x *GetTriggerReply) Reset()

func (*GetTriggerReply) String 

func (x *GetTriggerReply) String() string

type GetTriggerRequest 

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

GetTrigger has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.GetTrigger.

func (*GetTriggerRequest) Descriptor deprecated 

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

Deprecated: Use GetTriggerRequest.ProtoReflect.Descriptor instead.

func (*GetTriggerRequest) GetId 

func (x *GetTriggerRequest) GetId() string

func (*GetTriggerRequest) ProtoMessage 

func (*GetTriggerRequest) ProtoMessage()

func (*GetTriggerRequest) ProtoReflect 

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

func (*GetTriggerRequest) Reset 

func (x *GetTriggerRequest) Reset()

func (*GetTriggerRequest) String 

func (x *GetTriggerRequest) String() string

type GetValueForKeyRequest 

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

func (*GetValueForKeyRequest) Descriptor deprecated 

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

Deprecated: Use GetValueForKeyRequest.ProtoReflect.Descriptor instead.

func (*GetValueForKeyRequest) GetKey 

func (x *GetValueForKeyRequest) GetKey() string

func (*GetValueForKeyRequest) ProtoMessage 

func (*GetValueForKeyRequest) ProtoMessage()

func (*GetValueForKeyRequest) ProtoReflect 

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

func (*GetValueForKeyRequest) Reset 

func (x *GetValueForKeyRequest) Reset()

func (*GetValueForKeyRequest) String 

func (x *GetValueForKeyRequest) String() string

type GetValueForKeyResponse 

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

func (*GetValueForKeyResponse) Descriptor deprecated 

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

Deprecated: Use GetValueForKeyResponse.ProtoReflect.Descriptor instead.

func (*GetValueForKeyResponse) GetValue 

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

func (*GetValueForKeyResponse) ProtoMessage 

func (*GetValueForKeyResponse) ProtoMessage()

func (*GetValueForKeyResponse) ProtoReflect 

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

func (*GetValueForKeyResponse) Reset 

func (x *GetValueForKeyResponse) Reset()

func (*GetValueForKeyResponse) String 

func (x *GetValueForKeyResponse) String() string
type Head struct {
	Height    string `protobuf:"bytes,1,opt,name=height,proto3" json:"height,omitempty"`
	Hash      []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Head is gRPC adapter for the Head struct github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.Head.

func (*Head) Descriptor deprecated 

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

Deprecated: Use Head.ProtoReflect.Descriptor instead.

func (*Head) GetHash 

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

func (*Head) GetHeight added in v0.2.2 

func (x *Head) GetHeight() string

func (*Head) GetTimestamp 

func (x *Head) GetTimestamp() uint64

func (*Head) ProtoMessage 

func (*Head) ProtoMessage()

func (*Head) ProtoReflect 

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

func (*Head) Reset 

func (x *Head) Reset()

func (*Head) String 

func (x *Head) String() string

type HealthReportReply 

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

HealthReportReply has return arguments for github.com/smartcontractkit/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 KeyValueStoreClient 

type KeyValueStoreClient interface {
	StoreKeyValue(ctx context.Context, in *StoreKeyValueRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetValueForKey(ctx context.Context, in *GetValueForKeyRequest, opts ...grpc.CallOption) (*GetValueForKeyResponse, error)
	PruneExpiredEntries(ctx context.Context, in *PruneExpiredEntriesRequest, opts ...grpc.CallOption) (*PruneExpiredEntriesResponse, error)
}

KeyValueStoreClient is the client API for KeyValueStore 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 NewKeyValueStoreClient 

func NewKeyValueStoreClient(cc grpc.ClientConnInterface) KeyValueStoreClient

type KeyValueStoreServer 

type KeyValueStoreServer interface {
	StoreKeyValue(context.Context, *StoreKeyValueRequest) (*emptypb.Empty, error)
	GetValueForKey(context.Context, *GetValueForKeyRequest) (*GetValueForKeyResponse, error)
	PruneExpiredEntries(context.Context, *PruneExpiredEntriesRequest) (*PruneExpiredEntriesResponse, error)
	// contains filtered or unexported methods
}

KeyValueStoreServer is the server API for KeyValueStore service. All implementations must embed UnimplementedKeyValueStoreServer for forward compatibility.

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)
	Decrypt(ctx context.Context, in *DecryptRequest, opts ...grpc.CallOption) (*DecryptReply, 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)
	Decrypt(context.Context, *DecryptRequest) (*DecryptReply, 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 LatestHeadReply added in v0.2.2 

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

LatestHeadReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/loop.Relayer.LatestHeadReply.

func (*LatestHeadReply) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use LatestHeadReply.ProtoReflect.Descriptor instead.

func (*LatestHeadReply) GetHead added in v0.2.2 

func (x *LatestHeadReply) GetHead() *Head

func (*LatestHeadReply) ProtoMessage added in v0.2.2 

func (*LatestHeadReply) ProtoMessage()

func (*LatestHeadReply) ProtoReflect added in v0.2.2 

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

func (*LatestHeadReply) Reset added in v0.2.2 

func (x *LatestHeadReply) Reset()

func (*LatestHeadReply) String added in v0.2.2 

func (x *LatestHeadReply) String() string

type LatestHeadRequest added in v0.2.2 

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

func (*LatestHeadRequest) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use LatestHeadRequest.ProtoReflect.Descriptor instead.

func (*LatestHeadRequest) ProtoMessage added in v0.2.2 

func (*LatestHeadRequest) ProtoMessage()

func (*LatestHeadRequest) ProtoReflect added in v0.2.2 

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

func (*LatestHeadRequest) Reset added in v0.2.2 

func (x *LatestHeadRequest) Reset()

func (*LatestHeadRequest) String added in v0.2.2 

func (x *LatestHeadRequest) 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/smartcontractkit/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/smartcontractkit/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 ListReply 

type ListReply struct {
	CapabilityID []uint32 `protobuf:"varint,1,rep,packed,name=capabilityID,proto3" json:"capabilityID,omitempty"`
	// contains filtered or unexported fields
}

ListReply has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.List, expressed as a capabilityID (this is a GRPC connectionID internal to go-hashicorp-plugin).

func (*ListReply) Descriptor deprecated 

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

Deprecated: Use ListReply.ProtoReflect.Descriptor instead.

func (*ListReply) GetCapabilityID 

func (x *ListReply) GetCapabilityID() []uint32

func (*ListReply) ProtoMessage 

func (*ListReply) ProtoMessage()

func (*ListReply) ProtoReflect 

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

func (*ListReply) Reset 

func (x *ListReply) Reset()

func (*ListReply) String 

func (x *ListReply) 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/smartcontractkit/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 NewCCIPProviderReply added in v0.9.0 

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

NewCCIPProviderReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/loop.Relayer.NewCCIPProvider.

func (*NewCCIPProviderReply) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use NewCCIPProviderReply.ProtoReflect.Descriptor instead.

func (*NewCCIPProviderReply) GetCcipProviderID added in v0.9.0 

func (x *NewCCIPProviderReply) GetCcipProviderID() uint32

func (*NewCCIPProviderReply) ProtoMessage added in v0.9.0 

func (*NewCCIPProviderReply) ProtoMessage()

func (*NewCCIPProviderReply) ProtoReflect added in v0.9.0 

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

func (*NewCCIPProviderReply) Reset added in v0.9.0 

func (x *NewCCIPProviderReply) Reset()

func (*NewCCIPProviderReply) String added in v0.9.0 

func (x *NewCCIPProviderReply) String() string

type NewCCIPProviderRequest added in v0.9.0 

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

NewCCIPProviderRequest has arguments for github.com/smartcontractkit/chainlink-common/pkg/loop.Relayer.NewCCIPProvider.

func (*NewCCIPProviderRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use NewCCIPProviderRequest.ProtoReflect.Descriptor instead.

func (*NewCCIPProviderRequest) GetRelayArgs added in v0.9.0 

func (x *NewCCIPProviderRequest) GetRelayArgs() *RelayArgs

func (*NewCCIPProviderRequest) ProtoMessage added in v0.9.0 

func (*NewCCIPProviderRequest) ProtoMessage()

func (*NewCCIPProviderRequest) ProtoReflect added in v0.9.0 

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

func (*NewCCIPProviderRequest) Reset added in v0.9.0 

func (x *NewCCIPProviderRequest) Reset()

func (*NewCCIPProviderRequest) String added in v0.9.0 

func (x *NewCCIPProviderRequest) 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/smartcontractkit/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/smartcontractkit/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 NewContractReaderReply 

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

NewContractReaderReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/loop.Relayer.NewContractReader.

func (*NewContractReaderReply) Descriptor deprecated 

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

Deprecated: Use NewContractReaderReply.ProtoReflect.Descriptor instead.

func (*NewContractReaderReply) GetContractReaderID 

func (x *NewContractReaderReply) GetContractReaderID() uint32

func (*NewContractReaderReply) ProtoMessage 

func (*NewContractReaderReply) ProtoMessage()

func (*NewContractReaderReply) ProtoReflect 

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

func (*NewContractReaderReply) Reset 

func (x *NewContractReaderReply) Reset()

func (*NewContractReaderReply) String 

func (x *NewContractReaderReply) String() string

type NewContractReaderRequest 

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

NewContractReaderRequest has arguments for github.com/smartcontractkit/chainlink-common/pkg/loop.Relayer.NewContractReader.

func (*NewContractReaderRequest) Descriptor deprecated 

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

Deprecated: Use NewContractReaderRequest.ProtoReflect.Descriptor instead.

func (*NewContractReaderRequest) GetContractReaderConfig 

func (x *NewContractReaderRequest) GetContractReaderConfig() []byte

func (*NewContractReaderRequest) ProtoMessage 

func (*NewContractReaderRequest) ProtoMessage()

func (*NewContractReaderRequest) ProtoReflect 

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

func (*NewContractReaderRequest) Reset 

func (x *NewContractReaderRequest) Reset()

func (*NewContractReaderRequest) String 

func (x *NewContractReaderRequest) String() string

type NewContractWriterReply added in v0.4.0 

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

NewContractWriterReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/loop.Relayer.NewContractWriter.

func (*NewContractWriterReply) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use NewContractWriterReply.ProtoReflect.Descriptor instead.

func (*NewContractWriterReply) GetContractWriterID added in v0.4.0 

func (x *NewContractWriterReply) GetContractWriterID() uint32

func (*NewContractWriterReply) ProtoMessage added in v0.4.0 

func (*NewContractWriterReply) ProtoMessage()

func (*NewContractWriterReply) ProtoReflect added in v0.4.0 

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

func (*NewContractWriterReply) Reset added in v0.4.0 

func (x *NewContractWriterReply) Reset()

func (*NewContractWriterReply) String added in v0.4.0 

func (x *NewContractWriterReply) String() string

type NewContractWriterRequest added in v0.4.0 

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

NewContractWriterRequest has request parameters for github.com/smartcontractkit/chainlink-common/pkg/loop.Relayer.NewContractWriter.

func (*NewContractWriterRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use NewContractWriterRequest.ProtoReflect.Descriptor instead.

func (*NewContractWriterRequest) GetContractWriterConfig added in v0.4.0 

func (x *NewContractWriterRequest) GetContractWriterConfig() []byte

func (*NewContractWriterRequest) ProtoMessage added in v0.4.0 

func (*NewContractWriterRequest) ProtoMessage()

func (*NewContractWriterRequest) ProtoReflect added in v0.4.0 

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

func (*NewContractWriterRequest) Reset added in v0.4.0 

func (x *NewContractWriterRequest) Reset()

func (*NewContractWriterRequest) String added in v0.4.0 

func (x *NewContractWriterRequest) 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/smartcontractkit/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"`
	ContractID                   string `protobuf:"bytes,2,opt,name=contractID,proto3" json:"contractID,omitempty"`
	DataSourceID                 uint32 `protobuf:"varint,3,opt,name=dataSourceID,proto3" json:"dataSourceID,omitempty"`
	JuelsPerFeeCoinDataSourceID  uint32 `protobuf:"varint,4,opt,name=juelsPerFeeCoinDataSourceID,proto3" json:"juelsPerFeeCoinDataSourceID,omitempty"`
	ErrorLogID                   uint32 `protobuf:"varint,5,opt,name=errorLogID,proto3" json:"errorLogID,omitempty"`
	GasPriceSubunitsDataSourceID uint32 `protobuf:"varint,6,opt,name=gasPriceSubunitsDataSourceID,proto3" json:"gasPriceSubunitsDataSourceID,omitempty"`
	DeviationFuncDefinition      []byte `protobuf:"bytes,7,opt,name=deviationFuncDefinition,proto3,oneof" json:"deviationFuncDefinition,omitempty"` // serialized JSON, may be nil
	// contains filtered or unexported fields
}

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

func (*NewMedianFactoryRequest) Descriptor deprecated 

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

Deprecated: Use NewMedianFactoryRequest.ProtoReflect.Descriptor instead.

func (*NewMedianFactoryRequest) GetContractID added in v0.2.2 

func (x *NewMedianFactoryRequest) GetContractID() string

func (*NewMedianFactoryRequest) GetDataSourceID 

func (x *NewMedianFactoryRequest) GetDataSourceID() uint32

func (*NewMedianFactoryRequest) GetDeviationFuncDefinition added in v0.5.0 

func (x *NewMedianFactoryRequest) GetDeviationFuncDefinition() []byte

func (*NewMedianFactoryRequest) GetErrorLogID 

func (x *NewMedianFactoryRequest) GetErrorLogID() uint32

func (*NewMedianFactoryRequest) GetGasPriceSubunitsDataSourceID 

func (x *NewMedianFactoryRequest) GetGasPriceSubunitsDataSourceID() 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/smartcontractkit/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/smartcontractkit/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"`
	CapabilityRegistryID uint32 `protobuf:"varint,3,opt,name=capabilityRegistryID,proto3" json:"capabilityRegistryID,omitempty"`
	KeystoreCSAID        uint32 `protobuf:"varint,4,opt,name=keystoreCSAID,proto3" json:"keystoreCSAID,omitempty"`
	// contains filtered or unexported fields
}

func (*NewRelayerRequest) Descriptor deprecated 

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

Deprecated: Use NewRelayerRequest.ProtoReflect.Descriptor instead.

func (*NewRelayerRequest) GetCapabilityRegistryID 

func (x *NewRelayerRequest) GetCapabilityRegistryID() uint32

func (*NewRelayerRequest) GetConfig 

func (x *NewRelayerRequest) GetConfig() string

func (*NewRelayerRequest) GetKeystoreCSAID added in v0.7.1 

func (x *NewRelayerRequest) GetKeystoreCSAID() uint32

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/smartcontractkit/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"`
	CapRegistryID                uint32                        `protobuf:"varint,6,opt,name=capRegistryID,proto3" json:"capRegistryID,omitempty"`
	KeyValueStoreID              uint32                        `protobuf:"varint,7,opt,name=keyValueStoreID,proto3" json:"keyValueStoreID,omitempty"`
	RelayerSetID                 uint32                        `protobuf:"varint,8,opt,name=relayerSetID,proto3" json:"relayerSetID,omitempty"`
	// contains filtered or unexported fields
}

NewReportingPluginFactoryRequest has arguments for github.com/smartcontractkit/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) GetCapRegistryID 

func (x *NewReportingPluginFactoryRequest) GetCapRegistryID() uint32

func (*NewReportingPluginFactoryRequest) GetErrorLogID 

func (x *NewReportingPluginFactoryRequest) GetErrorLogID() uint32

func (*NewReportingPluginFactoryRequest) GetKeyValueStoreID 

func (x *NewReportingPluginFactoryRequest) GetKeyValueStoreID() uint32

func (*NewReportingPluginFactoryRequest) GetPipelineRunnerID 

func (x *NewReportingPluginFactoryRequest) GetPipelineRunnerID() uint32

func (*NewReportingPluginFactoryRequest) GetProviderID 

func (x *NewReportingPluginFactoryRequest) GetProviderID() uint32

func (*NewReportingPluginFactoryRequest) GetRelayerSetID 

func (x *NewReportingPluginFactoryRequest) GetRelayerSetID() 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 NodeReply added in v0.8.0 

type NodeReply struct {
	PeerID              []byte `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"` // [32]byte
	WorkflowDON         *DON   `protobuf:"bytes,2,opt,name=workflowDON,proto3" json:"workflowDON,omitempty"`
	CapabilityDONs      []*DON `protobuf:"bytes,3,rep,name=CapabilityDONs,proto3" json:"CapabilityDONs,omitempty"`
	NodeOperatorID      uint32 `protobuf:"varint,4,opt,name=nodeOperatorID,proto3" json:"nodeOperatorID,omitempty"`          // uint32
	Signer              []byte `protobuf:"bytes,5,opt,name=signer,proto3" json:"signer,omitempty"`                           // [32]byte
	EncryptionPublicKey []byte `protobuf:"bytes,6,opt,name=encryptionPublicKey,proto3" json:"encryptionPublicKey,omitempty"` // [32]byte
	// contains filtered or unexported fields
}

LocalNode has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.LocalNode.

func (*NodeReply) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use NodeReply.ProtoReflect.Descriptor instead.

func (*NodeReply) GetCapabilityDONs added in v0.8.0 

func (x *NodeReply) GetCapabilityDONs() []*DON

func (*NodeReply) GetEncryptionPublicKey added in v0.8.0 

func (x *NodeReply) GetEncryptionPublicKey() []byte

func (*NodeReply) GetNodeOperatorID added in v0.8.0 

func (x *NodeReply) GetNodeOperatorID() uint32

func (*NodeReply) GetPeerID added in v0.8.0 

func (x *NodeReply) GetPeerID() []byte

func (*NodeReply) GetSigner added in v0.8.0 

func (x *NodeReply) GetSigner() []byte

func (*NodeReply) GetWorkflowDON added in v0.8.0 

func (x *NodeReply) GetWorkflowDON() *DON

func (*NodeReply) ProtoMessage added in v0.8.0 

func (*NodeReply) ProtoMessage()

func (*NodeReply) ProtoReflect added in v0.8.0 

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

func (*NodeReply) Reset added in v0.8.0 

func (x *NodeReply) Reset()

func (*NodeReply) String added in v0.8.0 

func (x *NodeReply) String() string

type NodeRequest added in v0.8.0 

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

func (*NodeRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use NodeRequest.ProtoReflect.Descriptor instead.

func (*NodeRequest) GetPeerID added in v0.8.0 

func (x *NodeRequest) GetPeerID() []byte

func (*NodeRequest) ProtoMessage added in v0.8.0 

func (*NodeRequest) ProtoMessage()

func (*NodeRequest) ProtoReflect added in v0.8.0 

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

func (*NodeRequest) Reset added in v0.8.0 

func (x *NodeRequest) Reset()

func (*NodeRequest) String added in v0.8.0 

func (x *NodeRequest) 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/smartcontractkit/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/smartcontractkit/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/smartcontractkit/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
	GasPriceSubunits *BigInt `protobuf:"bytes,5,opt,name=gasPriceSubunits,proto3" json:"gasPriceSubunits,omitempty"`
	// 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) GetGasPriceSubunits 

func (x *ParsedAttributedObservation) GetGasPriceSubunits() *BigInt

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/smartcontractkit/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 PruneExpiredEntriesRequest added in v0.9.0 

type PruneExpiredEntriesRequest struct {
	MaxAge *durationpb.Duration `protobuf:"bytes,1,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"`
	// contains filtered or unexported fields
}

func (*PruneExpiredEntriesRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use PruneExpiredEntriesRequest.ProtoReflect.Descriptor instead.

func (*PruneExpiredEntriesRequest) GetMaxAge added in v0.9.0 

func (x *PruneExpiredEntriesRequest) GetMaxAge() *durationpb.Duration

func (*PruneExpiredEntriesRequest) ProtoMessage added in v0.9.0 

func (*PruneExpiredEntriesRequest) ProtoMessage()

func (*PruneExpiredEntriesRequest) ProtoReflect added in v0.9.0 

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

func (*PruneExpiredEntriesRequest) Reset added in v0.9.0 

func (x *PruneExpiredEntriesRequest) Reset()

func (*PruneExpiredEntriesRequest) String added in v0.9.0 

func (x *PruneExpiredEntriesRequest) String() string

type PruneExpiredEntriesResponse added in v0.9.0 

type PruneExpiredEntriesResponse struct {
	NumPruned int64 `protobuf:"varint,1,opt,name=num_pruned,json=numPruned,proto3" json:"num_pruned,omitempty"`
	// contains filtered or unexported fields
}

func (*PruneExpiredEntriesResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use PruneExpiredEntriesResponse.ProtoReflect.Descriptor instead.

func (*PruneExpiredEntriesResponse) GetNumPruned added in v0.9.0 

func (x *PruneExpiredEntriesResponse) GetNumPruned() int64

func (*PruneExpiredEntriesResponse) ProtoMessage added in v0.9.0 

func (*PruneExpiredEntriesResponse) ProtoMessage()

func (*PruneExpiredEntriesResponse) ProtoReflect added in v0.9.0 

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

func (*PruneExpiredEntriesResponse) Reset added in v0.9.0 

func (x *PruneExpiredEntriesResponse) Reset()

func (*PruneExpiredEntriesResponse) String added in v0.9.0 

func (x *PruneExpiredEntriesResponse) String() string

type QueryKeyFilter 

type QueryKeyFilter struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Expressions are lightweight orm like DSL defined for filtering over common blockchain primitives.
	Expression []*chain_common.Expression `protobuf:"bytes,2,rep,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryKeyFilter) Descriptor deprecated 

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

Deprecated: Use QueryKeyFilter.ProtoReflect.Descriptor instead.

func (*QueryKeyFilter) GetExpression 

func (x *QueryKeyFilter) GetExpression() []*chain_common.Expression

func (*QueryKeyFilter) GetKey 

func (x *QueryKeyFilter) GetKey() string

func (*QueryKeyFilter) ProtoMessage 

func (*QueryKeyFilter) ProtoMessage()

func (*QueryKeyFilter) ProtoReflect 

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

func (*QueryKeyFilter) Reset 

func (x *QueryKeyFilter) Reset()

func (*QueryKeyFilter) String 

func (x *QueryKeyFilter) String() string

type QueryKeyReply 

type QueryKeyReply struct {
	Sequences []*Sequence `protobuf:"bytes,1,rep,name=sequences,proto3" json:"sequences,omitempty"`
	// contains filtered or unexported fields
}

QueryKeyReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.QueryKey.

func (*QueryKeyReply) Descriptor deprecated 

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

Deprecated: Use QueryKeyReply.ProtoReflect.Descriptor instead.

func (*QueryKeyReply) GetSequences 

func (x *QueryKeyReply) GetSequences() []*Sequence

func (*QueryKeyReply) ProtoMessage 

func (*QueryKeyReply) ProtoMessage()

func (*QueryKeyReply) ProtoReflect 

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

func (*QueryKeyReply) Reset 

func (x *QueryKeyReply) Reset()

func (*QueryKeyReply) String 

func (x *QueryKeyReply) String() string

type QueryKeyRequest 

type QueryKeyRequest struct {
	Contract     *BoundContract             `protobuf:"bytes,1,opt,name=contract,proto3" json:"contract,omitempty"`
	Filter       *QueryKeyFilter            `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	LimitAndSort *chain_common.LimitAndSort `protobuf:"bytes,3,opt,name=limit_and_sort,json=limitAndSort,proto3" json:"limit_and_sort,omitempty"`
	AsValueType  bool                       `protobuf:"varint,4,opt,name=as_value_type,json=asValueType,proto3" json:"as_value_type,omitempty"`
	// contains filtered or unexported fields
}

QueryKeyRequest has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.QueryKey.

func (*QueryKeyRequest) Descriptor deprecated 

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

Deprecated: Use QueryKeyRequest.ProtoReflect.Descriptor instead.

func (*QueryKeyRequest) GetAsValueType added in v0.3.0 

func (x *QueryKeyRequest) GetAsValueType() bool

func (*QueryKeyRequest) GetContract added in v0.2.2 

func (x *QueryKeyRequest) GetContract() *BoundContract

func (*QueryKeyRequest) GetFilter 

func (x *QueryKeyRequest) GetFilter() *QueryKeyFilter

func (*QueryKeyRequest) GetLimitAndSort 

func (x *QueryKeyRequest) GetLimitAndSort() *chain_common.LimitAndSort

func (*QueryKeyRequest) ProtoMessage 

func (*QueryKeyRequest) ProtoMessage()

func (*QueryKeyRequest) ProtoReflect 

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

func (*QueryKeyRequest) Reset 

func (x *QueryKeyRequest) Reset()

func (*QueryKeyRequest) String 

func (x *QueryKeyRequest) String() string

type QueryKeysReply added in v0.4.0 

type QueryKeysReply struct {
	Sequences []*SequenceWithKey `protobuf:"bytes,1,rep,name=sequences,proto3" json:"sequences,omitempty"`
	// contains filtered or unexported fields
}

QueryKeysReply has return arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.QueryKeys.

func (*QueryKeysReply) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use QueryKeysReply.ProtoReflect.Descriptor instead.

func (*QueryKeysReply) GetSequences added in v0.4.0 

func (x *QueryKeysReply) GetSequences() []*SequenceWithKey

func (*QueryKeysReply) ProtoMessage added in v0.4.0 

func (*QueryKeysReply) ProtoMessage()

func (*QueryKeysReply) ProtoReflect added in v0.4.0 

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

func (*QueryKeysReply) Reset added in v0.4.0 

func (x *QueryKeysReply) Reset()

func (*QueryKeysReply) String added in v0.4.0 

func (x *QueryKeysReply) String() string

type QueryKeysRequest added in v0.4.0 

type QueryKeysRequest struct {
	Filters      []*ContractKeyFilter       `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	LimitAndSort *chain_common.LimitAndSort `protobuf:"bytes,2,opt,name=limit_and_sort,json=limitAndSort,proto3" json:"limit_and_sort,omitempty"`
	// contains filtered or unexported fields
}

QueryKeysRequest has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.QueryKeys.

func (*QueryKeysRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use QueryKeysRequest.ProtoReflect.Descriptor instead.

func (*QueryKeysRequest) GetFilters added in v0.4.0 

func (x *QueryKeysRequest) GetFilters() []*ContractKeyFilter

func (*QueryKeysRequest) GetLimitAndSort added in v0.4.0 

func (x *QueryKeysRequest) GetLimitAndSort() *chain_common.LimitAndSort

func (*QueryKeysRequest) ProtoMessage added in v0.4.0 

func (*QueryKeysRequest) ProtoMessage()

func (*QueryKeysRequest) ProtoReflect added in v0.4.0 

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

func (*QueryKeysRequest) Reset added in v0.4.0 

func (x *QueryKeysRequest) Reset()

func (*QueryKeysRequest) String added in v0.4.0 

func (x *QueryKeysRequest) String() string

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/smartcontractkit/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 {
	NewContractWriter(ctx context.Context, in *NewContractWriterRequest, opts ...grpc.CallOption) (*NewContractWriterReply, error)
	NewContractReader(ctx context.Context, in *NewContractReaderRequest, opts ...grpc.CallOption) (*NewContractReaderReply, error)
	NewConfigProvider(ctx context.Context, in *NewConfigProviderRequest, opts ...grpc.CallOption) (*NewConfigProviderReply, error)
	NewPluginProvider(ctx context.Context, in *NewPluginProviderRequest, opts ...grpc.CallOption) (*NewPluginProviderReply, error)
	NewCCIPProvider(ctx context.Context, in *NewCCIPProviderRequest, opts ...grpc.CallOption) (*NewCCIPProviderReply, error)
	LatestHead(ctx context.Context, in *LatestHeadRequest, opts ...grpc.CallOption) (*LatestHeadReply, error)
	GetChainStatus(ctx context.Context, in *GetChainStatusRequest, opts ...grpc.CallOption) (*GetChainStatusReply, error)
	GetChainInfo(ctx context.Context, in *GetChainInfoRequest, opts ...grpc.CallOption) (*GetChainInfoReply, error)
	ListNodeStatuses(ctx context.Context, in *ListNodeStatusesRequest, opts ...grpc.CallOption) (*ListNodeStatusesReply, error)
	Transact(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Replay(ctx context.Context, in *ReplayRequest, 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 {
	NewContractWriter(context.Context, *NewContractWriterRequest) (*NewContractWriterReply, error)
	NewContractReader(context.Context, *NewContractReaderRequest) (*NewContractReaderReply, error)
	NewConfigProvider(context.Context, *NewConfigProviderRequest) (*NewConfigProviderReply, error)
	NewPluginProvider(context.Context, *NewPluginProviderRequest) (*NewPluginProviderReply, error)
	NewCCIPProvider(context.Context, *NewCCIPProviderRequest) (*NewCCIPProviderReply, error)
	LatestHead(context.Context, *LatestHeadRequest) (*LatestHeadReply, error)
	GetChainStatus(context.Context, *GetChainStatusRequest) (*GetChainStatusReply, error)
	GetChainInfo(context.Context, *GetChainInfoRequest) (*GetChainInfoReply, error)
	ListNodeStatuses(context.Context, *ListNodeStatusesRequest) (*ListNodeStatusesReply, error)
	Transact(context.Context, *TransactionRequest) (*emptypb.Empty, error)
	Replay(context.Context, *ReplayRequest) (*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 RemoveRequest added in v0.4.0 

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

Remove has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.CapabilitiesRegistry.Remove.

func (*RemoveRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetId added in v0.4.0 

func (x *RemoveRequest) GetId() string

func (*RemoveRequest) ProtoMessage added in v0.4.0 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect added in v0.4.0 

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

func (*RemoveRequest) Reset added in v0.4.0 

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String added in v0.4.0 

func (x *RemoveRequest) String() string

type ReplayRequest added in v0.6.0 

type ReplayRequest struct {
	FromBlock string           `protobuf:"bytes,1,opt,name=fromBlock,proto3" json:"fromBlock,omitempty"`
	Args      *structpb.Struct `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplayRequest) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use ReplayRequest.ProtoReflect.Descriptor instead.

func (*ReplayRequest) GetArgs added in v0.6.0 

func (x *ReplayRequest) GetArgs() *structpb.Struct

func (*ReplayRequest) GetFromBlock added in v0.6.0 

func (x *ReplayRequest) GetFromBlock() string

func (*ReplayRequest) ProtoMessage added in v0.6.0 

func (*ReplayRequest) ProtoMessage()

func (*ReplayRequest) ProtoReflect added in v0.6.0 

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

func (*ReplayRequest) Reset added in v0.6.0 

func (x *ReplayRequest) Reset()

func (*ReplayRequest) String added in v0.6.0 

func (x *ReplayRequest) String() string

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.

ReportCodec is gRPC adapter of github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.ReportCodec.

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.

ReportCodec is gRPC adapter of github.com/smartcontractkit/libocr/offchainreporting2/reportingplugin/median.ReportCodec.

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 ReportTimestampToPb 

func ReportTimestampToPb(ts libocr.ReportTimestamp) *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)
	NewValidationService(ctx context.Context, in *ValidationServiceRequest, opts ...grpc.CallOption) (*ValidationServiceResponse, 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)
	NewValidationService(context.Context, *ValidationServiceRequest) (*ValidationServiceResponse, 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/smartcontractkit/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 Sequence 

type Sequence struct {
	SequenceCursor string                `protobuf:"bytes,1,opt,name=sequence_cursor,json=sequenceCursor,proto3" json:"sequence_cursor,omitempty"`
	Head           *Head                 `protobuf:"bytes,2,opt,name=head,proto3" json:"head,omitempty"`
	Data           *codec.VersionedBytes `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	TxHash         []byte                `protobuf:"bytes,4,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// contains filtered or unexported fields
}

Head is gRPC adapter for the Head struct github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.Sequence.

func (*Sequence) Descriptor deprecated 

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

Deprecated: Use Sequence.ProtoReflect.Descriptor instead.

func (*Sequence) GetData 

func (x *Sequence) GetData() *codec.VersionedBytes

func (*Sequence) GetHead 

func (x *Sequence) GetHead() *Head

func (*Sequence) GetSequenceCursor 

func (x *Sequence) GetSequenceCursor() string

func (*Sequence) GetTxHash added in v0.7.1 

func (x *Sequence) GetTxHash() []byte

func (*Sequence) ProtoMessage 

func (*Sequence) ProtoMessage()

func (*Sequence) ProtoReflect 

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

func (*Sequence) Reset 

func (x *Sequence) Reset()

func (*Sequence) String 

func (x *Sequence) String() string

type SequenceWithKey added in v0.4.0 

type SequenceWithKey struct {
	SequenceCursor string                `protobuf:"bytes,1,opt,name=sequence_cursor,json=sequenceCursor,proto3" json:"sequence_cursor,omitempty"`
	Head           *Head                 `protobuf:"bytes,2,opt,name=head,proto3" json:"head,omitempty"`
	Data           *codec.VersionedBytes `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Key            string                `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	TxHash         []byte                `protobuf:"bytes,5,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*SequenceWithKey) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use SequenceWithKey.ProtoReflect.Descriptor instead.

func (*SequenceWithKey) GetData added in v0.4.0 

func (x *SequenceWithKey) GetData() *codec.VersionedBytes

func (*SequenceWithKey) GetHead added in v0.4.0 

func (x *SequenceWithKey) GetHead() *Head

func (*SequenceWithKey) GetKey added in v0.4.0 

func (x *SequenceWithKey) GetKey() string

func (*SequenceWithKey) GetSequenceCursor added in v0.4.0 

func (x *SequenceWithKey) GetSequenceCursor() string

func (*SequenceWithKey) GetTxHash added in v0.7.1 

func (x *SequenceWithKey) GetTxHash() []byte

func (*SequenceWithKey) ProtoMessage added in v0.4.0 

func (*SequenceWithKey) ProtoMessage()

func (*SequenceWithKey) ProtoReflect added in v0.4.0 

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

func (*SequenceWithKey) Reset added in v0.4.0 

func (x *SequenceWithKey) Reset()

func (*SequenceWithKey) String added in v0.4.0 

func (x *SequenceWithKey) 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 StoreKeyValueRequest 

type StoreKeyValueRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreKeyValueRequest) Descriptor deprecated 

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

Deprecated: Use StoreKeyValueRequest.ProtoReflect.Descriptor instead.

func (*StoreKeyValueRequest) GetKey 

func (x *StoreKeyValueRequest) GetKey() string

func (*StoreKeyValueRequest) GetValue 

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

func (*StoreKeyValueRequest) ProtoMessage 

func (*StoreKeyValueRequest) ProtoMessage()

func (*StoreKeyValueRequest) ProtoReflect 

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

func (*StoreKeyValueRequest) Reset 

func (x *StoreKeyValueRequest) Reset()

func (*StoreKeyValueRequest) String 

func (x *StoreKeyValueRequest) String() string

type SubmitTransactionRequest 

type SubmitTransactionRequest struct {
	ContractName  string                `protobuf:"bytes,1,opt,name=contract_name,json=contractName,proto3" json:"contract_name,omitempty"`
	Method        string                `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Params        *codec.VersionedBytes `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	TransactionId string                `protobuf:"bytes,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	ToAddress     string                `protobuf:"bytes,5,opt,name=to_address,json=toAddress,proto3" json:"to_address,omitempty"`
	Meta          *TransactionMeta      `protobuf:"bytes,6,opt,name=meta,proto3" json:"meta,omitempty"`
	Value         *BigInt               `protobuf:"bytes,7,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitTransactionRequest) Descriptor deprecated 

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

Deprecated: Use SubmitTransactionRequest.ProtoReflect.Descriptor instead.

func (*SubmitTransactionRequest) GetContractName 

func (x *SubmitTransactionRequest) GetContractName() string

func (*SubmitTransactionRequest) GetMeta 

func (x *SubmitTransactionRequest) GetMeta() *TransactionMeta

func (*SubmitTransactionRequest) GetMethod 

func (x *SubmitTransactionRequest) GetMethod() string

func (*SubmitTransactionRequest) GetParams 

func (x *SubmitTransactionRequest) GetParams() *codec.VersionedBytes

func (*SubmitTransactionRequest) GetToAddress 

func (x *SubmitTransactionRequest) GetToAddress() string

func (*SubmitTransactionRequest) GetTransactionId 

func (x *SubmitTransactionRequest) GetTransactionId() string

func (*SubmitTransactionRequest) GetValue 

func (x *SubmitTransactionRequest) GetValue() *BigInt

func (*SubmitTransactionRequest) ProtoMessage 

func (*SubmitTransactionRequest) ProtoMessage()

func (*SubmitTransactionRequest) ProtoReflect 

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

func (*SubmitTransactionRequest) Reset 

func (x *SubmitTransactionRequest) Reset()

func (*SubmitTransactionRequest) String 

func (x *SubmitTransactionRequest) 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      []byte `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() []byte

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 TransactionMeta 

type TransactionMeta struct {
	WorkflowExecutionId string  `protobuf:"bytes,1,opt,name=workflow_execution_id,json=workflowExecutionId,proto3" json:"workflow_execution_id,omitempty"`
	GasLimit            *BigInt `protobuf:"bytes,2,opt,name=gas_limit,json=gasLimit,proto3" json:"gas_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionMeta) Descriptor deprecated 

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

Deprecated: Use TransactionMeta.ProtoReflect.Descriptor instead.

func (*TransactionMeta) GetGasLimit added in v0.2.2 

func (x *TransactionMeta) GetGasLimit() *BigInt

func (*TransactionMeta) GetWorkflowExecutionId 

func (x *TransactionMeta) GetWorkflowExecutionId() string

func (*TransactionMeta) ProtoMessage 

func (*TransactionMeta) ProtoMessage()

func (*TransactionMeta) ProtoReflect 

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

func (*TransactionMeta) Reset 

func (x *TransactionMeta) Reset()

func (*TransactionMeta) String 

func (x *TransactionMeta) String() string

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/smartcontractkit/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 UnbindRequest added in v0.2.2 

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

UnbindRequest has arguments for github.com/smartcontractkit/chainlink-common/pkg/types.ContractReader.Unbind.

func (*UnbindRequest) Descriptor deprecated added in v0.2.2 

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

Deprecated: Use UnbindRequest.ProtoReflect.Descriptor instead.

func (*UnbindRequest) GetBindings added in v0.2.2 

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

func (*UnbindRequest) ProtoMessage added in v0.2.2 

func (*UnbindRequest) ProtoMessage()

func (*UnbindRequest) ProtoReflect added in v0.2.2 

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

func (*UnbindRequest) Reset added in v0.2.2 

func (x *UnbindRequest) Reset()

func (*UnbindRequest) String added in v0.2.2 

func (x *UnbindRequest) String() string

type UnimplementedCapabilitiesRegistryServer 

type UnimplementedCapabilitiesRegistryServer struct{}

UnimplementedCapabilitiesRegistryServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedCapabilitiesRegistryServer) Add 

func (UnimplementedCapabilitiesRegistryServer) Add(context.Context, *AddRequest) (*emptypb.Empty, error)

func (UnimplementedCapabilitiesRegistryServer) ConfigForCapability added in v0.2.2 

func (UnimplementedCapabilitiesRegistryServer) ConfigForCapability(context.Context, *ConfigForCapabilityRequest) (*ConfigForCapabilityReply, error)

func (UnimplementedCapabilitiesRegistryServer) DONsForCapability added in v0.9.4 

func (UnimplementedCapabilitiesRegistryServer) DONsForCapability(context.Context, *DONForCapabilityRequest) (*DONForCapabilityReply, error)

func (UnimplementedCapabilitiesRegistryServer) Get 

func (UnimplementedCapabilitiesRegistryServer) Get(context.Context, *GetRequest) (*GetReply, error)

func (UnimplementedCapabilitiesRegistryServer) GetExecutable added in v0.7.1 

func (UnimplementedCapabilitiesRegistryServer) GetExecutable(context.Context, *GetExecutableRequest) (*GetExecutableReply, error)

func (UnimplementedCapabilitiesRegistryServer) GetTrigger 

func (UnimplementedCapabilitiesRegistryServer) GetTrigger(context.Context, *GetTriggerRequest) (*GetTriggerReply, error)

func (UnimplementedCapabilitiesRegistryServer) List 

func (UnimplementedCapabilitiesRegistryServer) List(context.Context, *emptypb.Empty) (*ListReply, error)

func (UnimplementedCapabilitiesRegistryServer) LocalNode added in v0.2.2 

func (UnimplementedCapabilitiesRegistryServer) LocalNode(context.Context, *emptypb.Empty) (*NodeReply, error)

func (UnimplementedCapabilitiesRegistryServer) NodeByPeerID added in v0.8.0 

func (UnimplementedCapabilitiesRegistryServer) NodeByPeerID(context.Context, *NodeRequest) (*NodeReply, error)

func (UnimplementedCapabilitiesRegistryServer) Remove added in v0.4.0 

func (UnimplementedCapabilitiesRegistryServer) Remove(context.Context, *RemoveRequest) (*emptypb.Empty, error)

type UnimplementedContractConfigTrackerServer 

type UnimplementedContractConfigTrackerServer struct{}

UnimplementedContractConfigTrackerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (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 UnimplementedContractReaderServer added in v0.2.2 

type UnimplementedContractReaderServer struct{}

UnimplementedContractReaderServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedContractReaderServer) BatchGetLatestValues added in v0.2.2 

func (UnimplementedContractReaderServer) BatchGetLatestValues(context.Context, *BatchGetLatestValuesRequest) (*BatchGetLatestValuesReply, error)

func (UnimplementedContractReaderServer) Bind added in v0.2.2 

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

func (UnimplementedContractReaderServer) GetLatestValue added in v0.2.2 

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

func (UnimplementedContractReaderServer) GetLatestValueWithHeadData added in v0.4.0 

func (UnimplementedContractReaderServer) GetLatestValueWithHeadData(context.Context, *GetLatestValueRequest) (*GetLatestValueWithHeadDataReply, error)

func (UnimplementedContractReaderServer) QueryKey added in v0.2.2 

func (UnimplementedContractReaderServer) QueryKey(context.Context, *QueryKeyRequest) (*QueryKeyReply, error)

func (UnimplementedContractReaderServer) QueryKeys added in v0.4.0 

func (UnimplementedContractReaderServer) QueryKeys(context.Context, *QueryKeysRequest) (*QueryKeysReply, error)

func (UnimplementedContractReaderServer) Unbind added in v0.2.2 

func (UnimplementedContractReaderServer) Unbind(context.Context, *UnbindRequest) (*emptypb.Empty, error)

type UnimplementedContractTransmitterServer 

type UnimplementedContractTransmitterServer struct{}

UnimplementedContractTransmitterServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (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 UnimplementedContractWriterServer added in v0.4.0 

type UnimplementedContractWriterServer struct{}

UnimplementedContractWriterServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedContractWriterServer) GetEstimateFee added in v0.7.1 

func (UnimplementedContractWriterServer) GetEstimateFee(context.Context, *GetEstimateFeeRequest) (*GetEstimateFeeReply, error)

func (UnimplementedContractWriterServer) GetFeeComponents added in v0.4.0 

func (UnimplementedContractWriterServer) GetFeeComponents(context.Context, *emptypb.Empty) (*GetFeeComponentsReply, error)

func (UnimplementedContractWriterServer) GetTransactionStatus added in v0.4.0 

func (UnimplementedContractWriterServer) GetTransactionStatus(context.Context, *evm.GetTransactionStatusRequest) (*evm.GetTransactionStatusReply, error)

func (UnimplementedContractWriterServer) SubmitTransaction added in v0.4.0 

func (UnimplementedContractWriterServer) SubmitTransaction(context.Context, *SubmitTransactionRequest) (*emptypb.Empty, error)

type UnimplementedDataSourceServer 

type UnimplementedDataSourceServer struct{}

UnimplementedDataSourceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDataSourceServer) Observe 

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

type UnimplementedErrorLogServer 

type UnimplementedErrorLogServer struct{}

UnimplementedErrorLogServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedErrorLogServer) SaveError 

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

type UnimplementedKeyValueStoreServer 

type UnimplementedKeyValueStoreServer struct{}

UnimplementedKeyValueStoreServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedKeyValueStoreServer) GetValueForKey 

func (UnimplementedKeyValueStoreServer) GetValueForKey(context.Context, *GetValueForKeyRequest) (*GetValueForKeyResponse, error)

func (UnimplementedKeyValueStoreServer) PruneExpiredEntries added in v0.9.0 

func (UnimplementedKeyValueStoreServer) PruneExpiredEntries(context.Context, *PruneExpiredEntriesRequest) (*PruneExpiredEntriesResponse, error)

func (UnimplementedKeyValueStoreServer) StoreKeyValue 

func (UnimplementedKeyValueStoreServer) StoreKeyValue(context.Context, *StoreKeyValueRequest) (*emptypb.Empty, error)

type UnimplementedKeystoreServer 

type UnimplementedKeystoreServer struct{}

UnimplementedKeystoreServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedKeystoreServer) Accounts 

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

func (UnimplementedKeystoreServer) Decrypt added in v0.9.3 

func (UnimplementedKeystoreServer) Decrypt(context.Context, *DecryptRequest) (*DecryptReply, 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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedRelayerServer) GetChainInfo added in v0.7.1 

func (UnimplementedRelayerServer) GetChainInfo(context.Context, *GetChainInfoRequest) (*GetChainInfoReply, error)

func (UnimplementedRelayerServer) GetChainStatus 

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

func (UnimplementedRelayerServer) LatestHead added in v0.2.2 

func (UnimplementedRelayerServer) LatestHead(context.Context, *LatestHeadRequest) (*LatestHeadReply, error)

func (UnimplementedRelayerServer) ListNodeStatuses 

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

func (UnimplementedRelayerServer) NewCCIPProvider added in v0.9.0 

func (UnimplementedRelayerServer) NewCCIPProvider(context.Context, *NewCCIPProviderRequest) (*NewCCIPProviderReply, error)

func (UnimplementedRelayerServer) NewConfigProvider 

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

func (UnimplementedRelayerServer) NewContractReader 

func (UnimplementedRelayerServer) NewContractReader(context.Context, *NewContractReaderRequest) (*NewContractReaderReply, error)

func (UnimplementedRelayerServer) NewContractWriter added in v0.4.0 

func (UnimplementedRelayerServer) NewContractWriter(context.Context, *NewContractWriterRequest) (*NewContractWriterReply, error)

func (UnimplementedRelayerServer) NewPluginProvider 

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

func (UnimplementedRelayerServer) Replay added in v0.6.0 

func (UnimplementedRelayerServer) Replay(context.Context, *ReplayRequest) (*emptypb.Empty, 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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedReportingPluginServiceServer) NewReportingPluginFactory 

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

func (UnimplementedReportingPluginServiceServer) NewValidationService 

func (UnimplementedReportingPluginServiceServer) NewValidationService(context.Context, *ValidationServiceRequest) (*ValidationServiceResponse, error)

type UnimplementedServiceServer 

type UnimplementedServiceServer struct{}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTelemetryServer) Send 

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

type UnimplementedValidationServiceServer 

type UnimplementedValidationServiceServer struct{}

UnimplementedValidationServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedValidationServiceServer) ValidateConfig 

func (UnimplementedValidationServiceServer) ValidateConfig(context.Context, *ValidateConfigRequest) (*ValidateConfigResponse, error)

type UnsafeCapabilitiesRegistryServer 

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

UnsafeCapabilitiesRegistryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CapabilitiesRegistryServer 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 UnsafeContractReaderServer added in v0.2.2 

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

UnsafeContractReaderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContractReaderServer 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 UnsafeContractWriterServer added in v0.4.0 

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

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

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

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

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

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

type ValidateConfigRequest 

type ValidateConfigRequest struct {
	Config *structpb.Struct `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateConfigRequest) Descriptor deprecated 

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

Deprecated: Use ValidateConfigRequest.ProtoReflect.Descriptor instead.

func (*ValidateConfigRequest) GetConfig 

func (x *ValidateConfigRequest) GetConfig() *structpb.Struct

func (*ValidateConfigRequest) ProtoMessage 

func (*ValidateConfigRequest) ProtoMessage()

func (*ValidateConfigRequest) ProtoReflect 

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

func (*ValidateConfigRequest) Reset 

func (x *ValidateConfigRequest) Reset()

func (*ValidateConfigRequest) String 

func (x *ValidateConfigRequest) String() string

type ValidateConfigResponse 

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

func (*ValidateConfigResponse) Descriptor deprecated 

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

Deprecated: Use ValidateConfigResponse.ProtoReflect.Descriptor instead.

func (*ValidateConfigResponse) ProtoMessage 

func (*ValidateConfigResponse) ProtoMessage()

func (*ValidateConfigResponse) ProtoReflect 

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

func (*ValidateConfigResponse) Reset 

func (x *ValidateConfigResponse) Reset()

func (*ValidateConfigResponse) String 

func (x *ValidateConfigResponse) String() string

type ValidationServiceClient 

type ValidationServiceClient interface {
	ValidateConfig(ctx context.Context, in *ValidateConfigRequest, opts ...grpc.CallOption) (*ValidateConfigResponse, error)
}

ValidationServiceClient is the client API for ValidationService 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 NewValidationServiceClient 

func NewValidationServiceClient(cc grpc.ClientConnInterface) ValidationServiceClient

type ValidationServiceRequest 

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

func (*ValidationServiceRequest) Descriptor deprecated 

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

Deprecated: Use ValidationServiceRequest.ProtoReflect.Descriptor instead.

func (*ValidationServiceRequest) ProtoMessage 

func (*ValidationServiceRequest) ProtoMessage()

func (*ValidationServiceRequest) ProtoReflect 

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

func (*ValidationServiceRequest) Reset 

func (x *ValidationServiceRequest) Reset()

func (*ValidationServiceRequest) String 

func (x *ValidationServiceRequest) String() string

type ValidationServiceResponse 

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

func (*ValidationServiceResponse) Descriptor deprecated 

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

Deprecated: Use ValidationServiceResponse.ProtoReflect.Descriptor instead.

func (*ValidationServiceResponse) GetID 

func (x *ValidationServiceResponse) GetID() uint32

func (*ValidationServiceResponse) ProtoMessage 

func (*ValidationServiceResponse) ProtoMessage()

func (*ValidationServiceResponse) ProtoReflect 

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

func (*ValidationServiceResponse) Reset 

func (x *ValidationServiceResponse) Reset()

func (*ValidationServiceResponse) String 

func (x *ValidationServiceResponse) String() string

type ValidationServiceServer 

type ValidationServiceServer interface {
	ValidateConfig(context.Context, *ValidateConfigRequest) (*ValidateConfigResponse, error)
	// contains filtered or unexported methods
}

ValidationServiceServer is the server API for ValidationService service. All implementations must embed UnimplementedValidationServiceServer for forward compatibility.

Source Files

View all Source files

Directories

Path Synopsis
codecgen command
v1
v2
v3
v4
generate command

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.