pb

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CapabilitiesRegistry_LocalNode_FullMethodName           = "/loop.CapabilitiesRegistry/LocalNode"
	CapabilitiesRegistry_ConfigForCapability_FullMethodName = "/loop.CapabilitiesRegistry/ConfigForCapability"
	CapabilitiesRegistry_Get_FullMethodName                 = "/loop.CapabilitiesRegistry/Get"
	CapabilitiesRegistry_GetTrigger_FullMethodName          = "/loop.CapabilitiesRegistry/GetTrigger"
	CapabilitiesRegistry_GetAction_FullMethodName           = "/loop.CapabilitiesRegistry/GetAction"
	CapabilitiesRegistry_GetConsensus_FullMethodName        = "/loop.CapabilitiesRegistry/GetConsensus"
	CapabilitiesRegistry_GetTarget_FullMethodName           = "/loop.CapabilitiesRegistry/GetTarget"
	CapabilitiesRegistry_List_FullMethodName                = "/loop.CapabilitiesRegistry/List"
	CapabilitiesRegistry_Add_FullMethodName                 = "/loop.CapabilitiesRegistry/Add"
)
View Source 
const (
	ChainWriter_SubmitTransaction_FullMethodName    = "/loop.ChainWriter/SubmitTransaction"
	ChainWriter_GetTransactionStatus_FullMethodName = "/loop.ChainWriter/GetTransactionStatus"
	ChainWriter_GetFeeComponents_FullMethodName     = "/loop.ChainWriter/GetFeeComponents"
)
View Source 
const (
	Codec_GetEncoding_FullMethodName = "/loop.Codec/GetEncoding"
	Codec_GetDecoding_FullMethodName = "/loop.Codec/GetDecoding"
	Codec_GetMaxSize_FullMethodName  = "/loop.Codec/GetMaxSize"
)
View Source 
const (
	ContractReader_GetLatestValue_FullMethodName       = "/loop.ContractReader/GetLatestValue"
	ContractReader_BatchGetLatestValues_FullMethodName = "/loop.ContractReader/BatchGetLatestValues"
	ContractReader_QueryKey_FullMethodName             = "/loop.ContractReader/QueryKey"
	ContractReader_Bind_FullMethodName                 = "/loop.ContractReader/Bind"
	ContractReader_Unbind_FullMethodName               = "/loop.ContractReader/Unbind"
)
View Source 
const (
	KeyValueStore_StoreKeyValue_FullMethodName  = "/loop.KeyValueStore/StoreKeyValue"
	KeyValueStore_GetValueForKey_FullMethodName = "/loop.KeyValueStore/GetValueForKey"
)
View Source 
const (
	ReportCodec_BuildReport_FullMethodName      = "/loop.ReportCodec/BuildReport"
	ReportCodec_MedianFromReport_FullMethodName = "/loop.ReportCodec/MedianFromReport"
	ReportCodec_MaxReportLength_FullMethodName  = "/loop.ReportCodec/MaxReportLength"
)
View Source 
const (
	MedianContract_LatestTransmissionDetails_FullMethodName = "/loop.MedianContract/LatestTransmissionDetails"
	MedianContract_LatestRoundRequested_FullMethodName      = "/loop.MedianContract/LatestRoundRequested"
)
View Source 
const (
	OnchainConfigCodec_Encode_FullMethodName = "/loop.OnchainConfigCodec/Encode"
	OnchainConfigCodec_Decode_FullMethodName = "/loop.OnchainConfigCodec/Decode"
)
View Source 
const (
	Keystore_Accounts_FullMethodName = "/loop.Keystore/Accounts"
	Keystore_Sign_FullMethodName     = "/loop.Keystore/Sign"
)
View Source 
const (
	Relayer_NewChainWriter_FullMethodName    = "/loop.Relayer/NewChainWriter"
	Relayer_NewContractReader_FullMethodName = "/loop.Relayer/NewContractReader"
	Relayer_NewConfigProvider_FullMethodName = "/loop.Relayer/NewConfigProvider"
	Relayer_NewPluginProvider_FullMethodName = "/loop.Relayer/NewPluginProvider"
	Relayer_LatestHead_FullMethodName        = "/loop.Relayer/LatestHead"
	Relayer_GetChainStatus_FullMethodName    = "/loop.Relayer/GetChainStatus"
	Relayer_ListNodeStatuses_FullMethodName  = "/loop.Relayer/ListNodeStatuses"
	Relayer_Transact_FullMethodName          = "/loop.Relayer/Transact"
)
View Source 
const (
	OffchainConfigDigester_ConfigDigest_FullMethodName       = "/loop.OffchainConfigDigester/ConfigDigest"
	OffchainConfigDigester_ConfigDigestPrefix_FullMethodName = "/loop.OffchainConfigDigester/ConfigDigestPrefix"
)
View Source 
const (
	ContractConfigTracker_LatestConfigDetails_FullMethodName = "/loop.ContractConfigTracker/LatestConfigDetails"
	ContractConfigTracker_LatestConfig_FullMethodName        = "/loop.ContractConfigTracker/LatestConfig"
	ContractConfigTracker_LatestBlockHeight_FullMethodName   = "/loop.ContractConfigTracker/LatestBlockHeight"
)
View Source 
const (
	ContractTransmitter_Transmit_FullMethodName                   = "/loop.ContractTransmitter/Transmit"
	ContractTransmitter_LatestConfigDigestAndEpoch_FullMethodName = "/loop.ContractTransmitter/LatestConfigDigestAndEpoch"
	ContractTransmitter_FromAccount_FullMethodName                = "/loop.ContractTransmitter/FromAccount"
)
View Source 
const (
	Service_Name_FullMethodName         = "/loop.Service/Name"
	Service_Close_FullMethodName        = "/loop.Service/Close"
	Service_Ready_FullMethodName        = "/loop.Service/Ready"
	Service_HealthReport_FullMethodName = "/loop.Service/HealthReport"
)
View Source 
const (
	ReportingPlugin_Query_FullMethodName                        = "/loop.ReportingPlugin/Query"
	ReportingPlugin_Observation_FullMethodName                  = "/loop.ReportingPlugin/Observation"
	ReportingPlugin_Report_FullMethodName                       = "/loop.ReportingPlugin/Report"
	ReportingPlugin_ShouldAcceptFinalizedReport_FullMethodName  = "/loop.ReportingPlugin/ShouldAcceptFinalizedReport"
	ReportingPlugin_ShouldTransmitAcceptedReport_FullMethodName = "/loop.ReportingPlugin/ShouldTransmitAcceptedReport"
	ReportingPlugin_Close_FullMethodName                        = "/loop.ReportingPlugin/Close"
)
View Source 
const (
	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",
	}
	ExecuteAPIType_value = map[string]int32{
		"EXECUTE_API_TYPE_UNKNOWN": 0,
		"EXECUTE_API_TYPE_TRIGGER": 1,
		"EXECUTE_API_TYPE_EXECUTE": 2,
	}
)

Enum value maps for ExecuteAPIType.

View Source 
var (
	TransactionStatus_name = map[int32]string{
		0: "TRANSACTION_STATUS_UNKNOWN",
		1: "TRANSACTION_STATUS_PENDING",
		2: "TRANSACTION_STATUS_UNCONFIRMED",
		3: "TRANSACTION_STATUS_FINALIZED",
		4: "TRANSACTION_STATUS_FAILED",
		5: "TRANSACTION_STATUS_FATAL",
	}
	TransactionStatus_value = map[string]int32{
		"TRANSACTION_STATUS_UNKNOWN":     0,
		"TRANSACTION_STATUS_PENDING":     1,
		"TRANSACTION_STATUS_UNCONFIRMED": 2,
		"TRANSACTION_STATUS_FINALIZED":   3,
		"TRANSACTION_STATUS_FAILED":      4,
		"TRANSACTION_STATUS_FATAL":       5,
	}
)

Enum value maps for TransactionStatus.

View Source 
var (
	ComparisonOperator_name = map[int32]string{
		0: "Eq",
		1: "Neq",
		2: "Gt",
		3: "Lt",
		4: "Gte",
		5: "Lte",
	}
	ComparisonOperator_value = map[string]int32{
		"Eq":  0,
		"Neq": 1,
		"Gt":  2,
		"Lt":  3,
		"Gte": 4,
		"Lte": 5,
	}
)

Enum value maps for ComparisonOperator.

View Source 
var (
	BooleanOperator_name = map[int32]string{
		0: "AND",
		1: "OR",
	}
	BooleanOperator_value = map[string]int32{
		"AND": 0,
		"OR":  1,
	}
)

Enum value maps for BooleanOperator.

View Source 
var (
	Confidence_name = map[int32]string{
		0: "Unconfirmed",
		1: "Finalized",
	}
	Confidence_value = map[string]int32{
		"Unconfirmed": 0,
		"Finalized":   1,
	}
)

Enum value maps for Confidence.

View Source 
var (
	CursorDirection_name = map[int32]string{
		0: "Preceding",
		1: "Following",
	}
	CursorDirection_value = map[string]int32{
		"Preceding": 0,
		"Following": 1,
	}
)

