pb

package

Go to main page

Versions in this module

v0

v0.5.0

Oct 28, 2024

v0.4.1

Nov 21, 2024

v0.4.0

Sep 2, 2024

v0.3.1

Nov 21, 2024

v0.3.0

Aug 22, 2024

v0.2.1

Nov 21, 2024

v0.2.0

Jul 16, 2024

Changes in this version

+ const CapabilitiesRegistry_GetLocalNode_FullMethodName

+ const ChainReader_Bind_FullMethodName

+ const ChainReader_GetLatestValue_FullMethodName

+ const ChainReader_QueryKey_FullMethodName

+ var ChainReader_ServiceDesc = grpc.ServiceDesc

+ var File_chain_reader_proto protoreflect.FileDescriptor

+ func RegisterChainReaderServer(s grpc.ServiceRegistrar, srv ChainReaderServer)

type CapabilitiesRegistryClient

+ GetLocalNode func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetLocalNodeReply, error)

type CapabilitiesRegistryServer

+ GetLocalNode func(context.Context, *emptypb.Empty) (*GetLocalNodeReply, error)

+ type ChainReaderClient interface

+ Bind func(ctx context.Context, in *BindRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetLatestValue func(ctx context.Context, in *GetLatestValueRequest, opts ...grpc.CallOption) (*GetLatestValueReply, error)

+ QueryKey func(ctx context.Context, in *QueryKeyRequest, opts ...grpc.CallOption) (*QueryKeyReply, error)

+ func NewChainReaderClient(cc grpc.ClientConnInterface) ChainReaderClient

+ type ChainReaderServer interface

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

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

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

type ExecuteAPIType

+ const ExecuteAPIType_EXECUTE_API_TYPE_CALLBACK

type GetLatestValueRequest

+ ContractName string

+ Method string

+ func (x *GetLatestValueRequest) GetContractName() string

+ func (x *GetLatestValueRequest) GetMethod() string

+ type GetLocalNodeReply struct

+ CapabilityDONs []*DON

+ PeerID []byte

+ WorkflowDON *DON

+ func (*GetLocalNodeReply) Descriptor() ([]byte, []int)

+ func (*GetLocalNodeReply) ProtoMessage()

+ func (x *GetLocalNodeReply) GetCapabilityDONs() []*DON

+ func (x *GetLocalNodeReply) GetPeerID() []byte

+ func (x *GetLocalNodeReply) GetWorkflowDON() *DON

+ func (x *GetLocalNodeReply) ProtoReflect() protoreflect.Message

+ func (x *GetLocalNodeReply) Reset()

+ func (x *GetLocalNodeReply) String() string

type Head

+ Identifier string

+ func (x *Head) GetIdentifier() string

type QueryKeyRequest

+ ContractName string

+ func (x *QueryKeyRequest) GetContractName() string

type UnimplementedCapabilitiesRegistryServer

+ func (UnimplementedCapabilitiesRegistryServer) GetLocalNode(context.Context, *emptypb.Empty) (*GetLocalNodeReply, error)

+ type UnimplementedChainReaderServer struct

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

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

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

+ type UnsafeChainReaderServer interface

v0.1.1

Nov 12, 2024

v0.0.1

Nov 21, 2024

Changes in this version

+ const CapabilitiesRegistry_Add_FullMethodName

+ const CapabilitiesRegistry_ConfigForCapability_FullMethodName

+ const CapabilitiesRegistry_GetAction_FullMethodName

+ const CapabilitiesRegistry_GetConsensus_FullMethodName

+ const CapabilitiesRegistry_GetTarget_FullMethodName

+ const CapabilitiesRegistry_GetTrigger_FullMethodName

+ const CapabilitiesRegistry_Get_FullMethodName

+ const CapabilitiesRegistry_List_FullMethodName

+ const CapabilitiesRegistry_LocalNode_FullMethodName

+ const ChainWriter_GetFeeComponents_FullMethodName

+ const ChainWriter_GetTransactionStatus_FullMethodName

+ const ChainWriter_SubmitTransaction_FullMethodName

+ const Codec_GetDecoding_FullMethodName

+ const Codec_GetEncoding_FullMethodName

+ const Codec_GetMaxSize_FullMethodName

+ const ContractConfigTracker_LatestBlockHeight_FullMethodName

+ const ContractConfigTracker_LatestConfigDetails_FullMethodName

+ const ContractConfigTracker_LatestConfig_FullMethodName

+ const ContractReader_BatchGetLatestValues_FullMethodName

+ const ContractReader_Bind_FullMethodName

+ const ContractReader_GetLatestValue_FullMethodName

+ const ContractReader_QueryKey_FullMethodName

+ const ContractReader_Unbind_FullMethodName

+ const ContractTransmitter_FromAccount_FullMethodName

+ const ContractTransmitter_LatestConfigDigestAndEpoch_FullMethodName

+ const ContractTransmitter_Transmit_FullMethodName

+ const DataSource_Observe_FullMethodName

+ const ErrorLog_SaveError_FullMethodName

+ const KeyValueStore_GetValueForKey_FullMethodName

+ const KeyValueStore_StoreKeyValue_FullMethodName

+ const Keystore_Accounts_FullMethodName

+ const Keystore_Sign_FullMethodName

+ const MedianContract_LatestRoundRequested_FullMethodName

+ const MedianContract_LatestTransmissionDetails_FullMethodName

+ const OffchainConfigDigester_ConfigDigestPrefix_FullMethodName

+ const OffchainConfigDigester_ConfigDigest_FullMethodName

+ const OnchainConfigCodec_Decode_FullMethodName

+ const OnchainConfigCodec_Encode_FullMethodName

+ const PipelineRunnerService_ExecuteRun_FullMethodName

+ const PluginMedian_NewMedianFactory_FullMethodName

+ const PluginRelayer_NewRelayer_FullMethodName

+ const Relayer_GetChainStatus_FullMethodName

+ const Relayer_LatestHead_FullMethodName

+ const Relayer_ListNodeStatuses_FullMethodName

+ const Relayer_NewChainWriter_FullMethodName

+ const Relayer_NewConfigProvider_FullMethodName

+ const Relayer_NewContractReader_FullMethodName

+ const Relayer_NewPluginProvider_FullMethodName

+ const Relayer_Transact_FullMethodName

+ const ReportCodec_BuildReport_FullMethodName

+ const ReportCodec_MaxReportLength_FullMethodName

+ const ReportCodec_MedianFromReport_FullMethodName

+ const ReportingPluginFactory_NewReportingPlugin_FullMethodName

+ const ReportingPluginService_NewReportingPluginFactory_FullMethodName

+ const ReportingPluginService_NewValidationService_FullMethodName

+ const ReportingPlugin_Close_FullMethodName

+ const ReportingPlugin_Observation_FullMethodName

+ const ReportingPlugin_Query_FullMethodName

+ const ReportingPlugin_Report_FullMethodName

+ const ReportingPlugin_ShouldAcceptFinalizedReport_FullMethodName

+ const ReportingPlugin_ShouldTransmitAcceptedReport_FullMethodName

+ const Service_Close_FullMethodName

+ const Service_HealthReport_FullMethodName

+ const Service_Name_FullMethodName

+ const Service_Ready_FullMethodName

+ const Telemetry_Send_FullMethodName

+ const ValidationService_ValidateConfig_FullMethodName

+ var BooleanOperator_name = map[int32]string

+ var BooleanOperator_value = map[string]int32

+ var CapabilitiesRegistry_ServiceDesc = grpc.ServiceDesc

+ var ChainWriter_ServiceDesc = grpc.ServiceDesc

+ var Codec_ServiceDesc = grpc.ServiceDesc

+ var ComparisonOperator_name = map[int32]string

+ var ComparisonOperator_value = map[string]int32

+ var Confidence_name = map[int32]string

+ var Confidence_value = map[string]int32

+ var ContractConfigTracker_ServiceDesc = grpc.ServiceDesc

+ var ContractReader_ServiceDesc = grpc.ServiceDesc

+ var ContractTransmitter_ServiceDesc = grpc.ServiceDesc

+ var CursorDirection_name = map[int32]string

+ var CursorDirection_value = map[string]int32

+ var DataSource_ServiceDesc = grpc.ServiceDesc

+ var ErrorLog_ServiceDesc = grpc.ServiceDesc

+ var ExecuteAPIType_name = map[int32]string

+ var ExecuteAPIType_value = map[string]int32

+ var File_chain_writer_proto protoreflect.FileDescriptor

+ var File_codec_proto protoreflect.FileDescriptor

+ var File_contract_reader_proto protoreflect.FileDescriptor

+ var File_keyvalue_store_proto protoreflect.FileDescriptor

+ var File_loop_internal_pb_capabilities_registry_proto protoreflect.FileDescriptor

+ var File_median_datasource_proto protoreflect.FileDescriptor

+ var File_median_proto protoreflect.FileDescriptor

+ var File_pipeline_runner_proto protoreflect.FileDescriptor

+ var File_relayer_proto protoreflect.FileDescriptor

+ var File_reporting_plugin_service_proto protoreflect.FileDescriptor

+ var File_reporting_proto protoreflect.FileDescriptor

+ var File_telemetry_proto protoreflect.FileDescriptor

+ var File_validate_config_proto protoreflect.FileDescriptor

+ var KeyValueStore_ServiceDesc = grpc.ServiceDesc

+ var Keystore_ServiceDesc = grpc.ServiceDesc

+ var MedianContract_ServiceDesc = grpc.ServiceDesc

+ var OffchainConfigDigester_ServiceDesc = grpc.ServiceDesc

+ var OnchainConfigCodec_ServiceDesc = grpc.ServiceDesc

+ var PipelineRunnerService_ServiceDesc = grpc.ServiceDesc

+ var PluginMedian_ServiceDesc = grpc.ServiceDesc

+ var PluginRelayer_ServiceDesc = grpc.ServiceDesc

+ var Relayer_ServiceDesc = grpc.ServiceDesc

+ var ReportCodec_ServiceDesc = grpc.ServiceDesc

+ var ReportingPluginFactory_ServiceDesc = grpc.ServiceDesc

+ var ReportingPluginService_ServiceDesc = grpc.ServiceDesc

+ var ReportingPlugin_ServiceDesc = grpc.ServiceDesc

+ var Service_ServiceDesc = grpc.ServiceDesc

+ var SortDirection_name = map[int32]string

+ var SortDirection_value = map[string]int32

+ var SortType_name = map[int32]string

+ var SortType_value = map[string]int32

+ var Telemetry_ServiceDesc = grpc.ServiceDesc

+ var TransactionStatus_name = map[int32]string

+ var TransactionStatus_value = map[string]int32

+ var ValidationService_ServiceDesc = grpc.ServiceDesc

+ func RegisterCapabilitiesRegistryServer(s grpc.ServiceRegistrar, srv CapabilitiesRegistryServer)

+ func RegisterChainWriterServer(s grpc.ServiceRegistrar, srv ChainWriterServer)

+ func RegisterCodecServer(s grpc.ServiceRegistrar, srv CodecServer)

+ func RegisterContractConfigTrackerServer(s grpc.ServiceRegistrar, srv ContractConfigTrackerServer)

+ func RegisterContractReaderServer(s grpc.ServiceRegistrar, srv ContractReaderServer)

+ func RegisterContractTransmitterServer(s grpc.ServiceRegistrar, srv ContractTransmitterServer)

+ func RegisterDataSourceServer(s grpc.ServiceRegistrar, srv DataSourceServer)

+ func RegisterErrorLogServer(s grpc.ServiceRegistrar, srv ErrorLogServer)

+ func RegisterKeyValueStoreServer(s grpc.ServiceRegistrar, srv KeyValueStoreServer)

+ func RegisterKeystoreServer(s grpc.ServiceRegistrar, srv KeystoreServer)

+ func RegisterMedianContractServer(s grpc.ServiceRegistrar, srv MedianContractServer)

+ func RegisterOffchainConfigDigesterServer(s grpc.ServiceRegistrar, srv OffchainConfigDigesterServer)

+ func RegisterOnchainConfigCodecServer(s grpc.ServiceRegistrar, srv OnchainConfigCodecServer)

+ func RegisterPipelineRunnerServiceServer(s grpc.ServiceRegistrar, srv PipelineRunnerServiceServer)

+ func RegisterPluginMedianServer(s grpc.ServiceRegistrar, srv PluginMedianServer)

+ func RegisterPluginRelayerServer(s grpc.ServiceRegistrar, srv PluginRelayerServer)

+ func RegisterRelayerServer(s grpc.ServiceRegistrar, srv RelayerServer)

+ func RegisterReportCodecServer(s grpc.ServiceRegistrar, srv ReportCodecServer)

+ func RegisterReportingPluginFactoryServer(s grpc.ServiceRegistrar, srv ReportingPluginFactoryServer)

+ func RegisterReportingPluginServer(s grpc.ServiceRegistrar, srv ReportingPluginServer)

+ func RegisterReportingPluginServiceServer(s grpc.ServiceRegistrar, srv ReportingPluginServiceServer)

+ func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

+ func RegisterTelemetryServer(s grpc.ServiceRegistrar, srv TelemetryServer)

+ func RegisterValidationServiceServer(s grpc.ServiceRegistrar, srv ValidationServiceServer)

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

+ type AccountsReply struct

+ Accounts []string

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

+ func (*AccountsReply) ProtoMessage()

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

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

+ func (x *AccountsReply) Reset()

+ func (x *AccountsReply) String() string

+ type AddRequest struct

+ CapabilityID uint32

+ Type ExecuteAPIType

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

+ func (*AddRequest) ProtoMessage()

+ func (x *AddRequest) GetCapabilityID() uint32

+ func (x *AddRequest) GetType() ExecuteAPIType

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

+ func (x *AddRequest) Reset()

+ func (x *AddRequest) String() string

+ type And struct

+ Expr []*Expression

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

+ func (*And) ProtoMessage()

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

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

+ func (x *And) Reset()

+ func (x *And) String() string

+ type AttributedObservation struct

+ Observation []byte

+ Observer uint32

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

+ func (*AttributedObservation) ProtoMessage()

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

+ func (x *AttributedObservation) GetObserver() uint32

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

+ func (x *AttributedObservation) Reset()

+ func (x *AttributedObservation) String() string

+ type AttributedOnchainSignature struct

+ Signature []byte

+ Signer uint32

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

+ func (*AttributedOnchainSignature) ProtoMessage()

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

+ func (x *AttributedOnchainSignature) GetSigner() uint32

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

+ func (x *AttributedOnchainSignature) Reset()

+ func (x *AttributedOnchainSignature) String() string

+ type BatchGetLatestValuesReply struct

+ Results []*ContractBatchResult

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

+ func (*BatchGetLatestValuesReply) ProtoMessage()

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

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

+ func (x *BatchGetLatestValuesReply) Reset()

+ func (x *BatchGetLatestValuesReply) String() string

+ type BatchGetLatestValuesRequest struct

+ Requests []*ContractBatch

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

+ func (*BatchGetLatestValuesRequest) ProtoMessage()

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

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

+ func (x *BatchGetLatestValuesRequest) Reset()

+ func (x *BatchGetLatestValuesRequest) String() string

+ type BatchRead struct

+ Params *VersionedBytes

+ ReadName string

+ ReturnVal *VersionedBytes

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

+ func (*BatchRead) ProtoMessage()

+ func (x *BatchRead) GetParams() *VersionedBytes

+ func (x *BatchRead) GetReadName() string

+ func (x *BatchRead) GetReturnVal() *VersionedBytes

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

+ func (x *BatchRead) Reset()

+ func (x *BatchRead) String() string

+ type BatchReadResult struct

+ Error string

+ ReadName string

+ ReturnVal *VersionedBytes

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

+ func (*BatchReadResult) ProtoMessage()

+ func (x *BatchReadResult) GetError() string

+ func (x *BatchReadResult) GetReadName() string

+ func (x *BatchReadResult) GetReturnVal() *VersionedBytes

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

+ func (x *BatchReadResult) Reset()

+ func (x *BatchReadResult) String() string

+ type BigInt struct

+ Negative bool

+ Value []byte

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

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

+ func (*BigInt) ProtoMessage()

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

+ func (x *BigInt) GetNegative() bool

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

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

+ func (x *BigInt) Reset()

+ func (x *BigInt) String() string

+ type BindRequest struct

+ Bindings []*BoundContract

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

+ func (*BindRequest) ProtoMessage()

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

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

+ func (x *BindRequest) Reset()

+ func (x *BindRequest) String() string

+ type Block struct

+ BlockNumber string

+ Operator ComparisonOperator

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

+ func (*Block) ProtoMessage()

+ func (x *Block) GetBlockNumber() string

+ func (x *Block) GetOperator() ComparisonOperator

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

+ func (x *Block) Reset()

+ func (x *Block) String() string

+ type BooleanExpression struct

+ BooleanOperator BooleanOperator

+ Expression []*Expression

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

+ func (*BooleanExpression) ProtoMessage()

+ func (x *BooleanExpression) GetBooleanOperator() BooleanOperator

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

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

+ func (x *BooleanExpression) Reset()

+ func (x *BooleanExpression) String() string

+ type BooleanOperator int32

+ const BooleanOperator_AND

+ const BooleanOperator_OR

+ func (BooleanOperator) Descriptor() protoreflect.EnumDescriptor

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

+ func (BooleanOperator) Type() protoreflect.EnumType

+ func (x BooleanOperator) Enum() *BooleanOperator

+ func (x BooleanOperator) Number() protoreflect.EnumNumber

+ func (x BooleanOperator) String() string

+ type BoundContract struct

+ Address string

+ Name string

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

+ func (*BoundContract) ProtoMessage()

+ func (x *BoundContract) GetAddress() string

+ func (x *BoundContract) GetName() string

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

+ func (x *BoundContract) Reset()

+ func (x *BoundContract) String() string

+ type BuildReportReply struct

+ Report []byte

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

+ func (*BuildReportReply) ProtoMessage()

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

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

+ func (x *BuildReportReply) Reset()

+ func (x *BuildReportReply) String() string

+ type BuildReportRequest struct

+ Observations []*ParsedAttributedObservation

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

+ func (*BuildReportRequest) ProtoMessage()

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

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

+ func (x *BuildReportRequest) Reset()

+ func (x *BuildReportRequest) String() string

+ type CapabilitiesRegistryClient interface

+ Add func(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ ConfigForCapability func(ctx context.Context, in *ConfigForCapabilityRequest, opts ...grpc.CallOption) (*ConfigForCapabilityReply, error)

+ Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)

+ GetAction func(ctx context.Context, in *GetActionRequest, opts ...grpc.CallOption) (*GetActionReply, error)

+ GetConsensus func(ctx context.Context, in *GetConsensusRequest, opts ...grpc.CallOption) (*GetConsensusReply, error)

+ GetTarget func(ctx context.Context, in *GetTargetRequest, opts ...grpc.CallOption) (*GetTargetReply, error)

+ GetTrigger func(ctx context.Context, in *GetTriggerRequest, opts ...grpc.CallOption) (*GetTriggerReply, error)

+ List func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListReply, error)