Enum value maps for CursorDirection.

View Source 
var (
	SortDirection_name = map[int32]string{
		0: "Asc",
		1: "Desc",
	}
	SortDirection_value = map[string]int32{
		"Asc":  0,
		"Desc": 1,
	}
)

Enum value maps for SortDirection.

View Source 
var (
	SortType_name = map[int32]string{
		0: "SortTimestamp",
		1: "SortBlock",
		2: "SortSequence",
	}
	SortType_value = map[string]int32{
		"SortTimestamp": 0,
		"SortBlock":     1,
		"SortSequence":  2,
	}
)

Enum value maps for SortType.

View Source 
var CapabilitiesRegistry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.CapabilitiesRegistry",
	HandlerType: (*CapabilitiesRegistryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LocalNode",
			Handler:    _CapabilitiesRegistry_LocalNode_Handler,
		},
		{
			MethodName: "ConfigForCapability",
			Handler:    _CapabilitiesRegistry_ConfigForCapability_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _CapabilitiesRegistry_Get_Handler,
		},
		{
			MethodName: "GetTrigger",
			Handler:    _CapabilitiesRegistry_GetTrigger_Handler,
		},
		{
			MethodName: "GetAction",
			Handler:    _CapabilitiesRegistry_GetAction_Handler,
		},
		{
			MethodName: "GetConsensus",
			Handler:    _CapabilitiesRegistry_GetConsensus_Handler,
		},
		{
			MethodName: "GetTarget",
			Handler:    _CapabilitiesRegistry_GetTarget_Handler,
		},
		{
			MethodName: "List",
			Handler:    _CapabilitiesRegistry_List_Handler,
		},
		{
			MethodName: "Add",
			Handler:    _CapabilitiesRegistry_Add_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "loop/internal/pb/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 ChainWriter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ChainWriter",
	HandlerType: (*ChainWriterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitTransaction",
			Handler:    _ChainWriter_SubmitTransaction_Handler,
		},
		{
			MethodName: "GetTransactionStatus",
			Handler:    _ChainWriter_GetTransactionStatus_Handler,
		},
		{
			MethodName: "GetFeeComponents",
			Handler:    _ChainWriter_GetFeeComponents_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chain_writer.proto",
}

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

View Source 
var Codec_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.Codec",
	HandlerType: (*CodecServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetEncoding",
			Handler:    _Codec_GetEncoding_Handler,
		},
		{
			MethodName: "GetDecoding",
			Handler:    _Codec_GetDecoding_Handler,
		},
		{
			MethodName: "GetMaxSize",
			Handler:    _Codec_GetMaxSize_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "codec.proto",
}

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

View Source 
var ContractConfigTracker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ContractConfigTracker",
	HandlerType: (*ContractConfigTrackerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LatestConfigDetails",
			Handler:    _ContractConfigTracker_LatestConfigDetails_Handler,
		},
		{
			MethodName: "LatestConfig",
			Handler:    _ContractConfigTracker_LatestConfig_Handler,
		},
		{
			MethodName: "LatestBlockHeight",
			Handler:    _ContractConfigTracker_LatestBlockHeight_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

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

View Source 
var ContractReader_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ContractReader",
	HandlerType: (*ContractReaderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetLatestValue",
			Handler:    _ContractReader_GetLatestValue_Handler,
		},
		{
			MethodName: "BatchGetLatestValues",
			Handler:    _ContractReader_BatchGetLatestValues_Handler,
		},
		{
			MethodName: "QueryKey",
			Handler:    _ContractReader_QueryKey_Handler,
		},
		{
			MethodName: "Bind",
			Handler:    _ContractReader_Bind_Handler,
		},
		{
			MethodName: "Unbind",
			Handler:    _ContractReader_Unbind_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "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: "relayer.proto",
}

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

View Source 
var DataSource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.DataSource",
	HandlerType: (*DataSourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Observe",
			Handler:    _DataSource_Observe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "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: "median.proto",
}

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

View Source 
var File_chain_writer_proto protoreflect.FileDescriptor
View Source 
var File_codec_proto protoreflect.FileDescriptor
View Source 
var File_contract_reader_proto protoreflect.FileDescriptor
View Source 
var File_keyvalue_store_proto protoreflect.FileDescriptor
View Source 
var File_loop_internal_pb_capabilities_registry_proto protoreflect.FileDescriptor
View Source 
var File_median_datasource_proto protoreflect.FileDescriptor
View Source 
var File_median_proto protoreflect.FileDescriptor
View Source 
var File_pipeline_runner_proto protoreflect.FileDescriptor
View Source 
var File_relayer_proto protoreflect.FileDescriptor
View Source 
var File_reporting_plugin_service_proto protoreflect.FileDescriptor
View Source 
var File_reporting_proto protoreflect.FileDescriptor
View Source 
var File_telemetry_proto protoreflect.FileDescriptor
View Source 
var 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,
		},
	},
	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,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

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

View Source 
var MedianContract_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.MedianContract",
	HandlerType: (*MedianContractServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LatestTransmissionDetails",
			Handler:    _MedianContract_LatestTransmissionDetails_Handler,
		},
		{
			MethodName: "LatestRoundRequested",
			Handler:    _MedianContract_LatestRoundRequested_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "median.proto",
}

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

View Source 
var OffchainConfigDigester_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.OffchainConfigDigester",
	HandlerType: (*OffchainConfigDigesterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ConfigDigest",
			Handler:    _OffchainConfigDigester_ConfigDigest_Handler,
		},
		{
			MethodName: "ConfigDigestPrefix",
			Handler:    _OffchainConfigDigester_ConfigDigestPrefix_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

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

View Source 
var OnchainConfigCodec_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.OnchainConfigCodec",
	HandlerType: (*OnchainConfigCodecServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Encode",
			Handler:    _OnchainConfigCodec_Encode_Handler,
		},
		{
			MethodName: "Decode",
			Handler:    _OnchainConfigCodec_Decode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "median.proto",
}

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

View Source 
var PipelineRunnerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.PipelineRunnerService",
	HandlerType: (*PipelineRunnerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecuteRun",
			Handler:    _PipelineRunnerService_ExecuteRun_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pipeline_runner.proto",
}

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

View Source 
var PluginMedian_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.PluginMedian",
	HandlerType: (*PluginMedianServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewMedianFactory",
			Handler:    _PluginMedian_NewMedianFactory_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "median.proto",
}

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

View Source 
var PluginRelayer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.PluginRelayer",
	HandlerType: (*PluginRelayerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewRelayer",
			Handler:    _PluginRelayer_NewRelayer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

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

View Source 
var Relayer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.Relayer",
	HandlerType: (*RelayerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewChainWriter",
			Handler:    _Relayer_NewChainWriter_Handler,
		},
		{
			MethodName: "NewContractReader",
			Handler:    _Relayer_NewContractReader_Handler,
		},
		{
			MethodName: "NewConfigProvider",
			Handler:    _Relayer_NewConfigProvider_Handler,
		},
		{
			MethodName: "NewPluginProvider",
			Handler:    _Relayer_NewPluginProvider_Handler,
		},
		{
			MethodName: "LatestHead",
			Handler:    _Relayer_LatestHead_Handler,
		},
		{
			MethodName: "GetChainStatus",
			Handler:    _Relayer_GetChainStatus_Handler,
		},
		{
			MethodName: "ListNodeStatuses",
			Handler:    _Relayer_ListNodeStatuses_Handler,
		},
		{
			MethodName: "Transact",
			Handler:    _Relayer_Transact_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

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

View Source 
var ReportCodec_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ReportCodec",
	HandlerType: (*ReportCodecServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BuildReport",
			Handler:    _ReportCodec_BuildReport_Handler,
		},
		{
			MethodName: "MedianFromReport",
			Handler:    _ReportCodec_MedianFromReport_Handler,
		},
		{
			MethodName: "MaxReportLength",
			Handler:    _ReportCodec_MaxReportLength_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "median.proto",
}

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

View Source 
var ReportingPluginFactory_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ReportingPluginFactory",
	HandlerType: (*ReportingPluginFactoryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewReportingPlugin",
			Handler:    _ReportingPluginFactory_NewReportingPlugin_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "reporting.proto",
}

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

View Source 
var ReportingPluginService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.ReportingPluginService",
	HandlerType: (*ReportingPluginServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewReportingPluginFactory",
			Handler:    _ReportingPluginService_NewReportingPluginFactory_Handler,
		},
		{
			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: "reporting.proto",
}

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

View Source 
var Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Name",
			Handler:    _Service_Name_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _Service_Close_Handler,
		},
		{
			MethodName: "Ready",
			Handler:    _Service_Ready_Handler,
		},
		{
			MethodName: "HealthReport",
			Handler:    _Service_HealthReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "relayer.proto",
}

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

View Source 
var Telemetry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.Telemetry",
	HandlerType: (*TelemetryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _Telemetry_Send_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "telemetry.proto",
}

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

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 RegisterChainWriterServer 

func RegisterChainWriterServer(s grpc.ServiceRegistrar, srv ChainWriterServer)

func RegisterCodecServer 

func RegisterCodecServer(s grpc.ServiceRegistrar, srv CodecServer)

func RegisterContractConfigTrackerServer 

func RegisterContractConfigTrackerServer(s grpc.ServiceRegistrar, srv ContractConfigTrackerServer)

func RegisterContractReaderServer 

func RegisterContractReaderServer(s grpc.ServiceRegistrar, srv ContractReaderServer)

func RegisterContractTransmitterServer 

func RegisterContractTransmitterServer(s grpc.ServiceRegistrar, srv ContractTransmitterServer)

func RegisterDataSourceServer 

func RegisterDataSourceServer(s grpc.ServiceRegistrar, srv DataSourceServer)

func RegisterErrorLogServer 

func RegisterErrorLogServer(s grpc.ServiceRegistrar, srv ErrorLogServer)

func 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/goplugin/plugin-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 And 

type And struct {
	Expr []*Expression `protobuf:"bytes,1,rep,name=expr,proto3" json:"expr,omitempty"`
	// contains filtered or unexported fields
}

func (*And) Descriptor deprecated 

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

Deprecated: Use And.ProtoReflect.Descriptor instead.

func (*And) GetExpr 

func (x *And) GetExpr() []*Expression

func (*And) ProtoMessage 

func (*And) ProtoMessage()

func (*And) ProtoReflect 

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

func (*And) Reset 

func (x *And) Reset()

func (*And) String 

func (x *And) 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/goplugin/plugin-libocr/offchainreporting2plus/types.AttributedObservation

func (*AttributedObservation) Descriptor deprecated 

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

Deprecated: Use AttributedObservation.ProtoReflect.Descriptor instead.

func (*AttributedObservation) GetObservation 

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

func (*AttributedObservation) GetObserver 

func (x *AttributedObservation) GetObserver() uint32

func (*AttributedObservation) ProtoMessage 

func (*AttributedObservation) ProtoMessage()

func (*AttributedObservation) ProtoReflect 

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

func (*AttributedObservation) Reset 

func (x *AttributedObservation) Reset()

func (*AttributedObservation) String 

func (x *AttributedObservation) String() string

type 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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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    *VersionedBytes `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	ReturnVal *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/goplugin/plugin-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() *VersionedBytes

func (*BatchRead) GetReadName 

func (x *BatchRead) GetReadName() string

func (*BatchRead) GetReturnVal 

func (x *BatchRead) GetReturnVal() *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 *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/goplugin/plugin-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() *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/goplugin/plugin-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 Block 

type Block struct {
	BlockNumber string             `protobuf:"bytes,1,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	Operator    ComparisonOperator `protobuf:"varint,2,opt,name=operator,proto3,enum=loop.ComparisonOperator" json:"operator,omitempty"`
	// contains filtered or unexported fields
}

func (*Block) Descriptor deprecated 

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

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetBlockNumber 

func (x *Block) GetBlockNumber() string

func (*Block) GetOperator 

func (x *Block) GetOperator() ComparisonOperator

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) ProtoReflect 

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

func (*Block) Reset 

func (x *Block) Reset()

func (*Block) String 

func (x *Block) String() string

type BooleanExpression 

type BooleanExpression struct {
	BooleanOperator BooleanOperator `` /* 133-byte string literal not displayed */
	Expression      []*Expression   `protobuf:"bytes,2,rep,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*BooleanExpression) Descriptor deprecated 

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

Deprecated: Use BooleanExpression.ProtoReflect.Descriptor instead.

func (*BooleanExpression) GetBooleanOperator 

func (x *BooleanExpression) GetBooleanOperator() BooleanOperator

func (*BooleanExpression) GetExpression 

func (x *BooleanExpression) GetExpression() []*Expression

func (*BooleanExpression) ProtoMessage 

func (*BooleanExpression) ProtoMessage()

func (*BooleanExpression) ProtoReflect 

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

func (*BooleanExpression) Reset 

func (x *BooleanExpression) Reset()

func (*BooleanExpression) String 

func (x *BooleanExpression) String() string

type BooleanOperator 

type BooleanOperator int32
const (
	BooleanOperator_AND BooleanOperator = 0
	BooleanOperator_OR  BooleanOperator = 1
)

func (BooleanOperator) Descriptor 

func (BooleanOperator) Descriptor() protoreflect.EnumDescriptor

func (BooleanOperator) Enum 

func (x BooleanOperator) Enum() *BooleanOperator

func (BooleanOperator) EnumDescriptor deprecated 

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

Deprecated: Use BooleanOperator.Descriptor instead.

func (BooleanOperator) Number 

func (x BooleanOperator) Number() protoreflect.EnumNumber

func (BooleanOperator) String 

func (x BooleanOperator) String() string

func (BooleanOperator) Type 

func (BooleanOperator) Type() protoreflect.EnumType

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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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) (*LocalNodeReply, error)
	ConfigForCapability(ctx context.Context, in *ConfigForCapabilityRequest, opts ...grpc.CallOption) (*ConfigForCapabilityReply, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
	GetTrigger(ctx context.Context, in *GetTriggerRequest, opts ...grpc.CallOption) (*GetTriggerReply, error)
	GetAction(ctx context.Context, in *GetActionRequest, opts ...grpc.CallOption) (*GetActionReply, error)
	GetConsensus(ctx context.Context, in *GetConsensusRequest, opts ...grpc.CallOption) (*GetConsensusReply, error)
	GetTarget(ctx context.Context, in *GetTargetRequest, opts ...grpc.CallOption) (*GetTargetReply, 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)
}

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) (*LocalNodeReply, error)
	ConfigForCapability(context.Context, *ConfigForCapabilityRequest) (*ConfigForCapabilityReply, error)
	Get(context.Context, *GetRequest) (*GetReply, error)
	GetTrigger(context.Context, *GetTriggerRequest) (*GetTriggerReply, error)
	GetAction(context.Context, *GetActionRequest) (*GetActionReply, error)
	GetConsensus(context.Context, *GetConsensusRequest) (*GetConsensusReply, error)
	GetTarget(context.Context, *GetTargetRequest) (*GetTargetReply, error)
	List(context.Context, *emptypb.Empty) (*ListReply, error)
	Add(context.Context, *AddRequest) (*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 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/goplugin/plugin-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 ChainWriterClient 

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

ChainWriterClient is the client API for ChainWriter 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 NewChainWriterClient 

func NewChainWriterClient(cc grpc.ClientConnInterface) ChainWriterClient

type ChainWriterServer 

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

ChainWriterServer is the server API for ChainWriter service. All implementations must embed UnimplementedChainWriterServer for forward compatibility

type CodecClient 

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

CodecClient is the client API for Codec service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCodecClient 

func NewCodecClient(cc grpc.ClientConnInterface) CodecClient

type CodecServer 

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

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

type Comparator 

type Comparator struct {
	Name             string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ValueComparators []*ValueComparator `protobuf:"bytes,2,rep,name=value_comparators,json=valueComparators,proto3" json:"value_comparators,omitempty"`
	// contains filtered or unexported fields
}

func (*Comparator) Descriptor deprecated 

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

Deprecated: Use Comparator.ProtoReflect.Descriptor instead.

func (*Comparator) GetName 

func (x *Comparator) GetName() string

func (*Comparator) GetValueComparators 

func (x *Comparator) GetValueComparators() []*ValueComparator

func (*Comparator) ProtoMessage 

func (*Comparator) ProtoMessage()

func (*Comparator) ProtoReflect 

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

func (*Comparator) Reset 

func (x *Comparator) Reset()

func (*Comparator) String 

func (x *Comparator) String() string

type ComparisonOperator 

type ComparisonOperator int32
const (
	ComparisonOperator_Eq  ComparisonOperator = 0
	ComparisonOperator_Neq ComparisonOperator = 1
	ComparisonOperator_Gt  ComparisonOperator = 2
	ComparisonOperator_Lt  ComparisonOperator = 3
	ComparisonOperator_Gte ComparisonOperator = 4
	ComparisonOperator_Lte ComparisonOperator = 5
)

func (ComparisonOperator) Descriptor 

func (ComparisonOperator) Descriptor() protoreflect.EnumDescriptor

func (ComparisonOperator) Enum 

func (x ComparisonOperator) Enum() *ComparisonOperator

func (ComparisonOperator) EnumDescriptor deprecated 

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

Deprecated: Use ComparisonOperator.Descriptor instead.

func (ComparisonOperator) Number 

func (x ComparisonOperator) Number() protoreflect.EnumNumber

func (ComparisonOperator) String 

func (x ComparisonOperator) String() string

func (ComparisonOperator) Type 

func (ComparisonOperator) Type() protoreflect.EnumType

type Confidence 

type Confidence int32
const (
	Confidence_Unconfirmed Confidence = 0
	Confidence_Finalized   Confidence = 1
)

func (Confidence) Descriptor 

func (Confidence) Descriptor() protoreflect.EnumDescriptor

func (Confidence) Enum 

func (x Confidence) Enum() *Confidence

func (Confidence) EnumDescriptor deprecated 

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

Deprecated: Use Confidence.Descriptor instead.

func (Confidence) Number 

func (x Confidence) Number() protoreflect.EnumNumber

func (Confidence) String 

func (x Confidence) String() string

func (Confidence) Type 

func (Confidence) Type() protoreflect.EnumType

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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 

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 

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

Deprecated: Use ConfigForCapabilityReply.ProtoReflect.Descriptor instead.

func (*ConfigForCapabilityReply) GetCapabilityConfig 

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

func (*ConfigForCapabilityReply) ProtoMessage 

func (*ConfigForCapabilityReply) ProtoMessage()

func (*ConfigForCapabilityReply) ProtoReflect 

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

func (*ConfigForCapabilityReply) Reset 

func (x *ConfigForCapabilityReply) Reset()

func (*ConfigForCapabilityReply) String 

func (x *ConfigForCapabilityReply) String() string

type ConfigForCapabilityRequest 

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 

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

Deprecated: Use ConfigForCapabilityRequest.ProtoReflect.Descriptor instead.

func (*ConfigForCapabilityRequest) GetCapabilityID 

func (x *ConfigForCapabilityRequest) GetCapabilityID() string

func (*ConfigForCapabilityRequest) GetDonID 

func (x *ConfigForCapabilityRequest) GetDonID() uint32

func (*ConfigForCapabilityRequest) ProtoMessage 

func (*ConfigForCapabilityRequest) ProtoMessage()

func (*ConfigForCapabilityRequest) ProtoReflect 

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

func (*ConfigForCapabilityRequest) Reset 

func (x *ConfigForCapabilityRequest) Reset()

func (*ConfigForCapabilityRequest) String 

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/goplugin/plugin-common/pkg/types.ContractReader.BatchGetLatestValuesRequest.

func (*ContractBatch) Descriptor deprecated 

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

Deprecated: Use ContractBatch.ProtoReflect.Descriptor instead.

func (*ContractBatch) GetContract 

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/goplugin/plugin-common/pkg/types.ContractReader.BatchGetLatestValues.

func (*ContractBatchResult) Descriptor deprecated 

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

Deprecated: Use ContractBatchResult.ProtoReflect.Descriptor instead.

func (*ContractBatchResult) GetContract 

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/goplugin/plugin-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 ContractReaderClient 

type ContractReaderClient interface {
	GetLatestValue(ctx context.Context, in *GetLatestValueRequest, opts ...grpc.CallOption) (*GetLatestValueReply, error)
	BatchGetLatestValues(ctx context.Context, in *BatchGetLatestValuesRequest, opts ...grpc.CallOption) (*BatchGetLatestValuesReply, error)
	QueryKey(ctx context.Context, in *QueryKeyRequest, opts ...grpc.CallOption) (*QueryKeyReply, 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 

func NewContractReaderClient(cc grpc.ClientConnInterface) ContractReaderClient

type ContractReaderServer 

type ContractReaderServer interface {
	GetLatestValue(context.Context, *GetLatestValueRequest) (*GetLatestValueReply, error)
	BatchGetLatestValues(context.Context, *BatchGetLatestValuesRequest) (*BatchGetLatestValuesReply, error)
	QueryKey(context.Context, *QueryKeyRequest) (*QueryKeyReply, 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 CursorDirection 

type CursorDirection int32

CursorDirection defines the direction for cursor-based data fetching. 

const (
	CursorDirection_Preceding CursorDirection = 0
	CursorDirection_Following CursorDirection = 1
)

func (CursorDirection) Descriptor 

func (CursorDirection) Descriptor() protoreflect.EnumDescriptor

func (CursorDirection) Enum 

func (x CursorDirection) Enum() *CursorDirection

func (CursorDirection) EnumDescriptor deprecated 

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

Deprecated: Use CursorDirection.Descriptor instead.

func (CursorDirection) Number 

func (x CursorDirection) Number() protoreflect.EnumNumber

func (CursorDirection) String 

func (x CursorDirection) String() string

func (CursorDirection) Type 

func (CursorDirection) Type() protoreflect.EnumType

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

DON has arguments for github.com/goplugin/plugin-common/pkg/capabilities.DON.

func (*DON) Descriptor deprecated 

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

Deprecated: Use DON.ProtoReflect.Descriptor instead.

func (*DON) GetConfigVersion 

func (x *DON) GetConfigVersion() uint32

func (*DON) GetF 

func (x *DON) GetF() uint32

func (*DON) GetId 

func (x *DON) GetId() uint32

func (*DON) GetMembers 

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

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 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/goplugin/plugin-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/goplugin/plugin-libocr/offchainreporting2/reportingplugin/median.OnchainConfigCodec.Decode.

func (*DecodeRequest) Descriptor deprecated 

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

Deprecated: Use DecodeRequest.ProtoReflect.Descriptor instead.

func (*DecodeRequest) GetEncoded 

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

func (*DecodeRequest) ProtoMessage 

func (*DecodeRequest) ProtoMessage()

func (*DecodeRequest) ProtoReflect 

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

func (*DecodeRequest) Reset 

func (x *DecodeRequest) Reset()

func (*DecodeRequest) String 

func (x *DecodeRequest) String() string

type EncodeReply 

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

EncodeReply has return arguments for github.com/goplugin/plugin-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/goplugin/plugin-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
)

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 Expression 

type Expression struct {

	// Types that are assignable to Evaluator:
	//
	//	*Expression_Primitive
	//	*Expression_BooleanExpression
	Evaluator isExpression_Evaluator `protobuf_oneof:"evaluator"`
	// contains filtered or unexported fields
}

Expression encapsulates a single unit of filtering logic, which can be a common blockchain primitive or a composite of boolean expressions. This allows for both simple and more complex nested expressions.

func (*Expression) Descriptor deprecated 

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

Deprecated: Use Expression.ProtoReflect.Descriptor instead.

func (*Expression) GetBooleanExpression 

func (x *Expression) GetBooleanExpression() *BooleanExpression

func (*Expression) GetEvaluator 

func (m *Expression) GetEvaluator() isExpression_Evaluator

func (*Expression) GetPrimitive 

func (x *Expression) GetPrimitive() *Primitive

func (*Expression) ProtoMessage 

func (*Expression) ProtoMessage()

func (*Expression) ProtoReflect 

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

func (*Expression) Reset 

func (x *Expression) Reset()

func (*Expression) String 

func (x *Expression) String() string

type Expression_BooleanExpression 

type Expression_BooleanExpression struct {
	BooleanExpression *BooleanExpression `protobuf:"bytes,2,opt,name=boolean_expression,json=booleanExpression,proto3,oneof"`
}

type Expression_Primitive 

type Expression_Primitive struct {
	Primitive *Primitive `protobuf:"bytes,1,opt,name=primitive,proto3,oneof"`
}

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/goplugin/plugin-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 GetActionReply 

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

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

func (*GetActionReply) Descriptor deprecated 

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

Deprecated: Use GetActionReply.ProtoReflect.Descriptor instead.

func (*GetActionReply) GetCapabilityID 

func (x *GetActionReply) GetCapabilityID() uint32

func (*GetActionReply) ProtoMessage 

func (*GetActionReply) ProtoMessage()

func (*GetActionReply) ProtoReflect 

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

func (*GetActionReply) Reset 

func (x *GetActionReply) Reset()

func (*GetActionReply) String 

func (x *GetActionReply) String() string

type GetActionRequest 

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

GetAction has arguments for github.com/goplugin/plugin-common/pkg/types.CapabilitiesRegistry.GetAction.

func (*GetActionRequest) Descriptor deprecated 

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

Deprecated: Use GetActionRequest.ProtoReflect.Descriptor instead.

func (*GetActionRequest) GetId 

func (x *GetActionRequest) GetId() string

func (*GetActionRequest) ProtoMessage 

func (*GetActionRequest) ProtoMessage()

func (*GetActionRequest) ProtoReflect 

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

func (*GetActionRequest) Reset 

func (x *GetActionRequest) Reset()

func (*GetActionRequest) String 

func (x *GetActionRequest) 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/goplugin/plugin-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 GetConsensusReply 

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

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

func (*GetConsensusReply) Descriptor deprecated 

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

Deprecated: Use GetConsensusReply.ProtoReflect.Descriptor instead.

func (*GetConsensusReply) GetCapabilityID 

func (x *GetConsensusReply) GetCapabilityID() uint32

func (*GetConsensusReply) ProtoMessage 

func (*GetConsensusReply) ProtoMessage()

func (*GetConsensusReply) ProtoReflect 

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

func (*GetConsensusReply) Reset 

func (x *GetConsensusReply) Reset()

func (*GetConsensusReply) String 

func (x *GetConsensusReply) String() string

type GetConsensusRequest 

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

GetConsensus has arguments for github.com/goplugin/plugin-common/pkg/types.CapabilitiesRegistry.GetConsensus.

func (*GetConsensusRequest) Descriptor deprecated 

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

Deprecated: Use GetConsensusRequest.ProtoReflect.Descriptor instead.

func (*GetConsensusRequest) GetId 

func (x *GetConsensusRequest) GetId() string

func (*GetConsensusRequest) ProtoMessage 

func (*GetConsensusRequest) ProtoMessage()

func (*GetConsensusRequest) ProtoReflect 

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

func (*GetConsensusRequest) Reset 

func (x *GetConsensusRequest) Reset()

func (*GetConsensusRequest) String 

func (x *GetConsensusRequest) String() string

type GetDecodingRequest 

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

func (*GetDecodingRequest) Descriptor deprecated 

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

Deprecated: Use GetDecodingRequest.ProtoReflect.Descriptor instead.

func (*GetDecodingRequest) GetEncoded 

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

func (*GetDecodingRequest) GetItemType 

func (x *GetDecodingRequest) GetItemType() string

func (*GetDecodingRequest) GetWireEncodingVersion 

func (x *GetDecodingRequest) GetWireEncodingVersion() uint32

func (*GetDecodingRequest) ProtoMessage 

func (*GetDecodingRequest) ProtoMessage()

func (*GetDecodingRequest) ProtoReflect 

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

func (*GetDecodingRequest) Reset 

func (x *GetDecodingRequest) Reset()

func (*GetDecodingRequest) String 

func (x *GetDecodingRequest) String() string

type GetDecodingResponse 

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

func (*GetDecodingResponse) Descriptor deprecated 

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

Deprecated: Use GetDecodingResponse.ProtoReflect.Descriptor instead.

func (*GetDecodingResponse) GetRetVal 

func (x *GetDecodingResponse) GetRetVal() *VersionedBytes

func (*GetDecodingResponse) ProtoMessage 

func (*GetDecodingResponse) ProtoMessage()

func (*GetDecodingResponse) ProtoReflect 

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

func (*GetDecodingResponse) Reset 

func (x *GetDecodingResponse) Reset()

func (*GetDecodingResponse) String 

func (x *GetDecodingResponse) String() string

type GetEncodingRequest 

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

func (*GetEncodingRequest) Descriptor deprecated 

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

Deprecated: Use GetEncodingRequest.ProtoReflect.Descriptor instead.

func (*GetEncodingRequest) GetItemType 

func (x *GetEncodingRequest) GetItemType() string

func (*GetEncodingRequest) GetParams 

func (x *GetEncodingRequest) GetParams() *VersionedBytes

func (*GetEncodingRequest) ProtoMessage 

func (*GetEncodingRequest) ProtoMessage()

func (*GetEncodingRequest) ProtoReflect 

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

func (*GetEncodingRequest) Reset 

func (x *GetEncodingRequest) Reset()

func (*GetEncodingRequest) String 

func (x *GetEncodingRequest) String() string

type GetEncodingResponse 

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

func (*GetEncodingResponse) Descriptor deprecated 

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

Deprecated: Use GetEncodingResponse.ProtoReflect.Descriptor instead.

func (*GetEncodingResponse) GetRetVal 

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

func (*GetEncodingResponse) ProtoMessage 

func (*GetEncodingResponse) ProtoMessage()

func (*GetEncodingResponse) ProtoReflect 

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

func (*GetEncodingResponse) Reset 

func (x *GetEncodingResponse) Reset()

func (*GetEncodingResponse) String 

func (x *GetEncodingResponse) String() string

type 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/goplugin/plugin-common/pkg/types.ChainWriter.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 *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/goplugin/plugin-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() *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     Confidence      `protobuf:"varint,2,opt,name=confidence,proto3,enum=loop.Confidence" json:"confidence,omitempty"`
	Params         *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/goplugin/plugin-common/pkg/types.ContractReader.GetLatestValue.

func (*GetLatestValueRequest) Descriptor deprecated 

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

Deprecated: Use GetLatestValueRequest.ProtoReflect.Descriptor instead.

func (*GetLatestValueRequest) GetAsValueType 

func (x *GetLatestValueRequest) GetAsValueType() bool

func (*GetLatestValueRequest) GetConfidence 

func (x *GetLatestValueRequest) GetConfidence() Confidence

func (*GetLatestValueRequest) GetParams 

func (x *GetLatestValueRequest) GetParams() *VersionedBytes

func (*GetLatestValueRequest) GetReadIdentifier 

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 GetMaxSizeRequest 

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

func (*GetMaxSizeRequest) Descriptor deprecated 

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

Deprecated: Use GetMaxSizeRequest.ProtoReflect.Descriptor instead.

func (*GetMaxSizeRequest) GetForEncoding 

func (x *GetMaxSizeRequest) GetForEncoding() bool

func (*GetMaxSizeRequest) GetItemType 

func (x *GetMaxSizeRequest) GetItemType() string

func (*GetMaxSizeRequest) GetN 

func (x *GetMaxSizeRequest) GetN() int32

func (*GetMaxSizeRequest) ProtoMessage 

func (*GetMaxSizeRequest) ProtoMessage()

func (*GetMaxSizeRequest) ProtoReflect 

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

func (*GetMaxSizeRequest) Reset 

func (x *GetMaxSizeRequest) Reset()

func (*GetMaxSizeRequest) String 

func (x *GetMaxSizeRequest) String() string

type GetMaxSizeResponse 

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

func (*GetMaxSizeResponse) Descriptor deprecated 

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

Deprecated: Use GetMaxSizeResponse.ProtoReflect.Descriptor instead.

func (*GetMaxSizeResponse) GetSizeInBytes 

func (x *GetMaxSizeResponse) GetSizeInBytes() int32

func (*GetMaxSizeResponse) ProtoMessage 

func (*GetMaxSizeResponse) ProtoMessage()

func (*GetMaxSizeResponse) ProtoReflect 

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

func (*GetMaxSizeResponse) Reset 

func (x *GetMaxSizeResponse) Reset()

func (*GetMaxSizeResponse) String 

func (x *GetMaxSizeResponse) String() string

type 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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 GetTargetRequest 

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

GetTarget has arguments for github.com/goplugin/plugin-common/pkg/types.CapabilitiesRegistry.GetTarget.

func (*GetTargetRequest) Descriptor deprecated 

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

Deprecated: Use GetTargetRequest.ProtoReflect.Descriptor instead.

func (*GetTargetRequest) GetId 

func (x *GetTargetRequest) GetId() string

func (*GetTargetRequest) ProtoMessage 

func (*GetTargetRequest) ProtoMessage()

func (*GetTargetRequest) ProtoReflect 

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

func (*GetTargetRequest) Reset 

func (x *GetTargetRequest) Reset()

func (*GetTargetRequest) String 

func (x *GetTargetRequest) String() string

type GetTransactionStatusReply 

type GetTransactionStatusReply struct {
	TransactionStatus TransactionStatus `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetTransactionStatusReply has return arguments for github.com/goplugin/plugin-common/pkg/types.ChainWriter.GetTransactionStatus.

func (*GetTransactionStatusReply) Descriptor deprecated 

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

Deprecated: Use GetTransactionStatusReply.ProtoReflect.Descriptor instead.

func (*GetTransactionStatusReply) GetTransactionStatus 

func (x *GetTransactionStatusReply) GetTransactionStatus() TransactionStatus

func (*GetTransactionStatusReply) ProtoMessage 

func (*GetTransactionStatusReply) ProtoMessage()

func (*GetTransactionStatusReply) ProtoReflect 

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

func (*GetTransactionStatusReply) Reset 

func (x *GetTransactionStatusReply) Reset()

func (*GetTransactionStatusReply) String 

func (x *GetTransactionStatusReply) String() string

type GetTransactionStatusRequest 

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

GetTransactionStatusRequest has arguments for github.com/goplugin/plugin-common/pkg/types.ChainWriter.GetTransactionStatus.

func (*GetTransactionStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetTransactionStatusRequest.ProtoReflect.Descriptor instead.

func (*GetTransactionStatusRequest) GetTransactionId 

func (x *GetTransactionStatusRequest) GetTransactionId() string

func (*GetTransactionStatusRequest) ProtoMessage 

func (*GetTransactionStatusRequest) ProtoMessage()

func (*GetTransactionStatusRequest) ProtoReflect 

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

func (*GetTransactionStatusRequest) Reset 

func (x *GetTransactionStatusRequest) Reset()

func (*GetTransactionStatusRequest) String 

func (x *GetTransactionStatusRequest) 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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 

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 `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

HealthReportReply has return arguments for github.com/goplugin/plugin-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)
}

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)
	// 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)
}

KeystoreClient is the client API for Keystore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewKeystoreClient 

func NewKeystoreClient(cc grpc.ClientConnInterface) KeystoreClient

type KeystoreServer 

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

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

type LatestBlockHeightReply 

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

LatestBlockHeightReply has return arguments for github.com/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 

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/goplugin/plugin-common/pkg/loop.Relayer.LatestHeadReply.

func (*LatestHeadReply) Descriptor deprecated 

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

Deprecated: Use LatestHeadReply.ProtoReflect.Descriptor instead.

func (*LatestHeadReply) GetHead 

func (x *LatestHeadReply) GetHead() *Head

func (*LatestHeadReply) ProtoMessage 

func (*LatestHeadReply) ProtoMessage()

func (*LatestHeadReply) ProtoReflect 

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

func (*LatestHeadReply) Reset 

func (x *LatestHeadReply) Reset()

func (*LatestHeadReply) String 

func (x *LatestHeadReply) String() string

type LatestHeadRequest 

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

func (*LatestHeadRequest) Descriptor deprecated 

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

Deprecated: Use LatestHeadRequest.ProtoReflect.Descriptor instead.

func (*LatestHeadRequest) ProtoMessage 

func (*LatestHeadRequest) ProtoMessage()

func (*LatestHeadRequest) ProtoReflect 

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

func (*LatestHeadRequest) Reset 

func (x *LatestHeadRequest) Reset()

func (*LatestHeadRequest) String 

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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 Limit 

type Limit struct {
	Cursor    *string          `protobuf:"bytes,1,opt,name=cursor,proto3,oneof" json:"cursor,omitempty"`
	Direction *CursorDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=loop.CursorDirection,oneof" json:"direction,omitempty"`
	Count     uint64           `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

Limit defines a structure for limiting the results of a query, including optional cursor-based pagination.

func (*Limit) Descriptor deprecated 

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

Deprecated: Use Limit.ProtoReflect.Descriptor instead.

func (*Limit) GetCount 

func (x *Limit) GetCount() uint64

func (*Limit) GetCursor 

func (x *Limit) GetCursor() string

func (*Limit) GetDirection 

func (x *Limit) GetDirection() CursorDirection

func (*Limit) ProtoMessage 

func (*Limit) ProtoMessage()

func (*Limit) ProtoReflect 

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

func (*Limit) Reset 

func (x *Limit) Reset()

func (*Limit) String 

func (x *Limit) String() string

type LimitAndSort 

type LimitAndSort struct {
	SortBy []*SortBy `protobuf:"bytes,1,rep,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"` // A list of sorting criteria.
	Limit  *Limit    `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`                 // Pagination limit and direction.
	// contains filtered or unexported fields
}

LimitAndSort combines sorting criteria with pagination limits.

func (*LimitAndSort) Descriptor deprecated 

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

Deprecated: Use LimitAndSort.ProtoReflect.Descriptor instead.

func (*LimitAndSort) GetLimit 

func (x *LimitAndSort) GetLimit() *Limit

func (*LimitAndSort) GetSortBy 

func (x *LimitAndSort) GetSortBy() []*SortBy

func (*LimitAndSort) ProtoMessage 

func (*LimitAndSort) ProtoMessage()

func (*LimitAndSort) ProtoReflect 

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

func (*LimitAndSort) Reset 

func (x *LimitAndSort) Reset()

func (*LimitAndSort) String 

func (x *LimitAndSort) 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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 LocalNodeReply 

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

LocalNode has arguments for github.com/goplugin/plugin-common/pkg/types.CapabilitiesRegistry.LocalNode.

func (*LocalNodeReply) Descriptor deprecated 

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

Deprecated: Use LocalNodeReply.ProtoReflect.Descriptor instead.

func (*LocalNodeReply) GetCapabilityDONs 

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

func (*LocalNodeReply) GetPeerID 

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

func (*LocalNodeReply) GetWorkflowDON 

func (x *LocalNodeReply) GetWorkflowDON() *DON

func (*LocalNodeReply) ProtoMessage 

func (*LocalNodeReply) ProtoMessage()

func (*LocalNodeReply) ProtoReflect 

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

func (*LocalNodeReply) Reset 

func (x *LocalNodeReply) Reset()

func (*LocalNodeReply) String 

func (x *LocalNodeReply) 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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 NewChainWriterReply 

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

NewChainWriterReply has return arguments for github.com/goplugin/plugin-common/pkg/loop.Relayer.NewChainWriter.

func (*NewChainWriterReply) Descriptor deprecated 

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

Deprecated: Use NewChainWriterReply.ProtoReflect.Descriptor instead.

func (*NewChainWriterReply) GetChainWriterID 

func (x *NewChainWriterReply) GetChainWriterID() uint32

func (*NewChainWriterReply) ProtoMessage 

func (*NewChainWriterReply) ProtoMessage()

func (*NewChainWriterReply) ProtoReflect 

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

func (*NewChainWriterReply) Reset 

func (x *NewChainWriterReply) Reset()

func (*NewChainWriterReply) String 

func (x *NewChainWriterReply) String() string

type NewChainWriterRequest 

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

NewChainWriterReply has return arguments for github.com/goplugin/plugin-common/pkg/loop.Relayer.NewChainWriter.

func (*NewChainWriterRequest) Descriptor deprecated 

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

Deprecated: Use NewChainWriterRequest.ProtoReflect.Descriptor instead.

func (*NewChainWriterRequest) GetChainWriterConfig 

func (x *NewChainWriterRequest) GetChainWriterConfig() []byte

func (*NewChainWriterRequest) ProtoMessage 

func (*NewChainWriterRequest) ProtoMessage()

func (*NewChainWriterRequest) ProtoReflect 

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

func (*NewChainWriterRequest) Reset 

func (x *NewChainWriterRequest) Reset()

func (*NewChainWriterRequest) String 

func (x *NewChainWriterRequest) 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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 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/goplugin/plugin-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"`
	// contains filtered or unexported fields
}

NewMedianFactoryRequest has arguments for github.com/goplugin/plugin-common/pkg/loop.Relayer.NewMedianFactory.

func (*NewMedianFactoryRequest) Descriptor deprecated 

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

Deprecated: Use NewMedianFactoryRequest.ProtoReflect.Descriptor instead.

func (*NewMedianFactoryRequest) GetContractID 

func (x *NewMedianFactoryRequest) GetContractID() string

func (*NewMedianFactoryRequest) GetDataSourceID 

func (x *NewMedianFactoryRequest) GetDataSourceID() uint32

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/goplugin/plugin-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/goplugin/plugin-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"`
	// 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) 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/goplugin/plugin-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/goplugin/plugin-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 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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 Or 

type Or struct {
	Expr []*Expression `protobuf:"bytes,1,rep,name=expr,proto3" json:"expr,omitempty"`
	// contains filtered or unexported fields
}

func (*Or) Descriptor deprecated 

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

Deprecated: Use Or.ProtoReflect.Descriptor instead.

func (*Or) GetExpr 

func (x *Or) GetExpr() []*Expression

func (*Or) ProtoMessage 

func (*Or) ProtoMessage()

func (*Or) ProtoReflect 

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

func (*Or) Reset 

func (x *Or) Reset()

func (*Or) String 

func (x *Or) 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/goplugin/plugin-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/goplugin/plugin-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 Primitive 

type Primitive struct {

	// Types that are assignable to Primitive:
	//
	//	*Primitive_Comparator
	//	*Primitive_Block
	//	*Primitive_Confidence
	//	*Primitive_Timestamp
	//	*Primitive_TxHash
	Primitive isPrimitive_Primitive `protobuf_oneof:"primitive"`
	// contains filtered or unexported fields
}

Primitive defines the basic building blocks for filter conditions based around fundamental blockchain concepts.

func (*Primitive) Descriptor deprecated 

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

Deprecated: Use Primitive.ProtoReflect.Descriptor instead.

func (*Primitive) GetBlock 

func (x *Primitive) GetBlock() *Block

func (*Primitive) GetComparator 

func (x *Primitive) GetComparator() *Comparator

func (*Primitive) GetConfidence 

func (x *Primitive) GetConfidence() Confidence

func (*Primitive) GetPrimitive 

func (m *Primitive) GetPrimitive() isPrimitive_Primitive

func (*Primitive) GetTimestamp 

func (x *Primitive) GetTimestamp() *Timestamp

func (*Primitive) GetTxHash 

func (x *Primitive) GetTxHash() *TxHash

func (*Primitive) ProtoMessage 

func (*Primitive) ProtoMessage()

func (*Primitive) ProtoReflect 

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

func (*Primitive) Reset 

func (x *Primitive) Reset()

func (*Primitive) String 

func (x *Primitive) String() string

type Primitive_Block 

type Primitive_Block struct {
	Block *Block `protobuf:"bytes,2,opt,name=block,proto3,oneof"`
}

type Primitive_Comparator 

type Primitive_Comparator struct {
	Comparator *Comparator `protobuf:"bytes,1,opt,name=comparator,proto3,oneof"`
}

type Primitive_Confidence 

type Primitive_Confidence struct {
	Confidence Confidence `protobuf:"varint,3,opt,name=confidence,proto3,enum=loop.Confidence,oneof"`
}

type Primitive_Timestamp 

type Primitive_Timestamp struct {
	Timestamp *Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3,oneof"`
}

type Primitive_TxHash 

type Primitive_TxHash struct {
	TxHash *TxHash `protobuf:"bytes,5,opt,name=tx_hash,json=txHash,proto3,oneof"`
}

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 []*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() []*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/goplugin/plugin-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 *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/goplugin/plugin-common/pkg/types.ContractReader.QueryKey.

func (*QueryKeyRequest) Descriptor deprecated 

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

Deprecated: Use QueryKeyRequest.ProtoReflect.Descriptor instead.

func (*QueryKeyRequest) GetAsValueType 

func (x *QueryKeyRequest) GetAsValueType() bool

func (*QueryKeyRequest) GetContract 

func (x *QueryKeyRequest) GetContract() *BoundContract

func (*QueryKeyRequest) GetFilter 

func (x *QueryKeyRequest) GetFilter() *QueryKeyFilter

func (*QueryKeyRequest) GetLimitAndSort 

func (x *QueryKeyRequest) GetLimitAndSort() *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 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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 {
	NewChainWriter(ctx context.Context, in *NewChainWriterRequest, opts ...grpc.CallOption) (*NewChainWriterReply, 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)
	LatestHead(ctx context.Context, in *LatestHeadRequest, opts ...grpc.CallOption) (*LatestHeadReply, error)
	GetChainStatus(ctx context.Context, in *GetChainStatusRequest, opts ...grpc.CallOption) (*GetChainStatusReply, error)
	ListNodeStatuses(ctx context.Context, in *ListNodeStatusesRequest, opts ...grpc.CallOption) (*ListNodeStatusesReply, error)
	Transact(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RelayerClient is the client API for Relayer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRelayerClient 

func NewRelayerClient(cc grpc.ClientConnInterface) RelayerClient

type RelayerServer 

type RelayerServer interface {
	NewChainWriter(context.Context, *NewChainWriterRequest) (*NewChainWriterReply, error)
	NewContractReader(context.Context, *NewContractReaderRequest) (*NewContractReaderReply, error)
	NewConfigProvider(context.Context, *NewConfigProviderRequest) (*NewConfigProviderReply, error)
	NewPluginProvider(context.Context, *NewPluginProviderRequest) (*NewPluginProviderReply, error)
	LatestHead(context.Context, *LatestHeadRequest) (*LatestHeadReply, error)
	GetChainStatus(context.Context, *GetChainStatusRequest) (*GetChainStatusReply, error)
	ListNodeStatuses(context.Context, *ListNodeStatusesRequest) (*ListNodeStatusesReply, error)
	Transact(context.Context, *TransactionRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

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

type ReportCodecClient 

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

ReportCodecClient is the client API for ReportCodec service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewReportCodecClient 

func NewReportCodecClient(cc grpc.ClientConnInterface) ReportCodecClient

type ReportCodecServer 

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

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

type ReportContext 

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

ReportContext represents github.com/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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           *VersionedBytes `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Head is gRPC adapter for the Head struct github.com/goplugin/plugin-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() *VersionedBytes

func (*Sequence) GetHead 

func (x *Sequence) GetHead() *Head

func (*Sequence) GetSequenceCursor 

func (x *Sequence) GetSequenceCursor() string

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 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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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/goplugin/plugin-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 SortBy 

type SortBy struct {
	SortType  SortType      `protobuf:"varint,1,opt,name=sort_type,json=sortType,proto3,enum=loop.SortType" json:"sort_type,omitempty"`
	Direction SortDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=loop.SortDirection" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*SortBy) Descriptor deprecated 

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

Deprecated: Use SortBy.ProtoReflect.Descriptor instead.

func (*SortBy) GetDirection 

func (x *SortBy) GetDirection() SortDirection

func (*SortBy) GetSortType 

func (x *SortBy) GetSortType() SortType

func (*SortBy) ProtoMessage 

func (*SortBy) ProtoMessage()

func (*SortBy) ProtoReflect 

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

func (*SortBy) Reset 

func (x *SortBy) Reset()

func (*SortBy) String 

func (x *SortBy) String() string

type SortDirection 

type SortDirection int32
const (
	SortDirection_Asc  SortDirection = 0
	SortDirection_Desc SortDirection = 1
)

func (SortDirection) Descriptor 

func (SortDirection) Descriptor() protoreflect.EnumDescriptor

func (SortDirection) Enum 

func (x SortDirection) Enum() *SortDirection

func (SortDirection) EnumDescriptor deprecated 

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

Deprecated: Use SortDirection.Descriptor instead.

func (SortDirection) Number 

func (x SortDirection) Number() protoreflect.EnumNumber

func (SortDirection) String 

func (x SortDirection) String() string

func (SortDirection) Type 

func (SortDirection) Type() protoreflect.EnumType

type SortType 

type SortType int32
const (
	SortType_SortTimestamp SortType = 0
	SortType_SortBlock     SortType = 1
	SortType_SortSequence  SortType = 2
)

func (SortType) Descriptor 

func (SortType) Descriptor() protoreflect.EnumDescriptor

func (SortType) Enum 

func (x SortType) Enum() *SortType

func (SortType) EnumDescriptor deprecated 

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

Deprecated: Use SortType.Descriptor instead.

func (SortType) Number 

func (x SortType) Number() protoreflect.EnumNumber

func (SortType) String 

func (x SortType) String() string

func (SortType) Type 

func (SortType) Type() protoreflect.EnumType

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        *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() *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 Timestamp 

type Timestamp struct {
	Timestamp uint64             `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Operator  ComparisonOperator `protobuf:"varint,2,opt,name=operator,proto3,enum=loop.ComparisonOperator" json:"operator,omitempty"`
	// contains filtered or unexported fields
}

func (*Timestamp) Descriptor deprecated 

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

Deprecated: Use Timestamp.ProtoReflect.Descriptor instead.

func (*Timestamp) GetOperator 

func (x *Timestamp) GetOperator() ComparisonOperator

func (*Timestamp) GetTimestamp 

func (x *Timestamp) GetTimestamp() uint64

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) ProtoReflect 

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

func (*Timestamp) Reset 

func (x *Timestamp) Reset()

func (*Timestamp) String 

func (x *Timestamp) String() string

type 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 

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/goplugin/plugin-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 TransactionStatus 

type TransactionStatus int32

TransactionStatus is an enum for the status of a transaction. This should always be a 1-1 mapping to: github.com/goplugin/plugin-common/pkg/types.TransactionStatus. 

const (
	TransactionStatus_TRANSACTION_STATUS_UNKNOWN     TransactionStatus = 0
	TransactionStatus_TRANSACTION_STATUS_PENDING     TransactionStatus = 1
	TransactionStatus_TRANSACTION_STATUS_UNCONFIRMED TransactionStatus = 2
	TransactionStatus_TRANSACTION_STATUS_FINALIZED   TransactionStatus = 3
	TransactionStatus_TRANSACTION_STATUS_FAILED      TransactionStatus = 4
	TransactionStatus_TRANSACTION_STATUS_FATAL       TransactionStatus = 5
)

func (TransactionStatus) Descriptor 

func (TransactionStatus) Descriptor() protoreflect.EnumDescriptor

func (TransactionStatus) Enum 

func (x TransactionStatus) Enum() *TransactionStatus

func (TransactionStatus) EnumDescriptor deprecated 

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

Deprecated: Use TransactionStatus.Descriptor instead.

func (TransactionStatus) Number 

func (x TransactionStatus) Number() protoreflect.EnumNumber

func (TransactionStatus) String 

func (x TransactionStatus) String() string

func (TransactionStatus) Type 

func (TransactionStatus) Type() protoreflect.EnumType

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/goplugin/plugin-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 TxHash 

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

func (*TxHash) Descriptor deprecated 

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

Deprecated: Use TxHash.ProtoReflect.Descriptor instead.

func (*TxHash) GetTxHash 

func (x *TxHash) GetTxHash() string

func (*TxHash) ProtoMessage 

func (*TxHash) ProtoMessage()

func (*TxHash) ProtoReflect 

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

func (*TxHash) Reset 

func (x *TxHash) Reset()

func (*TxHash) String 

func (x *TxHash) String() string

type UnbindRequest 

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/goplugin/plugin-common/pkg/types.ContractReader.Unbind.

func (*UnbindRequest) Descriptor deprecated 

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

Deprecated: Use UnbindRequest.ProtoReflect.Descriptor instead.

func (*UnbindRequest) GetBindings 

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

func (*UnbindRequest) ProtoMessage 

func (*UnbindRequest) ProtoMessage()

func (*UnbindRequest) ProtoReflect 

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

func (*UnbindRequest) Reset 

func (x *UnbindRequest) Reset()

func (*UnbindRequest) String 

func (x *UnbindRequest) String() string

type UnimplementedCapabilitiesRegistryServer 

type UnimplementedCapabilitiesRegistryServer struct {
}

UnimplementedCapabilitiesRegistryServer must be embedded to have forward compatible implementations.

func (UnimplementedCapabilitiesRegistryServer) Add 

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

func (UnimplementedCapabilitiesRegistryServer) ConfigForCapability 

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

func (UnimplementedCapabilitiesRegistryServer) Get 

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

func (UnimplementedCapabilitiesRegistryServer) GetAction 

func (UnimplementedCapabilitiesRegistryServer) GetAction(context.Context, *GetActionRequest) (*GetActionReply, error)

func (UnimplementedCapabilitiesRegistryServer) GetConsensus 

func (UnimplementedCapabilitiesRegistryServer) GetConsensus(context.Context, *GetConsensusRequest) (*GetConsensusReply, error)

func (UnimplementedCapabilitiesRegistryServer) GetTarget 

func (UnimplementedCapabilitiesRegistryServer) GetTarget(context.Context, *GetTargetRequest) (*GetTargetReply, 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 

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

type UnimplementedChainWriterServer 

type UnimplementedChainWriterServer struct {
}

UnimplementedChainWriterServer must be embedded to have forward compatible implementations.

func (UnimplementedChainWriterServer) GetFeeComponents 

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

func (UnimplementedChainWriterServer) GetTransactionStatus 

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

func (UnimplementedChainWriterServer) SubmitTransaction 

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

type UnimplementedCodecServer 

type UnimplementedCodecServer struct {
}

UnimplementedCodecServer must be embedded to have forward compatible implementations.

func (UnimplementedCodecServer) GetDecoding 

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

func (UnimplementedCodecServer) GetEncoding 

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

func (UnimplementedCodecServer) GetMaxSize 

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

type UnimplementedContractConfigTrackerServer 

type UnimplementedContractConfigTrackerServer struct {
}

UnimplementedContractConfigTrackerServer must be embedded to have forward compatible implementations.

func (UnimplementedContractConfigTrackerServer) LatestBlockHeight 

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

func (UnimplementedContractConfigTrackerServer) LatestConfig 

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

func (UnimplementedContractConfigTrackerServer) LatestConfigDetails 

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

type UnimplementedContractReaderServer 

type UnimplementedContractReaderServer struct {
}

UnimplementedContractReaderServer must be embedded to have forward compatible implementations.

func (UnimplementedContractReaderServer) BatchGetLatestValues 

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

func (UnimplementedContractReaderServer) Bind 

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

func (UnimplementedContractReaderServer) GetLatestValue 

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

func (UnimplementedContractReaderServer) QueryKey 

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

func (UnimplementedContractReaderServer) Unbind 

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

type UnimplementedContractTransmitterServer 

type UnimplementedContractTransmitterServer struct {
}

UnimplementedContractTransmitterServer must be embedded to have forward compatible implementations.

func (UnimplementedContractTransmitterServer) FromAccount 

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

func (UnimplementedContractTransmitterServer) LatestConfigDigestAndEpoch 

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

func (UnimplementedContractTransmitterServer) Transmit 

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

type UnimplementedDataSourceServer 

type UnimplementedDataSourceServer struct {
}

UnimplementedDataSourceServer must be embedded to have forward compatible implementations.

func (UnimplementedDataSourceServer) Observe 

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

type UnimplementedErrorLogServer 

type UnimplementedErrorLogServer struct {
}

UnimplementedErrorLogServer must be embedded to have forward compatible implementations.

func (UnimplementedErrorLogServer) SaveError 

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

type UnimplementedKeyValueStoreServer 

type UnimplementedKeyValueStoreServer struct {
}

UnimplementedKeyValueStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedKeyValueStoreServer) GetValueForKey 

func (UnimplementedKeyValueStoreServer) GetValueForKey(context.Context, *GetValueForKeyRequest) (*GetValueForKeyResponse, 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.

func (UnimplementedKeystoreServer) Accounts 

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

func (UnimplementedKeystoreServer) Sign 

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

type UnimplementedMedianContractServer 

type UnimplementedMedianContractServer struct {
}

UnimplementedMedianContractServer must be embedded to have forward compatible implementations.

func (UnimplementedMedianContractServer) LatestRoundRequested 

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

func (UnimplementedMedianContractServer) LatestTransmissionDetails 

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

type UnimplementedOffchainConfigDigesterServer 

type UnimplementedOffchainConfigDigesterServer struct {
}

UnimplementedOffchainConfigDigesterServer must be embedded to have forward compatible implementations.

func (UnimplementedOffchainConfigDigesterServer) ConfigDigest 

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

func (UnimplementedOffchainConfigDigesterServer) ConfigDigestPrefix 

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

type UnimplementedOnchainConfigCodecServer 

type UnimplementedOnchainConfigCodecServer struct {
}

UnimplementedOnchainConfigCodecServer must be embedded to have forward compatible implementations.

func (UnimplementedOnchainConfigCodecServer) Decode 

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

func (UnimplementedOnchainConfigCodecServer) Encode 

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

type UnimplementedPipelineRunnerServiceServer 

type UnimplementedPipelineRunnerServiceServer struct {
}

UnimplementedPipelineRunnerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPipelineRunnerServiceServer) ExecuteRun 

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

type UnimplementedPluginMedianServer 

type UnimplementedPluginMedianServer struct {
}

UnimplementedPluginMedianServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginMedianServer) NewMedianFactory 

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

type UnimplementedPluginRelayerServer 

type UnimplementedPluginRelayerServer struct {
}

UnimplementedPluginRelayerServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginRelayerServer) NewRelayer 

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

type UnimplementedRelayerServer 

type UnimplementedRelayerServer struct {
}

UnimplementedRelayerServer must be embedded to have forward compatible implementations.

func (UnimplementedRelayerServer) GetChainStatus 

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

func (UnimplementedRelayerServer) LatestHead 

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

func (UnimplementedRelayerServer) ListNodeStatuses 

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

func (UnimplementedRelayerServer) NewChainWriter 

func (UnimplementedRelayerServer) NewChainWriter(context.Context, *NewChainWriterRequest) (*NewChainWriterReply, 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) NewPluginProvider 

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

func (UnimplementedRelayerServer) Transact 

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

type UnimplementedReportCodecServer 

type UnimplementedReportCodecServer struct {
}

UnimplementedReportCodecServer must be embedded to have forward compatible implementations.

func (UnimplementedReportCodecServer) BuildReport 

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

func (UnimplementedReportCodecServer) MaxReportLength 

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

func (UnimplementedReportCodecServer) MedianFromReport 

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

type UnimplementedReportingPluginFactoryServer 

type UnimplementedReportingPluginFactoryServer struct {
}

UnimplementedReportingPluginFactoryServer must be embedded to have forward compatible implementations.

func (UnimplementedReportingPluginFactoryServer) NewReportingPlugin 

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

type UnimplementedReportingPluginServer 

type UnimplementedReportingPluginServer struct {
}

UnimplementedReportingPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedReportingPluginServer) Close 

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

func (UnimplementedReportingPluginServer) Observation 

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

func (UnimplementedReportingPluginServer) Query 

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

func (UnimplementedReportingPluginServer) Report 

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

func (UnimplementedReportingPluginServer) ShouldAcceptFinalizedReport 

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

func (UnimplementedReportingPluginServer) ShouldTransmitAcceptedReport 

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

type UnimplementedReportingPluginServiceServer 

type UnimplementedReportingPluginServiceServer struct {
}

UnimplementedReportingPluginServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedReportingPluginServiceServer) NewReportingPluginFactory 

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

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.

func (UnimplementedServiceServer) Close 

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

func (UnimplementedServiceServer) HealthReport 

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

func (UnimplementedServiceServer) Name 

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

func (UnimplementedServiceServer) Ready 

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

type UnimplementedTelemetryServer 

type UnimplementedTelemetryServer struct {
}

UnimplementedTelemetryServer must be embedded to have forward compatible implementations.

func (UnimplementedTelemetryServer) Send 

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

type UnimplementedValidationServiceServer 

type UnimplementedValidationServiceServer struct {
}

UnimplementedValidationServiceServer must be embedded to have forward compatible implementations.

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 UnsafeChainWriterServer 

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

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

type UnsafeCodecServer 

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

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

type UnsafeContractConfigTrackerServer 

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

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

type UnsafeContractReaderServer 

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

type ValueComparator 

type ValueComparator struct {
	Value    *VersionedBytes    `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Operator ComparisonOperator `protobuf:"varint,2,opt,name=operator,proto3,enum=loop.ComparisonOperator" json:"operator,omitempty"`
	// contains filtered or unexported fields
}

func (*ValueComparator) Descriptor deprecated 

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

Deprecated: Use ValueComparator.ProtoReflect.Descriptor instead.

func (*ValueComparator) GetOperator 

func (x *ValueComparator) GetOperator() ComparisonOperator

func (*ValueComparator) GetValue 

func (x *ValueComparator) GetValue() *VersionedBytes

func (*ValueComparator) ProtoMessage 

func (*ValueComparator) ProtoMessage()

func (*ValueComparator) ProtoReflect 

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

func (*ValueComparator) Reset 

func (x *ValueComparator) Reset()

func (*ValueComparator) String 

func (x *ValueComparator) String() string

type VersionedBytes 

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

func (*VersionedBytes) Descriptor deprecated 

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

Deprecated: Use VersionedBytes.ProtoReflect.Descriptor instead.

func (*VersionedBytes) GetData 

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

func (*VersionedBytes) GetVersion 

func (x *VersionedBytes) GetVersion() uint32

func (*VersionedBytes) ProtoMessage 

func (*VersionedBytes) ProtoMessage()

func (*VersionedBytes) ProtoReflect 

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

func (*VersionedBytes) Reset 

func (x *VersionedBytes) Reset()

func (*VersionedBytes) String 

func (x *VersionedBytes) String() string

Source Files

View all Source files

Directories

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

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.