+ LocalNode func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*LocalNodeReply, error)

+ func NewCapabilitiesRegistryClient(cc grpc.ClientConnInterface) CapabilitiesRegistryClient

+ type CapabilitiesRegistryServer interface

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

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

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

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

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

+ GetTarget func(context.Context, *GetTargetRequest) (*GetTargetReply, error)

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

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

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

+ type ChainStatus struct

+ Config string

+ Enabled bool

+ Id string

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

+ func (*ChainStatus) ProtoMessage()

+ func (x *ChainStatus) GetConfig() string

+ func (x *ChainStatus) GetEnabled() bool

+ func (x *ChainStatus) GetId() string

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

+ func (x *ChainStatus) Reset()

+ func (x *ChainStatus) String() string

+ type ChainWriterClient interface

+ GetFeeComponents func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetFeeComponentsReply, error)

+ GetTransactionStatus func(ctx context.Context, in *GetTransactionStatusRequest, opts ...grpc.CallOption) (*GetTransactionStatusReply, error)

+ SubmitTransaction func(ctx context.Context, in *SubmitTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewChainWriterClient(cc grpc.ClientConnInterface) ChainWriterClient

+ type ChainWriterServer interface

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

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

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

+ type CodecClient interface

+ GetDecoding func(ctx context.Context, in *GetDecodingRequest, opts ...grpc.CallOption) (*GetDecodingResponse, error)

+ GetEncoding func(ctx context.Context, in *GetEncodingRequest, opts ...grpc.CallOption) (*GetEncodingResponse, error)

+ GetMaxSize func(ctx context.Context, in *GetMaxSizeRequest, opts ...grpc.CallOption) (*GetMaxSizeResponse, error)

+ func NewCodecClient(cc grpc.ClientConnInterface) CodecClient

+ type CodecServer interface

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

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

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

+ type Comparator struct

+ Name string

+ ValueComparators []*ValueComparator

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

+ func (*Comparator) ProtoMessage()

+ func (x *Comparator) GetName() string

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

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

+ func (x *Comparator) Reset()

+ func (x *Comparator) String() string

+ type ComparisonOperator int32

+ const ComparisonOperator_Eq

+ const ComparisonOperator_Gt

+ const ComparisonOperator_Gte

+ const ComparisonOperator_Lt

+ const ComparisonOperator_Lte

+ const ComparisonOperator_Neq

+ func (ComparisonOperator) Descriptor() protoreflect.EnumDescriptor

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

+ func (ComparisonOperator) Type() protoreflect.EnumType

+ func (x ComparisonOperator) Enum() *ComparisonOperator

+ func (x ComparisonOperator) Number() protoreflect.EnumNumber

+ func (x ComparisonOperator) String() string

+ type Confidence int32

+ const Confidence_Finalized

+ const Confidence_Unconfirmed

+ func (Confidence) Descriptor() protoreflect.EnumDescriptor

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

+ func (Confidence) Type() protoreflect.EnumType

+ func (x Confidence) Enum() *Confidence

+ func (x Confidence) Number() protoreflect.EnumNumber

+ func (x Confidence) String() string

+ type ConfigDigestPrefixReply struct

+ ConfigDigestPrefix uint32

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

+ func (*ConfigDigestPrefixReply) ProtoMessage()

+ func (x *ConfigDigestPrefixReply) GetConfigDigestPrefix() uint32

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

+ func (x *ConfigDigestPrefixReply) Reset()

+ func (x *ConfigDigestPrefixReply) String() string

+ type ConfigDigestPrefixRequest struct

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

+ func (*ConfigDigestPrefixRequest) ProtoMessage()

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

+ func (x *ConfigDigestPrefixRequest) Reset()

+ func (x *ConfigDigestPrefixRequest) String() string

+ type ConfigDigestReply struct

+ ConfigDigest []byte

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

+ func (*ConfigDigestReply) ProtoMessage()

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

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

+ func (x *ConfigDigestReply) Reset()

+ func (x *ConfigDigestReply) String() string

+ type ConfigDigestRequest struct

+ ContractConfig *ContractConfig

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

+ func (*ConfigDigestRequest) ProtoMessage()

+ func (x *ConfigDigestRequest) GetContractConfig() *ContractConfig

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

+ func (x *ConfigDigestRequest) Reset()

+ func (x *ConfigDigestRequest) String() string

+ type ConfigForCapabilityReply struct

+ CapabilityConfig *pb.CapabilityConfig

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

+ func (*ConfigForCapabilityReply) ProtoMessage()

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

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

+ func (x *ConfigForCapabilityReply) Reset()

+ func (x *ConfigForCapabilityReply) String() string

+ type ConfigForCapabilityRequest struct

+ CapabilityID string

+ DonID uint32

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

+ func (*ConfigForCapabilityRequest) ProtoMessage()

+ func (x *ConfigForCapabilityRequest) GetCapabilityID() string

+ func (x *ConfigForCapabilityRequest) GetDonID() uint32

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

+ func (x *ConfigForCapabilityRequest) Reset()

+ func (x *ConfigForCapabilityRequest) String() string

+ type ContractBatch struct

+ Contract *BoundContract

+ Reads []*BatchRead

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

+ func (*ContractBatch) ProtoMessage()

+ func (x *ContractBatch) GetContract() *BoundContract

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

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

+ func (x *ContractBatch) Reset()

+ func (x *ContractBatch) String() string

+ type ContractBatchResult struct

+ Contract *BoundContract

+ Results []*BatchReadResult

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

+ func (*ContractBatchResult) ProtoMessage()

+ func (x *ContractBatchResult) GetContract() *BoundContract

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

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

+ func (x *ContractBatchResult) Reset()

+ func (x *ContractBatchResult) String() string

+ type ContractConfig struct

+ ConfigCount uint64

+ ConfigDigest []byte

+ F uint32

+ OffchainConfig []byte

+ OffchainConfigVersion uint64

+ OnchainConfig []byte

+ Signers [][]byte

+ Transmitters []string

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

+ func (*ContractConfig) ProtoMessage()

+ func (x *ContractConfig) GetConfigCount() uint64

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

+ func (x *ContractConfig) GetF() uint32

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

+ func (x *ContractConfig) GetOffchainConfigVersion() uint64

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

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

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

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

+ func (x *ContractConfig) Reset()

+ func (x *ContractConfig) String() string

+ type ContractConfigTrackerClient interface

+ LatestBlockHeight func(ctx context.Context, in *LatestBlockHeightRequest, opts ...grpc.CallOption) (*LatestBlockHeightReply, error)

+ LatestConfig func(ctx context.Context, in *LatestConfigRequest, opts ...grpc.CallOption) (*LatestConfigReply, error)

+ LatestConfigDetails func(ctx context.Context, in *LatestConfigDetailsRequest, opts ...grpc.CallOption) (*LatestConfigDetailsReply, error)

+ func NewContractConfigTrackerClient(cc grpc.ClientConnInterface) ContractConfigTrackerClient

+ type ContractConfigTrackerServer interface

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

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

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

+ type ContractReaderClient interface

+ BatchGetLatestValues func(ctx context.Context, in *BatchGetLatestValuesRequest, opts ...grpc.CallOption) (*BatchGetLatestValuesReply, error)

+ Bind func(ctx context.Context, in *BindRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetLatestValue func(ctx context.Context, in *GetLatestValueRequest, opts ...grpc.CallOption) (*GetLatestValueReply, error)

+ QueryKey func(ctx context.Context, in *QueryKeyRequest, opts ...grpc.CallOption) (*QueryKeyReply, error)

+ Unbind func(ctx context.Context, in *UnbindRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewContractReaderClient(cc grpc.ClientConnInterface) ContractReaderClient

+ type ContractReaderServer interface

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

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

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

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

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

+ type ContractTransmitterClient interface

+ FromAccount func(ctx context.Context, in *FromAccountRequest, opts ...grpc.CallOption) (*FromAccountReply, error)

+ LatestConfigDigestAndEpoch func(ctx context.Context, in *LatestConfigDigestAndEpochRequest, ...) (*LatestConfigDigestAndEpochReply, error)

+ Transmit func(ctx context.Context, in *TransmitRequest, opts ...grpc.CallOption) (*TransmitReply, error)

+ func NewContractTransmitterClient(cc grpc.ClientConnInterface) ContractTransmitterClient

+ type ContractTransmitterServer interface

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

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

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

+ type CursorDirection int32

+ const CursorDirection_Following

+ const CursorDirection_Preceding

+ func (CursorDirection) Descriptor() protoreflect.EnumDescriptor

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

+ func (CursorDirection) Type() protoreflect.EnumType

+ func (x CursorDirection) Enum() *CursorDirection

+ func (x CursorDirection) Number() protoreflect.EnumNumber

+ func (x CursorDirection) String() string

+ type DON struct

+ ConfigVersion uint32

+ F uint32

+ Id uint32

+ Members [][]byte

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

+ func (*DON) ProtoMessage()

+ func (x *DON) GetConfigVersion() uint32

+ func (x *DON) GetF() uint32

+ func (x *DON) GetId() uint32

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

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

+ func (x *DON) Reset()

+ func (x *DON) String() string

+ type DataSourceClient interface

+ Observe func(ctx context.Context, in *ObserveRequest, opts ...grpc.CallOption) (*ObserveReply, error)

+ func NewDataSourceClient(cc grpc.ClientConnInterface) DataSourceClient

+ type DataSourceServer interface

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

+ type DecodeReply struct

+ OnchainConfig *OnchainConfig

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

+ func (*DecodeReply) ProtoMessage()

+ func (x *DecodeReply) GetOnchainConfig() *OnchainConfig

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

+ func (x *DecodeReply) Reset()

+ func (x *DecodeReply) String() string

+ type DecodeRequest struct

+ Encoded []byte

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

+ func (*DecodeRequest) ProtoMessage()

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

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

+ func (x *DecodeRequest) Reset()

+ func (x *DecodeRequest) String() string

+ type EncodeReply struct

+ Encoded []byte

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

+ func (*EncodeReply) ProtoMessage()

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

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

+ func (x *EncodeReply) Reset()

+ func (x *EncodeReply) String() string

+ type EncodeRequest struct

+ OnchainConfig *OnchainConfig

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

+ func (*EncodeRequest) ProtoMessage()

+ func (x *EncodeRequest) GetOnchainConfig() *OnchainConfig

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

+ func (x *EncodeRequest) Reset()

+ func (x *EncodeRequest) String() string

+ type ErrConfigDigestLen int

+ func (e ErrConfigDigestLen) Error() string

+ type ErrUint8Bounds struct

+ Name string

+ U uint32

+ func (e ErrUint8Bounds) Error() string

+ type ErrorLogClient interface

+ SaveError func(ctx context.Context, in *SaveErrorRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewErrorLogClient(cc grpc.ClientConnInterface) ErrorLogClient

+ type ErrorLogServer interface

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

+ type ExecuteAPIType int32

+ const ExecuteAPIType_EXECUTE_API_TYPE_EXECUTE

+ const ExecuteAPIType_EXECUTE_API_TYPE_TRIGGER

+ const ExecuteAPIType_EXECUTE_API_TYPE_UNKNOWN

+ func (ExecuteAPIType) Descriptor() protoreflect.EnumDescriptor

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

+ func (ExecuteAPIType) Type() protoreflect.EnumType

+ func (x ExecuteAPIType) Enum() *ExecuteAPIType

+ func (x ExecuteAPIType) Number() protoreflect.EnumNumber

+ func (x ExecuteAPIType) String() string

+ type Expression struct

+ Evaluator isExpression_Evaluator

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

+ func (*Expression) ProtoMessage()

+ func (m *Expression) GetEvaluator() isExpression_Evaluator

+ func (x *Expression) GetBooleanExpression() *BooleanExpression

+ func (x *Expression) GetPrimitive() *Primitive

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

+ func (x *Expression) Reset()

+ func (x *Expression) String() string

+ type Expression_BooleanExpression struct

+ BooleanExpression *BooleanExpression

+ type Expression_Primitive struct

+ Primitive *Primitive

+ type FromAccountReply struct

+ Account string

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

+ func (*FromAccountReply) ProtoMessage()

+ func (x *FromAccountReply) GetAccount() string

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

+ func (x *FromAccountReply) Reset()

+ func (x *FromAccountReply) String() string

+ type FromAccountRequest struct

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

+ func (*FromAccountRequest) ProtoMessage()

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

+ func (x *FromAccountRequest) Reset()

+ func (x *FromAccountRequest) String() string

+ type GetActionReply struct

+ CapabilityID uint32

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

+ func (*GetActionReply) ProtoMessage()

+ func (x *GetActionReply) GetCapabilityID() uint32

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

+ func (x *GetActionReply) Reset()

+ func (x *GetActionReply) String() string

+ type GetActionRequest struct

+ Id string

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

+ func (*GetActionRequest) ProtoMessage()

+ func (x *GetActionRequest) GetId() string

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

+ func (x *GetActionRequest) Reset()

+ func (x *GetActionRequest) String() string

+ type GetChainStatusReply struct

+ Chain *ChainStatus

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

+ func (*GetChainStatusReply) ProtoMessage()

+ func (x *GetChainStatusReply) GetChain() *ChainStatus

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

+ func (x *GetChainStatusReply) Reset()

+ func (x *GetChainStatusReply) String() string

+ type GetChainStatusRequest struct

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

+ func (*GetChainStatusRequest) ProtoMessage()

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

+ func (x *GetChainStatusRequest) Reset()

+ func (x *GetChainStatusRequest) String() string

+ type GetConsensusReply struct

+ CapabilityID uint32

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

+ func (*GetConsensusReply) ProtoMessage()

+ func (x *GetConsensusReply) GetCapabilityID() uint32

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

+ func (x *GetConsensusReply) Reset()

+ func (x *GetConsensusReply) String() string

+ type GetConsensusRequest struct

+ Id string

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

+ func (*GetConsensusRequest) ProtoMessage()

+ func (x *GetConsensusRequest) GetId() string

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

+ func (x *GetConsensusRequest) Reset()

+ func (x *GetConsensusRequest) String() string

+ type GetDecodingRequest struct

+ Encoded []byte

+ ItemType string

+ WireEncodingVersion uint32

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

+ func (*GetDecodingRequest) ProtoMessage()

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

+ func (x *GetDecodingRequest) GetItemType() string

+ func (x *GetDecodingRequest) GetWireEncodingVersion() uint32

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

+ func (x *GetDecodingRequest) Reset()

+ func (x *GetDecodingRequest) String() string

+ type GetDecodingResponse struct

+ RetVal *VersionedBytes

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

+ func (*GetDecodingResponse) ProtoMessage()

+ func (x *GetDecodingResponse) GetRetVal() *VersionedBytes

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

+ func (x *GetDecodingResponse) Reset()

+ func (x *GetDecodingResponse) String() string

+ type GetEncodingRequest struct

+ ItemType string

+ Params *VersionedBytes

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

+ func (*GetEncodingRequest) ProtoMessage()

+ func (x *GetEncodingRequest) GetItemType() string

+ func (x *GetEncodingRequest) GetParams() *VersionedBytes

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

+ func (x *GetEncodingRequest) Reset()

+ func (x *GetEncodingRequest) String() string

+ type GetEncodingResponse struct

+ RetVal []byte

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

+ func (*GetEncodingResponse) ProtoMessage()

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

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

+ func (x *GetEncodingResponse) Reset()

+ func (x *GetEncodingResponse) String() string

+ type GetFeeComponentsReply struct

+ DataAvailabilityFee *BigInt

+ ExecutionFee *BigInt

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

+ func (*GetFeeComponentsReply) ProtoMessage()

+ func (x *GetFeeComponentsReply) GetDataAvailabilityFee() *BigInt

+ func (x *GetFeeComponentsReply) GetExecutionFee() *BigInt

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

+ func (x *GetFeeComponentsReply) Reset()

+ func (x *GetFeeComponentsReply) String() string

+ type GetLatestValueReply struct

+ RetVal *VersionedBytes

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

+ func (*GetLatestValueReply) ProtoMessage()

+ func (x *GetLatestValueReply) GetRetVal() *VersionedBytes

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

+ func (x *GetLatestValueReply) Reset()

+ func (x *GetLatestValueReply) String() string

+ type GetLatestValueRequest struct

+ AsValueType bool

+ Confidence Confidence

+ Params *VersionedBytes

+ ReadIdentifier string

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

+ func (*GetLatestValueRequest) ProtoMessage()

+ func (x *GetLatestValueRequest) GetAsValueType() bool

+ func (x *GetLatestValueRequest) GetConfidence() Confidence

+ func (x *GetLatestValueRequest) GetParams() *VersionedBytes

+ func (x *GetLatestValueRequest) GetReadIdentifier() string

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

+ func (x *GetLatestValueRequest) Reset()

+ func (x *GetLatestValueRequest) String() string

+ type GetMaxSizeRequest struct

+ ForEncoding bool

+ ItemType string

+ N int32

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

+ func (*GetMaxSizeRequest) ProtoMessage()

+ func (x *GetMaxSizeRequest) GetForEncoding() bool

+ func (x *GetMaxSizeRequest) GetItemType() string

+ func (x *GetMaxSizeRequest) GetN() int32

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

+ func (x *GetMaxSizeRequest) Reset()

+ func (x *GetMaxSizeRequest) String() string

+ type GetMaxSizeResponse struct

+ SizeInBytes int32

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

+ func (*GetMaxSizeResponse) ProtoMessage()

+ func (x *GetMaxSizeResponse) GetSizeInBytes() int32

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

+ func (x *GetMaxSizeResponse) Reset()

+ func (x *GetMaxSizeResponse) String() string

+ type GetReply struct

+ CapabilityID uint32

+ Type ExecuteAPIType

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

+ func (*GetReply) ProtoMessage()

+ func (x *GetReply) GetCapabilityID() uint32

+ func (x *GetReply) GetType() ExecuteAPIType

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

+ func (x *GetReply) Reset()

+ func (x *GetReply) String() string

+ type GetRequest struct

+ Id string

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

+ func (*GetRequest) ProtoMessage()

+ func (x *GetRequest) GetId() string

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

+ func (x *GetRequest) Reset()

+ func (x *GetRequest) String() string

+ type GetTargetReply struct

+ CapabilityID uint32

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

+ func (*GetTargetReply) ProtoMessage()

+ func (x *GetTargetReply) GetCapabilityID() uint32

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

+ func (x *GetTargetReply) Reset()

+ func (x *GetTargetReply) String() string

+ type GetTargetRequest struct

+ Id string

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

+ func (*GetTargetRequest) ProtoMessage()

+ func (x *GetTargetRequest) GetId() string

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

+ func (x *GetTargetRequest) Reset()

+ func (x *GetTargetRequest) String() string

+ type GetTransactionStatusReply struct

+ TransactionStatus TransactionStatus

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

+ func (*GetTransactionStatusReply) ProtoMessage()

+ func (x *GetTransactionStatusReply) GetTransactionStatus() TransactionStatus

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

+ func (x *GetTransactionStatusReply) Reset()

+ func (x *GetTransactionStatusReply) String() string

+ type GetTransactionStatusRequest struct

+ TransactionId string

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

+ func (*GetTransactionStatusRequest) ProtoMessage()

+ func (x *GetTransactionStatusRequest) GetTransactionId() string

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

+ func (x *GetTransactionStatusRequest) Reset()

+ func (x *GetTransactionStatusRequest) String() string

+ type GetTriggerReply struct

+ CapabilityID uint32

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

+ func (*GetTriggerReply) ProtoMessage()

+ func (x *GetTriggerReply) GetCapabilityID() uint32

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

+ func (x *GetTriggerReply) Reset()

+ func (x *GetTriggerReply) String() string

+ type GetTriggerRequest struct

+ Id string

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

+ func (*GetTriggerRequest) ProtoMessage()

+ func (x *GetTriggerRequest) GetId() string

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

+ func (x *GetTriggerRequest) Reset()

+ func (x *GetTriggerRequest) String() string

+ type GetValueForKeyRequest struct

+ Key string

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

+ func (*GetValueForKeyRequest) ProtoMessage()

+ func (x *GetValueForKeyRequest) GetKey() string

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

+ func (x *GetValueForKeyRequest) Reset()

+ func (x *GetValueForKeyRequest) String() string

+ type GetValueForKeyResponse struct

+ Value []byte

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

+ func (*GetValueForKeyResponse) ProtoMessage()

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

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

+ func (x *GetValueForKeyResponse) Reset()

+ func (x *GetValueForKeyResponse) String() string

+ type Head struct

+ Hash []byte

+ Height string

+ Timestamp uint64

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

+ func (*Head) ProtoMessage()

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

+ func (x *Head) GetHeight() string

+ func (x *Head) GetTimestamp() uint64

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

+ func (x *Head) Reset()

+ func (x *Head) String() string

+ type HealthReportReply struct

+ HealthReport map[string]string

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

+ func (*HealthReportReply) ProtoMessage()

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

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

+ func (x *HealthReportReply) Reset()

+ func (x *HealthReportReply) String() string

+ type KeyValueStoreClient interface

+ GetValueForKey func(ctx context.Context, in *GetValueForKeyRequest, opts ...grpc.CallOption) (*GetValueForKeyResponse, error)

+ StoreKeyValue func(ctx context.Context, in *StoreKeyValueRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewKeyValueStoreClient(cc grpc.ClientConnInterface) KeyValueStoreClient

+ type KeyValueStoreServer interface

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

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

+ type KeystoreClient interface

+ Accounts func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AccountsReply, error)

+ Sign func(ctx context.Context, in *SignRequest, opts ...grpc.CallOption) (*SignReply, error)

+ func NewKeystoreClient(cc grpc.ClientConnInterface) KeystoreClient

+ type KeystoreServer interface

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

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

+ type LatestBlockHeightReply struct

+ BlockHeight uint64

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

+ func (*LatestBlockHeightReply) ProtoMessage()

+ func (x *LatestBlockHeightReply) GetBlockHeight() uint64

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

+ func (x *LatestBlockHeightReply) Reset()

+ func (x *LatestBlockHeightReply) String() string

+ type LatestBlockHeightRequest struct

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

+ func (*LatestBlockHeightRequest) ProtoMessage()

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

+ func (x *LatestBlockHeightRequest) Reset()

+ func (x *LatestBlockHeightRequest) String() string

+ type LatestConfigDetailsReply struct

+ ChangedInBlock uint64

+ ConfigDigest []byte

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

+ func (*LatestConfigDetailsReply) ProtoMessage()

+ func (x *LatestConfigDetailsReply) GetChangedInBlock() uint64

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

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

+ func (x *LatestConfigDetailsReply) Reset()

+ func (x *LatestConfigDetailsReply) String() string

+ type LatestConfigDetailsRequest struct

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

+ func (*LatestConfigDetailsRequest) ProtoMessage()

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

+ func (x *LatestConfigDetailsRequest) Reset()

+ func (x *LatestConfigDetailsRequest) String() string

+ type LatestConfigDigestAndEpochReply struct

+ ConfigDigest []byte

+ Epoch uint32

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

+ func (*LatestConfigDigestAndEpochReply) ProtoMessage()

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

+ func (x *LatestConfigDigestAndEpochReply) GetEpoch() uint32

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

+ func (x *LatestConfigDigestAndEpochReply) Reset()

+ func (x *LatestConfigDigestAndEpochReply) String() string

+ type LatestConfigDigestAndEpochRequest struct

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

+ func (*LatestConfigDigestAndEpochRequest) ProtoMessage()

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

+ func (x *LatestConfigDigestAndEpochRequest) Reset()

+ func (x *LatestConfigDigestAndEpochRequest) String() string

+ type LatestConfigReply struct

+ ContractConfig *ContractConfig

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

+ func (*LatestConfigReply) ProtoMessage()

+ func (x *LatestConfigReply) GetContractConfig() *ContractConfig

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

+ func (x *LatestConfigReply) Reset()

+ func (x *LatestConfigReply) String() string

+ type LatestConfigRequest struct

+ ChangedInBlock uint64

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

+ func (*LatestConfigRequest) ProtoMessage()

+ func (x *LatestConfigRequest) GetChangedInBlock() uint64

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

+ func (x *LatestConfigRequest) Reset()

+ func (x *LatestConfigRequest) String() string

+ type LatestHeadReply struct

+ Head *Head

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

+ func (*LatestHeadReply) ProtoMessage()

+ func (x *LatestHeadReply) GetHead() *Head

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

+ func (x *LatestHeadReply) Reset()

+ func (x *LatestHeadReply) String() string

+ type LatestHeadRequest struct

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

+ func (*LatestHeadRequest) ProtoMessage()

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

+ func (x *LatestHeadRequest) Reset()

+ func (x *LatestHeadRequest) String() string

+ type LatestRoundRequestedReply struct

+ ConfigDigest []byte

+ Epoch uint32

+ Round uint32

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

+ func (*LatestRoundRequestedReply) ProtoMessage()

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

+ func (x *LatestRoundRequestedReply) GetEpoch() uint32

+ func (x *LatestRoundRequestedReply) GetRound() uint32

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

+ func (x *LatestRoundRequestedReply) Reset()

+ func (x *LatestRoundRequestedReply) String() string

+ type LatestRoundRequestedRequest struct

+ Lookback int64

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

+ func (*LatestRoundRequestedRequest) ProtoMessage()

+ func (x *LatestRoundRequestedRequest) GetLookback() int64

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

+ func (x *LatestRoundRequestedRequest) Reset()

+ func (x *LatestRoundRequestedRequest) String() string

+ type LatestTransmissionDetailsReply struct

+ ConfigDigest []byte

+ Epoch uint32

+ LatestAnswer *BigInt

+ LatestTimestamp *timestamppb.Timestamp

+ Round uint32

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

+ func (*LatestTransmissionDetailsReply) ProtoMessage()

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

+ func (x *LatestTransmissionDetailsReply) GetEpoch() uint32

+ func (x *LatestTransmissionDetailsReply) GetLatestAnswer() *BigInt

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

+ func (x *LatestTransmissionDetailsReply) GetRound() uint32

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

+ func (x *LatestTransmissionDetailsReply) Reset()

+ func (x *LatestTransmissionDetailsReply) String() string

+ type LatestTransmissionDetailsRequest struct

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

+ func (*LatestTransmissionDetailsRequest) ProtoMessage()

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

+ func (x *LatestTransmissionDetailsRequest) Reset()

+ func (x *LatestTransmissionDetailsRequest) String() string

+ type Limit struct

+ Count uint64

+ Cursor *string

+ Direction *CursorDirection

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

+ func (*Limit) ProtoMessage()

+ func (x *Limit) GetCount() uint64

+ func (x *Limit) GetCursor() string

+ func (x *Limit) GetDirection() CursorDirection

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

+ func (x *Limit) Reset()

+ func (x *Limit) String() string

+ type LimitAndSort struct

+ Limit *Limit

+ SortBy []*SortBy

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

+ func (*LimitAndSort) ProtoMessage()

+ func (x *LimitAndSort) GetLimit() *Limit

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

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

+ func (x *LimitAndSort) Reset()

+ func (x *LimitAndSort) String() string

+ type ListNodeStatusesReply struct

+ NextPageToken string

+ Nodes []*NodeStatus

+ Total int32

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

+ func (*ListNodeStatusesReply) ProtoMessage()

+ func (x *ListNodeStatusesReply) GetNextPageToken() string

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

+ func (x *ListNodeStatusesReply) GetTotal() int32

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

+ func (x *ListNodeStatusesReply) Reset()

+ func (x *ListNodeStatusesReply) String() string

+ type ListNodeStatusesRequest struct

+ PageSize int32

+ PageToken string

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

+ func (*ListNodeStatusesRequest) ProtoMessage()

+ func (x *ListNodeStatusesRequest) GetPageSize() int32

+ func (x *ListNodeStatusesRequest) GetPageToken() string

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

+ func (x *ListNodeStatusesRequest) Reset()

+ func (x *ListNodeStatusesRequest) String() string

+ type ListReply struct

+ CapabilityID []uint32

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

+ func (*ListReply) ProtoMessage()

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

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

+ func (x *ListReply) Reset()

+ func (x *ListReply) String() string

+ type LocalNodeReply struct

+ CapabilityDONs []*DON

+ PeerID []byte

+ WorkflowDON *DON

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

+ func (*LocalNodeReply) ProtoMessage()

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

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

+ func (x *LocalNodeReply) GetWorkflowDON() *DON

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

+ func (x *LocalNodeReply) Reset()

+ func (x *LocalNodeReply) String() string

+ type MaxReportLengthReply struct

+ Max int64

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

+ func (*MaxReportLengthReply) ProtoMessage()

+ func (x *MaxReportLengthReply) GetMax() int64

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

+ func (x *MaxReportLengthReply) Reset()

+ func (x *MaxReportLengthReply) String() string

+ type MaxReportLengthRequest struct

+ N int64

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

+ func (*MaxReportLengthRequest) ProtoMessage()

+ func (x *MaxReportLengthRequest) GetN() int64

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

+ func (x *MaxReportLengthRequest) Reset()

+ func (x *MaxReportLengthRequest) String() string

+ type MedianContractClient interface

+ LatestRoundRequested func(ctx context.Context, in *LatestRoundRequestedRequest, opts ...grpc.CallOption) (*LatestRoundRequestedReply, error)

+ LatestTransmissionDetails func(ctx context.Context, in *LatestTransmissionDetailsRequest, ...) (*LatestTransmissionDetailsReply, error)

+ func NewMedianContractClient(cc grpc.ClientConnInterface) MedianContractClient

+ type MedianContractServer interface

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

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

+ type MedianFromReportReply struct

+ Median *BigInt

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

+ func (*MedianFromReportReply) ProtoMessage()

+ func (x *MedianFromReportReply) GetMedian() *BigInt

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

+ func (x *MedianFromReportReply) Reset()

+ func (x *MedianFromReportReply) String() string

+ type MedianFromReportRequest struct

+ Report []byte

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

+ func (*MedianFromReportRequest) ProtoMessage()

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

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

+ func (x *MedianFromReportRequest) Reset()

+ func (x *MedianFromReportRequest) String() string

+ type NameReply struct

+ Name string

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

+ func (*NameReply) ProtoMessage()

+ func (x *NameReply) GetName() string

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

+ func (x *NameReply) Reset()

+ func (x *NameReply) String() string

+ type NewChainWriterReply struct

+ ChainWriterID uint32

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

+ func (*NewChainWriterReply) ProtoMessage()

+ func (x *NewChainWriterReply) GetChainWriterID() uint32

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

+ func (x *NewChainWriterReply) Reset()

+ func (x *NewChainWriterReply) String() string

+ type NewChainWriterRequest struct

+ ChainWriterConfig []byte

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

+ func (*NewChainWriterRequest) ProtoMessage()

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

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

+ func (x *NewChainWriterRequest) Reset()

+ func (x *NewChainWriterRequest) String() string

+ type NewConfigProviderReply struct

+ ConfigProviderID uint32

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

+ func (*NewConfigProviderReply) ProtoMessage()

+ func (x *NewConfigProviderReply) GetConfigProviderID() uint32

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

+ func (x *NewConfigProviderReply) Reset()

+ func (x *NewConfigProviderReply) String() string

+ type NewConfigProviderRequest struct

+ RelayArgs *RelayArgs

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

+ func (*NewConfigProviderRequest) ProtoMessage()

+ func (x *NewConfigProviderRequest) GetRelayArgs() *RelayArgs

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

+ func (x *NewConfigProviderRequest) Reset()

+ func (x *NewConfigProviderRequest) String() string

+ type NewContractReaderReply struct

+ ContractReaderID uint32

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

+ func (*NewContractReaderReply) ProtoMessage()

+ func (x *NewContractReaderReply) GetContractReaderID() uint32

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

+ func (x *NewContractReaderReply) Reset()

+ func (x *NewContractReaderReply) String() string

+ type NewContractReaderRequest struct

+ ContractReaderConfig []byte

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

+ func (*NewContractReaderRequest) ProtoMessage()

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

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

+ func (x *NewContractReaderRequest) Reset()

+ func (x *NewContractReaderRequest) String() string

+ type NewMedianFactoryReply struct

+ ReportingPluginFactoryID uint32

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

+ func (*NewMedianFactoryReply) ProtoMessage()

+ func (x *NewMedianFactoryReply) GetReportingPluginFactoryID() uint32

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

+ func (x *NewMedianFactoryReply) Reset()

+ func (x *NewMedianFactoryReply) String() string

+ type NewMedianFactoryRequest struct

+ ContractID string

+ DataSourceID uint32

+ ErrorLogID uint32

+ GasPriceSubunitsDataSourceID uint32

+ JuelsPerFeeCoinDataSourceID uint32

+ MedianProviderID uint32

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

+ func (*NewMedianFactoryRequest) ProtoMessage()

+ func (x *NewMedianFactoryRequest) GetContractID() string

+ func (x *NewMedianFactoryRequest) GetDataSourceID() uint32

+ func (x *NewMedianFactoryRequest) GetErrorLogID() uint32

+ func (x *NewMedianFactoryRequest) GetGasPriceSubunitsDataSourceID() uint32

+ func (x *NewMedianFactoryRequest) GetJuelsPerFeeCoinDataSourceID() uint32

+ func (x *NewMedianFactoryRequest) GetMedianProviderID() uint32

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

+ func (x *NewMedianFactoryRequest) Reset()

+ func (x *NewMedianFactoryRequest) String() string

+ type NewPluginProviderReply struct

+ PluginProviderID uint32

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

+ func (*NewPluginProviderReply) ProtoMessage()

+ func (x *NewPluginProviderReply) GetPluginProviderID() uint32

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

+ func (x *NewPluginProviderReply) Reset()

+ func (x *NewPluginProviderReply) String() string

+ type NewPluginProviderRequest struct

+ PluginArgs *PluginArgs

+ RelayArgs *RelayArgs

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

+ func (*NewPluginProviderRequest) ProtoMessage()

+ func (x *NewPluginProviderRequest) GetPluginArgs() *PluginArgs

+ func (x *NewPluginProviderRequest) GetRelayArgs() *RelayArgs

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

+ func (x *NewPluginProviderRequest) Reset()

+ func (x *NewPluginProviderRequest) String() string

+ type NewRelayerReply struct

+ RelayerID uint32

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

+ func (*NewRelayerReply) ProtoMessage()

+ func (x *NewRelayerReply) GetRelayerID() uint32

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

+ func (x *NewRelayerReply) Reset()

+ func (x *NewRelayerReply) String() string

+ type NewRelayerRequest struct

+ CapabilityRegistryID uint32

+ Config string

+ KeystoreID uint32

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

+ func (*NewRelayerRequest) ProtoMessage()

+ func (x *NewRelayerRequest) GetCapabilityRegistryID() uint32

+ func (x *NewRelayerRequest) GetConfig() string

+ func (x *NewRelayerRequest) GetKeystoreID() uint32

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

+ func (x *NewRelayerRequest) Reset()

+ func (x *NewRelayerRequest) String() string

+ type NewReportingPluginFactoryReply struct

+ ID uint32

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

+ func (*NewReportingPluginFactoryReply) ProtoMessage()

+ func (x *NewReportingPluginFactoryReply) GetID() uint32

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

+ func (x *NewReportingPluginFactoryReply) Reset()

+ func (x *NewReportingPluginFactoryReply) String() string

+ type NewReportingPluginFactoryRequest struct

+ CapRegistryID uint32

+ ErrorLogID uint32

+ KeyValueStoreID uint32

+ PipelineRunnerID uint32

+ ProviderID uint32

+ RelayerSetID uint32

+ ReportingPluginServiceConfig *ReportingPluginServiceConfig

+ TelemetryID uint32

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

+ func (*NewReportingPluginFactoryRequest) ProtoMessage()

+ func (x *NewReportingPluginFactoryRequest) GetCapRegistryID() uint32

+ func (x *NewReportingPluginFactoryRequest) GetErrorLogID() uint32

+ func (x *NewReportingPluginFactoryRequest) GetKeyValueStoreID() uint32

+ func (x *NewReportingPluginFactoryRequest) GetPipelineRunnerID() uint32

+ func (x *NewReportingPluginFactoryRequest) GetProviderID() uint32

+ func (x *NewReportingPluginFactoryRequest) GetRelayerSetID() uint32

+ func (x *NewReportingPluginFactoryRequest) GetReportingPluginServiceConfig() *ReportingPluginServiceConfig

+ func (x *NewReportingPluginFactoryRequest) GetTelemetryID() uint32

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

+ func (x *NewReportingPluginFactoryRequest) Reset()

+ func (x *NewReportingPluginFactoryRequest) String() string

+ type NewReportingPluginReply struct

+ ReportingPluginID uint32

+ ReportingPluginInfo *ReportingPluginInfo

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

+ func (*NewReportingPluginReply) ProtoMessage()

+ func (x *NewReportingPluginReply) GetReportingPluginID() uint32

+ func (x *NewReportingPluginReply) GetReportingPluginInfo() *ReportingPluginInfo

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

+ func (x *NewReportingPluginReply) Reset()

+ func (x *NewReportingPluginReply) String() string

+ type NewReportingPluginRequest struct

+ ReportingPluginConfig *ReportingPluginConfig

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

+ func (*NewReportingPluginRequest) ProtoMessage()

+ func (x *NewReportingPluginRequest) GetReportingPluginConfig() *ReportingPluginConfig

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

+ func (x *NewReportingPluginRequest) Reset()

+ func (x *NewReportingPluginRequest) String() string

+ type NodeStatus struct

+ ChainID string

+ Config string

+ Name string

+ State string

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

+ func (*NodeStatus) ProtoMessage()

+ func (x *NodeStatus) GetChainID() string

+ func (x *NodeStatus) GetConfig() string

+ func (x *NodeStatus) GetName() string

+ func (x *NodeStatus) GetState() string

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

+ func (x *NodeStatus) Reset()

+ func (x *NodeStatus) String() string

+ type ObservationReply struct

+ Observation []byte

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

+ func (*ObservationReply) ProtoMessage()

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

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

+ func (x *ObservationReply) Reset()

+ func (x *ObservationReply) String() string

+ type ObservationRequest struct

+ Query []byte

+ ReportTimestamp *ReportTimestamp

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

+ func (*ObservationRequest) ProtoMessage()

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

+ func (x *ObservationRequest) GetReportTimestamp() *ReportTimestamp

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

+ func (x *ObservationRequest) Reset()

+ func (x *ObservationRequest) String() string

+ type ObserveReply struct

+ Value *BigInt

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

+ func (*ObserveReply) ProtoMessage()

+ func (x *ObserveReply) GetValue() *BigInt

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

+ func (x *ObserveReply) Reset()

+ func (x *ObserveReply) String() string

+ type ObserveRequest struct

+ ReportTimestamp *ReportTimestamp

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

+ func (*ObserveRequest) ProtoMessage()

+ func (x *ObserveRequest) GetReportTimestamp() *ReportTimestamp

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

+ func (x *ObserveRequest) Reset()

+ func (x *ObserveRequest) String() string

+ type OffchainConfigDigesterClient interface

+ ConfigDigest func(ctx context.Context, in *ConfigDigestRequest, opts ...grpc.CallOption) (*ConfigDigestReply, error)

+ ConfigDigestPrefix func(ctx context.Context, in *ConfigDigestPrefixRequest, opts ...grpc.CallOption) (*ConfigDigestPrefixReply, error)

+ func NewOffchainConfigDigesterClient(cc grpc.ClientConnInterface) OffchainConfigDigesterClient

+ type OffchainConfigDigesterServer interface

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

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

+ type OnchainConfig struct

+ Max *BigInt

+ Min *BigInt

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

+ func (*OnchainConfig) ProtoMessage()

+ func (x *OnchainConfig) GetMax() *BigInt

+ func (x *OnchainConfig) GetMin() *BigInt

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

+ func (x *OnchainConfig) Reset()

+ func (x *OnchainConfig) String() string

+ type OnchainConfigCodecClient interface

+ Decode func(ctx context.Context, in *DecodeRequest, opts ...grpc.CallOption) (*DecodeReply, error)

+ Encode func(ctx context.Context, in *EncodeRequest, opts ...grpc.CallOption) (*EncodeReply, error)

+ func NewOnchainConfigCodecClient(cc grpc.ClientConnInterface) OnchainConfigCodecClient

+ type OnchainConfigCodecServer interface

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

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

+ type Options struct

+ MaxTaskDuration *durationpb.Duration

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

+ func (*Options) ProtoMessage()

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

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

+ func (x *Options) Reset()

+ func (x *Options) String() string

+ type Or struct

+ Expr []*Expression

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

+ func (*Or) ProtoMessage()

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

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

+ func (x *Or) Reset()

+ func (x *Or) String() string

+ type ParsedAttributedObservation struct

+ GasPriceSubunits *BigInt

+ JulesPerFeeCoin *BigInt

+ Observer uint32

+ Timestamp uint32

+ Value *BigInt

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

+ func (*ParsedAttributedObservation) ProtoMessage()

+ func (x *ParsedAttributedObservation) GetGasPriceSubunits() *BigInt

+ func (x *ParsedAttributedObservation) GetJulesPerFeeCoin() *BigInt

+ func (x *ParsedAttributedObservation) GetObserver() uint32

+ func (x *ParsedAttributedObservation) GetTimestamp() uint32

+ func (x *ParsedAttributedObservation) GetValue() *BigInt

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

+ func (x *ParsedAttributedObservation) Reset()

+ func (x *ParsedAttributedObservation) String() string

+ type PipelineRunnerServiceClient interface

+ ExecuteRun func(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)

+ func NewPipelineRunnerServiceClient(cc grpc.ClientConnInterface) PipelineRunnerServiceClient

+ type PipelineRunnerServiceServer interface

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

+ type PluginArgs struct

+ PluginConfig []byte

+ TransmitterID string

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

+ func (*PluginArgs) ProtoMessage()

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

+ func (x *PluginArgs) GetTransmitterID() string

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

+ func (x *PluginArgs) Reset()

+ func (x *PluginArgs) String() string

+ type PluginMedianClient interface

+ NewMedianFactory func(ctx context.Context, in *NewMedianFactoryRequest, opts ...grpc.CallOption) (*NewMedianFactoryReply, error)

+ func NewPluginMedianClient(cc grpc.ClientConnInterface) PluginMedianClient

+ type PluginMedianServer interface

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

+ type PluginRelayerClient interface

+ NewRelayer func(ctx context.Context, in *NewRelayerRequest, opts ...grpc.CallOption) (*NewRelayerReply, error)

+ func NewPluginRelayerClient(cc grpc.ClientConnInterface) PluginRelayerClient

+ type PluginRelayerServer interface

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

+ type Primitive struct

+ Primitive isPrimitive_Primitive

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

+ func (*Primitive) ProtoMessage()

+ func (m *Primitive) GetPrimitive() isPrimitive_Primitive

+ func (x *Primitive) GetBlock() *Block

+ func (x *Primitive) GetComparator() *Comparator

+ func (x *Primitive) GetConfidence() Confidence

+ func (x *Primitive) GetTimestamp() *Timestamp

+ func (x *Primitive) GetTxHash() *TxHash

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

+ func (x *Primitive) Reset()

+ func (x *Primitive) String() string

+ type Primitive_Block struct

+ Block *Block

+ type Primitive_Comparator struct

+ Comparator *Comparator

+ type Primitive_Confidence struct

+ Confidence Confidence

+ type Primitive_Timestamp struct

+ Timestamp *Timestamp

+ type Primitive_TxHash struct

+ TxHash *TxHash

+ type QueryKeyFilter struct

+ Expression []*Expression

+ Key string

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

+ func (*QueryKeyFilter) ProtoMessage()

+ func (x *QueryKeyFilter) GetExpression() []*Expression

+ func (x *QueryKeyFilter) GetKey() string

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

+ func (x *QueryKeyFilter) Reset()

+ func (x *QueryKeyFilter) String() string

+ type QueryKeyReply struct

+ Sequences []*Sequence

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

+ func (*QueryKeyReply) ProtoMessage()

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

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

+ func (x *QueryKeyReply) Reset()

+ func (x *QueryKeyReply) String() string

+ type QueryKeyRequest struct

+ AsValueType bool

+ Contract *BoundContract

+ Filter *QueryKeyFilter

+ LimitAndSort *LimitAndSort

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

+ func (*QueryKeyRequest) ProtoMessage()

+ func (x *QueryKeyRequest) GetAsValueType() bool

+ func (x *QueryKeyRequest) GetContract() *BoundContract

+ func (x *QueryKeyRequest) GetFilter() *QueryKeyFilter

+ func (x *QueryKeyRequest) GetLimitAndSort() *LimitAndSort

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

+ func (x *QueryKeyRequest) Reset()

+ func (x *QueryKeyRequest) String() string

+ type QueryReply struct

+ Query []byte

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

+ func (*QueryReply) ProtoMessage()

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

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

+ func (x *QueryReply) Reset()

+ func (x *QueryReply) String() string

+ type QueryRequest struct

+ ReportTimestamp *ReportTimestamp

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

+ func (*QueryRequest) ProtoMessage()

+ func (x *QueryRequest) GetReportTimestamp() *ReportTimestamp

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

+ func (x *QueryRequest) Reset()

+ func (x *QueryRequest) String() string

+ type RelayArgs struct

+ ContractID string

+ ExternalJobID []byte

+ JobID int32

+ New bool

+ ProviderType string

+ RelayConfig []byte

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

+ func (*RelayArgs) ProtoMessage()

+ func (x *RelayArgs) GetContractID() string

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

+ func (x *RelayArgs) GetJobID() int32

+ func (x *RelayArgs) GetNew() bool

+ func (x *RelayArgs) GetProviderType() string

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

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

+ func (x *RelayArgs) Reset()

+ func (x *RelayArgs) String() string

+ type RelayID struct

+ ChainId string

+ Network string

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

+ func (*RelayID) ProtoMessage()

+ func (x *RelayID) GetChainId() string

+ func (x *RelayID) GetNetwork() string

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

+ func (x *RelayID) Reset()

+ func (x *RelayID) String() string

+ type RelayerClient interface

+ GetChainStatus func(ctx context.Context, in *GetChainStatusRequest, opts ...grpc.CallOption) (*GetChainStatusReply, error)

+ LatestHead func(ctx context.Context, in *LatestHeadRequest, opts ...grpc.CallOption) (*LatestHeadReply, error)

+ ListNodeStatuses func(ctx context.Context, in *ListNodeStatusesRequest, opts ...grpc.CallOption) (*ListNodeStatusesReply, error)

+ NewChainWriter func(ctx context.Context, in *NewChainWriterRequest, opts ...grpc.CallOption) (*NewChainWriterReply, error)

+ NewConfigProvider func(ctx context.Context, in *NewConfigProviderRequest, opts ...grpc.CallOption) (*NewConfigProviderReply, error)

+ NewContractReader func(ctx context.Context, in *NewContractReaderRequest, opts ...grpc.CallOption) (*NewContractReaderReply, error)

+ NewPluginProvider func(ctx context.Context, in *NewPluginProviderRequest, opts ...grpc.CallOption) (*NewPluginProviderReply, error)

+ Transact func(ctx context.Context, in *TransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewRelayerClient(cc grpc.ClientConnInterface) RelayerClient

+ type RelayerServer interface

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

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

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

+ NewChainWriter func(context.Context, *NewChainWriterRequest) (*NewChainWriterReply, error)

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

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

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

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

+ type ReportCodecClient interface

+ BuildReport func(ctx context.Context, in *BuildReportRequest, opts ...grpc.CallOption) (*BuildReportReply, error)

+ MaxReportLength func(ctx context.Context, in *MaxReportLengthRequest, opts ...grpc.CallOption) (*MaxReportLengthReply, error)

+ MedianFromReport func(ctx context.Context, in *MedianFromReportRequest, opts ...grpc.CallOption) (*MedianFromReportReply, error)

+ func NewReportCodecClient(cc grpc.ClientConnInterface) ReportCodecClient

+ type ReportCodecServer interface

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

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

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

+ type ReportContext struct

+ ExtraHash []byte

+ ReportTimestamp *ReportTimestamp

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

+ func (*ReportContext) ProtoMessage()

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

+ func (x *ReportContext) GetReportTimestamp() *ReportTimestamp

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

+ func (x *ReportContext) Reset()

+ func (x *ReportContext) String() string

+ type ReportReply struct

+ Report []byte

+ ShouldReport bool

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

+ func (*ReportReply) ProtoMessage()

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

+ func (x *ReportReply) GetShouldReport() bool

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

+ func (x *ReportReply) Reset()

+ func (x *ReportReply) String() string

+ type ReportRequest struct

+ Observations []*AttributedObservation

+ Query []byte

+ ReportTimestamp *ReportTimestamp

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

+ func (*ReportRequest) ProtoMessage()

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

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

+ func (x *ReportRequest) GetReportTimestamp() *ReportTimestamp

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

+ func (x *ReportRequest) Reset()

+ func (x *ReportRequest) String() string

+ type ReportTimestamp struct

+ ConfigDigest []byte

+ Epoch uint32

+ Round uint32

+ func ReportTimestampToPb(ts libocr.ReportTimestamp) *ReportTimestamp

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

+ func (*ReportTimestamp) ProtoMessage()

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

+ func (x *ReportTimestamp) GetEpoch() uint32

+ func (x *ReportTimestamp) GetRound() uint32

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

+ func (x *ReportTimestamp) Reset()

+ func (x *ReportTimestamp) String() string

+ type ReportingPluginClient interface

+ Close func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Observation func(ctx context.Context, in *ObservationRequest, opts ...grpc.CallOption) (*ObservationReply, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryReply, error)

+ Report func(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*ReportReply, error)

+ ShouldAcceptFinalizedReport func(ctx context.Context, in *ShouldAcceptFinalizedReportRequest, ...) (*ShouldAcceptFinalizedReportReply, error)

+ ShouldTransmitAcceptedReport func(ctx context.Context, in *ShouldTransmitAcceptedReportRequest, ...) (*ShouldTransmitAcceptedReportReply, error)

+ func NewReportingPluginClient(cc grpc.ClientConnInterface) ReportingPluginClient

+ type ReportingPluginConfig struct

+ ConfigDigest []byte

+ EstimatedRoundInterval int64

+ F uint32

+ MaxDurationObservation int64

+ MaxDurationQuery int64

+ MaxDurationReport int64

+ MaxDurationShouldAcceptFinalizedReport int64

+ MaxDurationShouldTransmitAcceptedReport int64

+ N uint32

+ OffchainConfig []byte

+ OnchainConfig []byte

+ OracleID uint32

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

+ func (*ReportingPluginConfig) ProtoMessage()

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

+ func (x *ReportingPluginConfig) GetEstimatedRoundInterval() int64

+ func (x *ReportingPluginConfig) GetF() uint32

+ func (x *ReportingPluginConfig) GetMaxDurationObservation() int64

+ func (x *ReportingPluginConfig) GetMaxDurationQuery() int64

+ func (x *ReportingPluginConfig) GetMaxDurationReport() int64

+ func (x *ReportingPluginConfig) GetMaxDurationShouldAcceptFinalizedReport() int64

+ func (x *ReportingPluginConfig) GetMaxDurationShouldTransmitAcceptedReport() int64

+ func (x *ReportingPluginConfig) GetN() uint32

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

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

+ func (x *ReportingPluginConfig) GetOracleID() uint32

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

+ func (x *ReportingPluginConfig) Reset()

+ func (x *ReportingPluginConfig) String() string

+ type ReportingPluginFactoryClient interface

+ NewReportingPlugin func(ctx context.Context, in *NewReportingPluginRequest, opts ...grpc.CallOption) (*NewReportingPluginReply, error)

+ func NewReportingPluginFactoryClient(cc grpc.ClientConnInterface) ReportingPluginFactoryClient

+ type ReportingPluginFactoryServer interface

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

+ type ReportingPluginInfo struct

+ Name string

+ ReportingPluginLimits *ReportingPluginLimits

+ UniqueReports bool

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

+ func (*ReportingPluginInfo) ProtoMessage()

+ func (x *ReportingPluginInfo) GetName() string

+ func (x *ReportingPluginInfo) GetReportingPluginLimits() *ReportingPluginLimits

+ func (x *ReportingPluginInfo) GetUniqueReports() bool

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

+ func (x *ReportingPluginInfo) Reset()

+ func (x *ReportingPluginInfo) String() string

+ type ReportingPluginLimits struct

+ MaxObservationLength uint64

+ MaxQueryLength uint64

+ MaxReportLength uint64

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

+ func (*ReportingPluginLimits) ProtoMessage()

+ func (x *ReportingPluginLimits) GetMaxObservationLength() uint64

+ func (x *ReportingPluginLimits) GetMaxQueryLength() uint64

+ func (x *ReportingPluginLimits) GetMaxReportLength() uint64

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

+ func (x *ReportingPluginLimits) Reset()

+ func (x *ReportingPluginLimits) String() string

+ type ReportingPluginServer interface

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

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

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

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

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

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

+ type ReportingPluginServiceClient interface

+ NewReportingPluginFactory func(ctx context.Context, in *NewReportingPluginFactoryRequest, ...) (*NewReportingPluginFactoryReply, error)

+ NewValidationService func(ctx context.Context, in *ValidationServiceRequest, opts ...grpc.CallOption) (*ValidationServiceResponse, error)

+ func NewReportingPluginServiceClient(cc grpc.ClientConnInterface) ReportingPluginServiceClient

+ type ReportingPluginServiceConfig struct

+ Command string

+ PluginConfig string

+ PluginName string

+ ProviderType string

+ TelemetryType string

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

+ func (*ReportingPluginServiceConfig) ProtoMessage()

+ func (x *ReportingPluginServiceConfig) GetCommand() string

+ func (x *ReportingPluginServiceConfig) GetPluginConfig() string

+ func (x *ReportingPluginServiceConfig) GetPluginName() string

+ func (x *ReportingPluginServiceConfig) GetProviderType() string

+ func (x *ReportingPluginServiceConfig) GetTelemetryType() string

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

+ func (x *ReportingPluginServiceConfig) Reset()

+ func (x *ReportingPluginServiceConfig) String() string

+ type ReportingPluginServiceServer interface

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

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

+ type RunRequest struct

+ Options *Options

+ Spec string

+ Vars *structpb.Struct

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

+ func (*RunRequest) ProtoMessage()

+ func (x *RunRequest) GetOptions() *Options

+ func (x *RunRequest) GetSpec() string

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

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

+ func (x *RunRequest) Reset()

+ func (x *RunRequest) String() string

+ type RunResponse struct

+ Results []*TaskResult

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

+ func (*RunResponse) ProtoMessage()

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

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

+ func (x *RunResponse) Reset()

+ func (x *RunResponse) String() string

+ type SaveErrorRequest struct

+ Message string

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

+ func (*SaveErrorRequest) ProtoMessage()

+ func (x *SaveErrorRequest) GetMessage() string

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

+ func (x *SaveErrorRequest) Reset()

+ func (x *SaveErrorRequest) String() string

+ type Sequence struct

+ Data *VersionedBytes

+ Head *Head

+ SequenceCursor string

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

+ func (*Sequence) ProtoMessage()

+ func (x *Sequence) GetData() *VersionedBytes

+ func (x *Sequence) GetHead() *Head

+ func (x *Sequence) GetSequenceCursor() string

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

+ func (x *Sequence) Reset()

+ func (x *Sequence) String() string

+ type ServiceClient interface

+ Close func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ HealthReport func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthReportReply, error)

+ Name func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NameReply, error)

+ Ready func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

+ type ServiceServer interface

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

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

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

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

+ type ShouldAcceptFinalizedReportReply struct

+ ShouldAccept bool

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

+ func (*ShouldAcceptFinalizedReportReply) ProtoMessage()

+ func (x *ShouldAcceptFinalizedReportReply) GetShouldAccept() bool

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

+ func (x *ShouldAcceptFinalizedReportReply) Reset()

+ func (x *ShouldAcceptFinalizedReportReply) String() string

+ type ShouldAcceptFinalizedReportRequest struct

+ Report []byte

+ ReportTimestamp *ReportTimestamp

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

+ func (*ShouldAcceptFinalizedReportRequest) ProtoMessage()

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

+ func (x *ShouldAcceptFinalizedReportRequest) GetReportTimestamp() *ReportTimestamp

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

+ func (x *ShouldAcceptFinalizedReportRequest) Reset()

+ func (x *ShouldAcceptFinalizedReportRequest) String() string

+ type ShouldTransmitAcceptedReportReply struct

+ ShouldTransmit bool

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

+ func (*ShouldTransmitAcceptedReportReply) ProtoMessage()

+ func (x *ShouldTransmitAcceptedReportReply) GetShouldTransmit() bool

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

+ func (x *ShouldTransmitAcceptedReportReply) Reset()

+ func (x *ShouldTransmitAcceptedReportReply) String() string

+ type ShouldTransmitAcceptedReportRequest struct

+ Report []byte

+ ReportTimestamp *ReportTimestamp

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

+ func (*ShouldTransmitAcceptedReportRequest) ProtoMessage()

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

+ func (x *ShouldTransmitAcceptedReportRequest) GetReportTimestamp() *ReportTimestamp

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

+ func (x *ShouldTransmitAcceptedReportRequest) Reset()

+ func (x *ShouldTransmitAcceptedReportRequest) String() string

+ type SignReply struct

+ SignedData []byte

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

+ func (*SignReply) ProtoMessage()

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

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

+ func (x *SignReply) Reset()

+ func (x *SignReply) String() string

+ type SignRequest struct

+ Account string

+ Data []byte

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

+ func (*SignRequest) ProtoMessage()

+ func (x *SignRequest) GetAccount() string

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

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

+ func (x *SignRequest) Reset()

+ func (x *SignRequest) String() string

+ type SortBy struct

+ Direction SortDirection

+ SortType SortType

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

+ func (*SortBy) ProtoMessage()

+ func (x *SortBy) GetDirection() SortDirection

+ func (x *SortBy) GetSortType() SortType

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

+ func (x *SortBy) Reset()

+ func (x *SortBy) String() string

+ type SortDirection int32

+ const SortDirection_Asc

+ const SortDirection_Desc

+ func (SortDirection) Descriptor() protoreflect.EnumDescriptor

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

+ func (SortDirection) Type() protoreflect.EnumType

+ func (x SortDirection) Enum() *SortDirection

+ func (x SortDirection) Number() protoreflect.EnumNumber

+ func (x SortDirection) String() string

+ type SortType int32

+ const SortType_SortBlock

+ const SortType_SortSequence

+ const SortType_SortTimestamp

+ func (SortType) Descriptor() protoreflect.EnumDescriptor

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

+ func (SortType) Type() protoreflect.EnumType

+ func (x SortType) Enum() *SortType

+ func (x SortType) Number() protoreflect.EnumNumber

+ func (x SortType) String() string

+ type StarknetMessageHash struct

+ Hash *BigInt

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

+ func (*StarknetMessageHash) ProtoMessage()

+ func (x *StarknetMessageHash) GetHash() *BigInt

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

+ func (x *StarknetMessageHash) Reset()

+ func (x *StarknetMessageHash) String() string

+ type StarknetSignature struct

+ X *BigInt

+ Y *BigInt

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

+ func (*StarknetSignature) ProtoMessage()

+ func (x *StarknetSignature) GetX() *BigInt

+ func (x *StarknetSignature) GetY() *BigInt

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

+ func (x *StarknetSignature) Reset()

+ func (x *StarknetSignature) String() string

+ type StoreKeyValueRequest struct

+ Key string

+ Value []byte

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

+ func (*StoreKeyValueRequest) ProtoMessage()

+ func (x *StoreKeyValueRequest) GetKey() string

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

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

+ func (x *StoreKeyValueRequest) Reset()

+ func (x *StoreKeyValueRequest) String() string

+ type SubmitTransactionRequest struct

+ ContractName string

+ Meta *TransactionMeta

+ Method string

+ Params *VersionedBytes

+ ToAddress string

+ TransactionId string

+ Value *BigInt

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

+ func (*SubmitTransactionRequest) ProtoMessage()

+ func (x *SubmitTransactionRequest) GetContractName() string

+ func (x *SubmitTransactionRequest) GetMeta() *TransactionMeta

+ func (x *SubmitTransactionRequest) GetMethod() string

+ func (x *SubmitTransactionRequest) GetParams() *VersionedBytes

+ func (x *SubmitTransactionRequest) GetToAddress() string

+ func (x *SubmitTransactionRequest) GetTransactionId() string

+ func (x *SubmitTransactionRequest) GetValue() *BigInt

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

+ func (x *SubmitTransactionRequest) Reset()

+ func (x *SubmitTransactionRequest) String() string

+ type TaskResult struct

+ Error string

+ HasError bool

+ Id string

+ Index int32

+ IsTerminal bool

+ Type string

+ Value []byte

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

+ func (*TaskResult) ProtoMessage()

+ func (x *TaskResult) GetError() string

+ func (x *TaskResult) GetHasError() bool

+ func (x *TaskResult) GetId() string

+ func (x *TaskResult) GetIndex() int32

+ func (x *TaskResult) GetIsTerminal() bool

+ func (x *TaskResult) GetType() string

+ func (x *TaskResult) GetValue() []byte

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

+ func (x *TaskResult) Reset()

+ func (x *TaskResult) String() string

+ type TelemetryClient interface

+ Send func(ctx context.Context, in *TelemetryMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewTelemetryClient(cc grpc.ClientConnInterface) TelemetryClient

+ type TelemetryMessage struct

+ ContractID string

+ Payload []byte

+ RelayID *RelayID

+ TelemetryType string

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

+ func (*TelemetryMessage) ProtoMessage()

+ func (x *TelemetryMessage) GetContractID() string

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

+ func (x *TelemetryMessage) GetRelayID() *RelayID

+ func (x *TelemetryMessage) GetTelemetryType() string

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

+ func (x *TelemetryMessage) Reset()

+ func (x *TelemetryMessage) String() string

+ type TelemetryServer interface

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

+ type Timestamp struct

+ Operator ComparisonOperator

+ Timestamp uint64

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

+ func (*Timestamp) ProtoMessage()

+ func (x *Timestamp) GetOperator() ComparisonOperator

+ func (x *Timestamp) GetTimestamp() uint64

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

+ func (x *Timestamp) Reset()

+ func (x *Timestamp) String() string

+ type TransactionMeta struct

+ GasLimit *BigInt

+ WorkflowExecutionId string

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

+ func (*TransactionMeta) ProtoMessage()

+ func (x *TransactionMeta) GetGasLimit() *BigInt

+ func (x *TransactionMeta) GetWorkflowExecutionId() string

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

+ func (x *TransactionMeta) Reset()

+ func (x *TransactionMeta) String() string

+ type TransactionRequest struct

+ Amount *BigInt

+ BalanceCheck bool

+ From string

+ To string

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

+ func (*TransactionRequest) ProtoMessage()

+ func (x *TransactionRequest) GetAmount() *BigInt

+ func (x *TransactionRequest) GetBalanceCheck() bool

+ func (x *TransactionRequest) GetFrom() string

+ func (x *TransactionRequest) GetTo() string

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

+ func (x *TransactionRequest) Reset()

+ func (x *TransactionRequest) String() string

+ type TransactionStatus int32

+ const TransactionStatus_TRANSACTION_STATUS_FAILED

+ const TransactionStatus_TRANSACTION_STATUS_FATAL

+ const TransactionStatus_TRANSACTION_STATUS_FINALIZED

+ const TransactionStatus_TRANSACTION_STATUS_PENDING

+ const TransactionStatus_TRANSACTION_STATUS_UNCONFIRMED

+ const TransactionStatus_TRANSACTION_STATUS_UNKNOWN

+ func (TransactionStatus) Descriptor() protoreflect.EnumDescriptor

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

+ func (TransactionStatus) Type() protoreflect.EnumType

+ func (x TransactionStatus) Enum() *TransactionStatus

+ func (x TransactionStatus) Number() protoreflect.EnumNumber

+ func (x TransactionStatus) String() string

+ type TransmitReply struct

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

+ func (*TransmitReply) ProtoMessage()

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

+ func (x *TransmitReply) Reset()

+ func (x *TransmitReply) String() string

+ type TransmitRequest struct

+ AttributedOnchainSignatures []*AttributedOnchainSignature

+ Report []byte

+ ReportContext *ReportContext

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

+ func (*TransmitRequest) ProtoMessage()

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

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

+ func (x *TransmitRequest) GetReportContext() *ReportContext

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

+ func (x *TransmitRequest) Reset()

+ func (x *TransmitRequest) String() string

+ type TxHash struct

+ TxHash string

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

+ func (*TxHash) ProtoMessage()

+ func (x *TxHash) GetTxHash() string

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

+ func (x *TxHash) Reset()

+ func (x *TxHash) String() string

+ type UnbindRequest struct

+ Bindings []*BoundContract

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

+ func (*UnbindRequest) ProtoMessage()

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

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

+ func (x *UnbindRequest) Reset()

+ func (x *UnbindRequest) String() string

+ type UnimplementedCapabilitiesRegistryServer struct

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

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

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

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

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

+ func (UnimplementedCapabilitiesRegistryServer) GetTarget(context.Context, *GetTargetRequest) (*GetTargetReply, error)

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

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

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

+ type UnimplementedChainWriterServer struct

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

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

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

+ type UnimplementedCodecServer struct

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

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

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

+ type UnimplementedContractConfigTrackerServer struct

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

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

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

+ type UnimplementedContractReaderServer struct

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

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

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

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

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

+ type UnimplementedContractTransmitterServer struct

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

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

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

+ type UnimplementedDataSourceServer struct

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

+ type UnimplementedErrorLogServer struct

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

+ type UnimplementedKeyValueStoreServer struct

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

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

+ type UnimplementedKeystoreServer struct

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

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

+ type UnimplementedMedianContractServer struct

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

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

+ type UnimplementedOffchainConfigDigesterServer struct

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

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

+ type UnimplementedOnchainConfigCodecServer struct

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

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

+ type UnimplementedPipelineRunnerServiceServer struct

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

+ type UnimplementedPluginMedianServer struct

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

+ type UnimplementedPluginRelayerServer struct

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

+ type UnimplementedRelayerServer struct

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

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

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

+ func (UnimplementedRelayerServer) NewChainWriter(context.Context, *NewChainWriterRequest) (*NewChainWriterReply, error)

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

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

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

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

+ type UnimplementedReportCodecServer struct

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

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

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

+ type UnimplementedReportingPluginFactoryServer struct

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

+ type UnimplementedReportingPluginServer struct

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

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

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

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

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

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

+ type UnimplementedReportingPluginServiceServer struct

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

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

+ type UnimplementedServiceServer struct

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

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

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

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

+ type UnimplementedTelemetryServer struct

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

+ type UnimplementedValidationServiceServer struct

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

+ type UnsafeCapabilitiesRegistryServer interface

+ type UnsafeChainWriterServer interface

+ type UnsafeCodecServer interface

+ type UnsafeContractConfigTrackerServer interface

+ type UnsafeContractReaderServer interface

+ type UnsafeContractTransmitterServer interface

+ type UnsafeDataSourceServer interface

+ type UnsafeErrorLogServer interface

+ type UnsafeKeyValueStoreServer interface

+ type UnsafeKeystoreServer interface

+ type UnsafeMedianContractServer interface

+ type UnsafeOffchainConfigDigesterServer interface

+ type UnsafeOnchainConfigCodecServer interface

+ type UnsafePipelineRunnerServiceServer interface

+ type UnsafePluginMedianServer interface

+ type UnsafePluginRelayerServer interface

+ type UnsafeRelayerServer interface

+ type UnsafeReportCodecServer interface

+ type UnsafeReportingPluginFactoryServer interface

+ type UnsafeReportingPluginServer interface

+ type UnsafeReportingPluginServiceServer interface

+ type UnsafeServiceServer interface

+ type UnsafeTelemetryServer interface

+ type UnsafeValidationServiceServer interface

+ type ValidateConfigRequest struct

+ Config *structpb.Struct

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

+ func (*ValidateConfigRequest) ProtoMessage()

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

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

+ func (x *ValidateConfigRequest) Reset()

+ func (x *ValidateConfigRequest) String() string

+ type ValidateConfigResponse struct

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

+ func (*ValidateConfigResponse) ProtoMessage()

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

+ func (x *ValidateConfigResponse) Reset()

+ func (x *ValidateConfigResponse) String() string

+ type ValidationServiceClient interface

+ ValidateConfig func(ctx context.Context, in *ValidateConfigRequest, opts ...grpc.CallOption) (*ValidateConfigResponse, error)

+ func NewValidationServiceClient(cc grpc.ClientConnInterface) ValidationServiceClient

+ type ValidationServiceRequest struct

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

+ func (*ValidationServiceRequest) ProtoMessage()

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

+ func (x *ValidationServiceRequest) Reset()

+ func (x *ValidationServiceRequest) String() string

+ type ValidationServiceResponse struct

+ ID uint32

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

+ func (*ValidationServiceResponse) ProtoMessage()

+ func (x *ValidationServiceResponse) GetID() uint32

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

+ func (x *ValidationServiceResponse) Reset()

+ func (x *ValidationServiceResponse) String() string

+ type ValidationServiceServer interface

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

+ type ValueComparator struct

+ Operator ComparisonOperator

+ Value *VersionedBytes

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

+ func (*ValueComparator) ProtoMessage()

+ func (x *ValueComparator) GetOperator() ComparisonOperator

+ func (x *ValueComparator) GetValue() *VersionedBytes

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

+ func (x *ValueComparator) Reset()

+ func (x *ValueComparator) String() string

+ type VersionedBytes struct

+ Data []byte

+ Version uint32

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

+ func (*VersionedBytes) ProtoMessage()

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

+ func (x *VersionedBytes) GetVersion() uint32

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

+ func (x *VersionedBytes) Reset()

+ func (x *VersionedBytes) String() string

v0.0.1-beta

Nov 26, 2024

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL