pb

package

Go to main page

Versions in this module

v0

v0.9.6

Sep 26, 2025

v0.9.5

Sep 19, 2025

Changes in this version

+ type CCIPProviderArgs struct

+ ChainWriterConfig []byte

+ ContractReaderConfig []byte

+ ExternalJobID []byte

+ OffRampAddress string

+ PluginType uint32

+ SyncedAddresses map[string][]byte

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

+ func (*CCIPProviderArgs) ProtoMessage()

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

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

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

+ func (x *CCIPProviderArgs) GetOffRampAddress() string

+ func (x *CCIPProviderArgs) GetPluginType() uint32

+ func (x *CCIPProviderArgs) GetSyncedAddresses() map[string][]byte

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

+ func (x *CCIPProviderArgs) Reset()

+ func (x *CCIPProviderArgs) String() string

type NewCCIPProviderRequest

+ CcipProviderArgs *CCIPProviderArgs

+ func (x *NewCCIPProviderRequest) GetCcipProviderArgs() *CCIPProviderArgs

v0.9.4

Sep 2, 2025

Changes in this version

+ const CapabilitiesRegistry_DONsForCapability_FullMethodName

type CapabilitiesRegistryClient

+ DONsForCapability func(ctx context.Context, in *DONForCapabilityRequest, opts ...grpc.CallOption) (*DONForCapabilityReply, error)

type CapabilitiesRegistryServer

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

+ type DONForCapabilityReply struct

+ Dons []*DONWithNodes

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

+ func (*DONForCapabilityReply) ProtoMessage()

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

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

+ func (x *DONForCapabilityReply) Reset()

+ func (x *DONForCapabilityReply) String() string

+ type DONForCapabilityRequest struct

+ CapabilityID string

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

+ func (*DONForCapabilityRequest) ProtoMessage()

+ func (x *DONForCapabilityRequest) GetCapabilityID() string

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

+ func (x *DONForCapabilityRequest) Reset()

+ func (x *DONForCapabilityRequest) String() string

+ type DONWithNodes struct

+ Don *DON

+ Nodes []*NodeReply

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

+ func (*DONWithNodes) ProtoMessage()

+ func (x *DONWithNodes) GetDon() *DON

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

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

+ func (x *DONWithNodes) Reset()

+ func (x *DONWithNodes) String() string

type UnimplementedCapabilitiesRegistryServer

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

v0.9.3

Aug 21, 2025

Changes in this version

+ const Keystore_Decrypt_FullMethodName

+ var File_loop_internal_pb_keystore_proto protoreflect.FileDescriptor

+ type DecryptReply struct

+ DecryptedData []byte

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

+ func (*DecryptReply) ProtoMessage()

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

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

+ func (x *DecryptReply) Reset()

+ func (x *DecryptReply) String() string

+ type DecryptRequest struct

+ Account string

+ Data []byte

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

+ func (*DecryptRequest) ProtoMessage()

+ func (x *DecryptRequest) GetAccount() string

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

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

+ func (x *DecryptRequest) Reset()

+ func (x *DecryptRequest) String() string

type KeystoreClient

+ Decrypt func(ctx context.Context, in *DecryptRequest, opts ...grpc.CallOption) (*DecryptReply, error)

type KeystoreServer

+ Decrypt func(context.Context, *DecryptRequest) (*DecryptReply, error)

type UnimplementedKeystoreServer

+ func (UnimplementedKeystoreServer) Decrypt(context.Context, *DecryptRequest) (*DecryptReply, error)

v0.9.2

Aug 21, 2025

v0.9.1

Aug 20, 2025

v0.9.0

Aug 8, 2025

Changes in this version

+ const KeyValueStore_PruneExpiredEntries_FullMethodName

+ const Relayer_NewCCIPProvider_FullMethodName

type DON

+ Config []byte

+ Families []string

+ Name string

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

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

+ func (x *DON) GetName() string

type KeyValueStoreClient

+ PruneExpiredEntries func(ctx context.Context, in *PruneExpiredEntriesRequest, opts ...grpc.CallOption) (*PruneExpiredEntriesResponse, error)

type KeyValueStoreServer

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

+ type NewCCIPProviderReply struct

+ CcipProviderID uint32

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

+ func (*NewCCIPProviderReply) ProtoMessage()

+ func (x *NewCCIPProviderReply) GetCcipProviderID() uint32

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

+ func (x *NewCCIPProviderReply) Reset()

+ func (x *NewCCIPProviderReply) String() string

+ type NewCCIPProviderRequest struct

+ RelayArgs *RelayArgs

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

+ func (*NewCCIPProviderRequest) ProtoMessage()

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

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

+ func (x *NewCCIPProviderRequest) Reset()

+ func (x *NewCCIPProviderRequest) String() string

+ type PruneExpiredEntriesRequest struct

+ MaxAge *durationpb.Duration

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

+ func (*PruneExpiredEntriesRequest) ProtoMessage()

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

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

+ func (x *PruneExpiredEntriesRequest) Reset()

+ func (x *PruneExpiredEntriesRequest) String() string

+ type PruneExpiredEntriesResponse struct

+ NumPruned int64

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

+ func (*PruneExpiredEntriesResponse) ProtoMessage()

+ func (x *PruneExpiredEntriesResponse) GetNumPruned() int64

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

+ func (x *PruneExpiredEntriesResponse) Reset()

+ func (x *PruneExpiredEntriesResponse) String() string

type RelayerClient

+ NewCCIPProvider func(ctx context.Context, in *NewCCIPProviderRequest, opts ...grpc.CallOption) (*NewCCIPProviderReply, error)

type RelayerServer

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

type UnimplementedKeyValueStoreServer

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

type UnimplementedRelayerServer

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

v0.8.0

Jul 14, 2025

Changes in this version

+ const CapabilitiesRegistry_NodeByPeerID_FullMethodName

type CapabilitiesRegistryClient

+ NodeByPeerID func(ctx context.Context, in *NodeRequest, opts ...grpc.CallOption) (*NodeReply, error)

type CapabilitiesRegistryServer

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

+ type NodeReply struct

+ CapabilityDONs []*DON

+ EncryptionPublicKey []byte

+ NodeOperatorID uint32

+ PeerID []byte

+ Signer []byte

+ WorkflowDON *DON

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

+ func (*NodeReply) ProtoMessage()

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

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

+ func (x *NodeReply) GetNodeOperatorID() uint32

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

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

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

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

+ func (x *NodeReply) Reset()

+ func (x *NodeReply) String() string

+ type NodeRequest struct

+ PeerID []byte

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

+ func (*NodeRequest) ProtoMessage()

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

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

+ func (x *NodeRequest) Reset()

+ func (x *NodeRequest) String() string

type UnimplementedCapabilitiesRegistryServer

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

v0.7.2

Aug 1, 2025

v0.7.1

Jul 28, 2025

Changes in this version

+ const CapabilitiesRegistry_GetExecutable_FullMethodName

+ const ContractWriter_GetEstimateFee_FullMethodName

+ const Relayer_GetChainInfo_FullMethodName

+ var File_capabilities_registry_proto protoreflect.FileDescriptor

+ var File_loop_internal_pb_contract_reader_proto protoreflect.FileDescriptor

+ var File_loop_internal_pb_median_datasource_proto protoreflect.FileDescriptor

+ var File_loop_internal_pb_median_proto protoreflect.FileDescriptor

+ var File_loop_internal_pb_relayer_proto protoreflect.FileDescriptor

+ var File_loop_internal_pb_reporting_proto protoreflect.FileDescriptor

type CapabilitiesRegistryClient

+ GetExecutable func(ctx context.Context, in *GetExecutableRequest, opts ...grpc.CallOption) (*GetExecutableReply, error)

type CapabilitiesRegistryServer

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

+ type ChainInfo struct

+ ChainId string

+ FamilyName string

+ NetworkName string

+ NetworkNameFull string

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

+ func (*ChainInfo) ProtoMessage()

+ func (x *ChainInfo) GetChainId() string

+ func (x *ChainInfo) GetFamilyName() string

+ func (x *ChainInfo) GetNetworkName() string

+ func (x *ChainInfo) GetNetworkNameFull() string

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

+ func (x *ChainInfo) Reset()

+ func (x *ChainInfo) String() string

type ContractWriterClient

+ GetEstimateFee func(ctx context.Context, in *GetEstimateFeeRequest, opts ...grpc.CallOption) (*GetEstimateFeeReply, error)

type ContractWriterServer

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

type ExecuteAPIType

+ const ExecuteAPIType_EXECUTE_API_TYPE_COMBINED

+ type GetChainInfoReply struct

+ ChainInfo *ChainInfo

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

+ func (*GetChainInfoReply) ProtoMessage()

+ func (x *GetChainInfoReply) GetChainInfo() *ChainInfo

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

+ func (x *GetChainInfoReply) Reset()

+ func (x *GetChainInfoReply) String() string

+ type GetChainInfoRequest struct

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

+ func (*GetChainInfoRequest) ProtoMessage()

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

+ func (x *GetChainInfoRequest) Reset()

+ func (x *GetChainInfoRequest) String() string

+ type GetEstimateFeeReply struct

+ Decimals uint32

+ Fee *BigInt

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

+ func (*GetEstimateFeeReply) ProtoMessage()

+ func (x *GetEstimateFeeReply) GetDecimals() uint32

+ func (x *GetEstimateFeeReply) GetFee() *BigInt

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

+ func (x *GetEstimateFeeReply) Reset()

+ func (x *GetEstimateFeeReply) String() string

+ type GetEstimateFeeRequest struct

+ ContractName string

+ Meta *TransactionMeta

+ Method string

+ Params *codec.VersionedBytes

+ ToAddress string

+ Value *BigInt

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

+ func (*GetEstimateFeeRequest) ProtoMessage()

+ func (x *GetEstimateFeeRequest) GetContractName() string

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

+ func (x *GetEstimateFeeRequest) GetMethod() string

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

+ func (x *GetEstimateFeeRequest) GetToAddress() string

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

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

+ func (x *GetEstimateFeeRequest) Reset()

+ func (x *GetEstimateFeeRequest) String() string

+ type GetExecutableReply struct

+ CapabilityID uint32

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

+ func (*GetExecutableReply) ProtoMessage()

+ func (x *GetExecutableReply) GetCapabilityID() uint32

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

+ func (x *GetExecutableReply) Reset()

+ func (x *GetExecutableReply) String() string

+ type GetExecutableRequest struct

+ Id string

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

+ func (*GetExecutableRequest) ProtoMessage()

+ func (x *GetExecutableRequest) GetId() string

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

+ func (x *GetExecutableRequest) Reset()

+ func (x *GetExecutableRequest) String() string

type NewRelayerRequest

+ KeystoreCSAID uint32

+ func (x *NewRelayerRequest) GetKeystoreCSAID() uint32

type RelayerClient

+ GetChainInfo func(ctx context.Context, in *GetChainInfoRequest, opts ...grpc.CallOption) (*GetChainInfoReply, error)

type RelayerServer

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

type Sequence

+ TxHash []byte

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

type SequenceWithKey

+ TxHash []byte

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

type UnimplementedCapabilitiesRegistryServer

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

type UnimplementedContractWriterServer

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

type UnimplementedRelayerServer

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

v0.7.1-ccip

Aug 7, 2025

v0.7.0

Apr 14, 2025

v0.6.0

Mar 27, 2025

Changes in this version

+ const Relayer_Replay_FullMethodName

type RelayerClient

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

type RelayerServer

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

+ type ReplayRequest struct

+ Args *structpb.Struct

+ FromBlock string

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

+ func (*ReplayRequest) ProtoMessage()

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

+ func (x *ReplayRequest) GetFromBlock() string

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

+ func (x *ReplayRequest) Reset()

+ func (x *ReplayRequest) String() string

type UnimplementedRelayerServer

+ func (UnimplementedRelayerServer) Replay(context.Context, *ReplayRequest) (*emptypb.Empty, error)

v0.5.0

Mar 12, 2025

Changes in this version

type NewMedianFactoryRequest

+ DeviationFuncDefinition []byte

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

v0.4.1

Jan 16, 2025

v0.4.0

Dec 14, 2024

Changes in this version

+ const CapabilitiesRegistry_Remove_FullMethodName

+ const ContractReader_GetLatestValueWithHeadData_FullMethodName

+ const ContractReader_QueryKeys_FullMethodName

+ const ContractWriter_GetFeeComponents_FullMethodName

+ const ContractWriter_GetTransactionStatus_FullMethodName

+ const ContractWriter_SubmitTransaction_FullMethodName

+ const Relayer_NewContractWriter_FullMethodName

+ var ContractWriter_ServiceDesc = grpc.ServiceDesc

+ var File_contract_writer_proto protoreflect.FileDescriptor

+ func RegisterContractWriterServer(s grpc.ServiceRegistrar, srv ContractWriterServer)

type CapabilitiesRegistryClient

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

type CapabilitiesRegistryServer

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

+ type ContractKeyFilter struct

+ AsValueType bool

+ Contract *BoundContract

+ Filter *QueryKeyFilter

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

+ func (*ContractKeyFilter) ProtoMessage()

+ func (x *ContractKeyFilter) GetAsValueType() bool

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

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

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

+ func (x *ContractKeyFilter) Reset()

+ func (x *ContractKeyFilter) String() string

type ContractReaderClient

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

+ QueryKeys func(ctx context.Context, in *QueryKeysRequest, opts ...grpc.CallOption) (*QueryKeysReply, error)

type ContractReaderServer

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

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

+ type ContractWriterClient 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 NewContractWriterClient(cc grpc.ClientConnInterface) ContractWriterClient

+ type ContractWriterServer 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 GetLatestValueWithHeadDataReply struct

+ HeadData *Head

+ RetVal *VersionedBytes

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

+ func (*GetLatestValueWithHeadDataReply) ProtoMessage()

+ func (x *GetLatestValueWithHeadDataReply) GetHeadData() *Head

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

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

+ func (x *GetLatestValueWithHeadDataReply) Reset()

+ func (x *GetLatestValueWithHeadDataReply) String() string

+ type NewContractWriterReply struct

+ ContractWriterID uint32

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

+ func (*NewContractWriterReply) ProtoMessage()

+ func (x *NewContractWriterReply) GetContractWriterID() uint32

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

+ func (x *NewContractWriterReply) Reset()

+ func (x *NewContractWriterReply) String() string

+ type NewContractWriterRequest struct

+ ContractWriterConfig []byte

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

+ func (*NewContractWriterRequest) ProtoMessage()

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

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

+ func (x *NewContractWriterRequest) Reset()

+ func (x *NewContractWriterRequest) String() string

+ type QueryKeysReply struct

+ Sequences []*SequenceWithKey

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

+ func (*QueryKeysReply) ProtoMessage()

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

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

+ func (x *QueryKeysReply) Reset()

+ func (x *QueryKeysReply) String() string

+ type QueryKeysRequest struct

+ Filters []*ContractKeyFilter

+ LimitAndSort *LimitAndSort

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

+ func (*QueryKeysRequest) ProtoMessage()

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

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

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

+ func (x *QueryKeysRequest) Reset()

+ func (x *QueryKeysRequest) String() string

type RelayerClient

+ NewContractWriter func(ctx context.Context, in *NewContractWriterRequest, opts ...grpc.CallOption) (*NewContractWriterReply, error)

type RelayerServer

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

+ type RemoveRequest struct

+ Id string

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

+ func (*RemoveRequest) ProtoMessage()

+ func (x *RemoveRequest) GetId() string

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

+ func (x *RemoveRequest) Reset()

+ func (x *RemoveRequest) String() string

+ type SequenceWithKey struct

+ Data *VersionedBytes

+ Head *Head

+ Key string

+ SequenceCursor string

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

+ func (*SequenceWithKey) ProtoMessage()

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

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

+ func (x *SequenceWithKey) GetKey() string

+ func (x *SequenceWithKey) GetSequenceCursor() string

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

+ func (x *SequenceWithKey) Reset()

+ func (x *SequenceWithKey) String() string

type UnimplementedCapabilitiesRegistryServer

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

type UnimplementedContractReaderServer

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

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

+ type UnimplementedContractWriterServer struct

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

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

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

type UnimplementedRelayerServer

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

+ type UnsafeContractWriterServer interface

v0.3.1-beholder

Nov 21, 2024

v0.3.0

Oct 9, 2024

Changes in this version

type GetLatestValueRequest

+ AsValueType bool

+ func (x *GetLatestValueRequest) GetAsValueType() bool

type QueryKeyRequest

+ AsValueType bool

+ func (x *QueryKeyRequest) GetAsValueType() bool

v0.2.2

Sep 17, 2024

Changes in this version

+ const CapabilitiesRegistry_ConfigForCapability_FullMethodName

+ const CapabilitiesRegistry_LocalNode_FullMethodName

+ const ContractReader_BatchGetLatestValues_FullMethodName

+ const ContractReader_Bind_FullMethodName

+ const ContractReader_GetLatestValue_FullMethodName

+ const ContractReader_QueryKey_FullMethodName

+ const ContractReader_Unbind_FullMethodName

+ const Relayer_LatestHead_FullMethodName

+ var ContractReader_ServiceDesc = grpc.ServiceDesc

+ var File_contract_reader_proto protoreflect.FileDescriptor

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

type CapabilitiesRegistryClient

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

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

type CapabilitiesRegistryServer

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

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

+ 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

+ Contract *BoundContract

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

type ContractBatchResult

+ Contract *BoundContract

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

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

+ const ExecuteAPIType_EXECUTE_API_TYPE_EXECUTE

type GetLatestValueRequest

+ ReadIdentifier string

+ func (x *GetLatestValueRequest) GetReadIdentifier() string

type Head

+ Height string

+ func (x *Head) GetHeight() 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 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 NewMedianFactoryRequest

+ ContractID string

+ func (x *NewMedianFactoryRequest) GetContractID() string

type QueryKeyRequest

+ Contract *BoundContract

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

type RelayerClient

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

type RelayerServer

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

type TransactionMeta

+ GasLimit *BigInt

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

type TransactionStatus

+ const TransactionStatus_TRANSACTION_STATUS_PENDING

+ 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

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

+ func (UnimplementedCapabilitiesRegistryServer) LocalNode(context.Context, *emptypb.Empty) (*LocalNodeReply, 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 UnimplementedRelayerServer

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

+ type UnsafeContractReaderServer interface

v0.2.1

Jul 18, 2024

v0.2.0

Jul 15, 2024

Changes in this version

+ const CapabilitiesRegistry_Add_FullMethodName

+ const CapabilitiesRegistry_GetAction_FullMethodName

+ const CapabilitiesRegistry_GetConsensus_FullMethodName

+ const CapabilitiesRegistry_GetLocalNode_FullMethodName

+ const CapabilitiesRegistry_GetTarget_FullMethodName

+ const CapabilitiesRegistry_GetTrigger_FullMethodName

+ const CapabilitiesRegistry_Get_FullMethodName

+ const CapabilitiesRegistry_List_FullMethodName

+ const ChainReader_BatchGetLatestValues_FullMethodName

+ const ChainReader_Bind_FullMethodName

+ const ChainReader_GetLatestValue_FullMethodName

+ const ChainReader_QueryKey_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 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_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 ChainReader_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 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_reader_proto protoreflect.FileDescriptor

+ var File_chain_writer_proto protoreflect.FileDescriptor

+ var File_codec_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 RegisterChainReaderServer(s grpc.ServiceRegistrar, srv ChainReaderServer)

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

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

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

+ 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 map[string]*ContractBatchResult

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

+ func (*BatchGetLatestValuesReply) ProtoMessage()

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

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

+ func (x *BatchGetLatestValuesReply) Reset()

+ func (x *BatchGetLatestValuesReply) String() string

+ type BatchGetLatestValuesRequest struct

+ Requests map[string]*ContractBatch

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

+ func (*BatchGetLatestValuesRequest) ProtoMessage()

+ func (x *BatchGetLatestValuesRequest) GetRequests() map[string]*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 uint64

+ Operator ComparisonOperator

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

+ func (*Block) ProtoMessage()

+ func (x *Block) GetBlockNumber() uint64

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

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

+ GetLocalNode func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetLocalNodeReply, 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)

+ func NewCapabilitiesRegistryClient(cc grpc.ClientConnInterface) CapabilitiesRegistryClient

+ type CapabilitiesRegistryServer interface

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

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

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

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

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

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

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

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

+ type ChainReaderClient 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)

+ func NewChainReaderClient(cc grpc.ClientConnInterface) ChainReaderClient

+ type ChainReaderServer 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)

+ 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 ContractBatch struct

+ Reads []*BatchRead

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

+ func (*ContractBatch) ProtoMessage()

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

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

+ func (x *ContractBatch) Reset()

+ func (x *ContractBatch) String() string

+ type ContractBatchResult struct

+ Results []*BatchReadResult

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

+ func (*ContractBatchResult) ProtoMessage()

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

+ 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

+ Confidence Confidence

+ ContractName string

+ Method string

+ Params *VersionedBytes

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

+ func (*GetLatestValueRequest) ProtoMessage()

+ func (x *GetLatestValueRequest) GetConfidence() Confidence

+ func (x *GetLatestValueRequest) GetContractName() string

+ func (x *GetLatestValueRequest) GetMethod() string

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

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

+ func (x *GetLatestValueRequest) Reset()

+ func (x *GetLatestValueRequest) String() 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 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

+ Identifier string

+ Timestamp uint64

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

+ func (*Head) ProtoMessage()

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

+ func (x *Head) GetIdentifier() 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 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 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

+ DataSourceID uint32

+ ErrorLogID uint32

+ GasPriceSubunitsDataSourceID uint32

+ JuelsPerFeeCoinDataSourceID uint32

+ MedianProviderID uint32

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

+ func (*NewMedianFactoryRequest) ProtoMessage()

+ 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

+ ContractName string

+ Filter *QueryKeyFilter

+ LimitAndSort *LimitAndSort

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

+ func (*QueryKeyRequest) ProtoMessage()

+ func (x *QueryKeyRequest) GetContractName() string

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

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

+ 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

+ WorkflowExecutionId string

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

+ func (*TransactionMeta) ProtoMessage()

+ 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_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 UnimplementedCapabilitiesRegistryServer struct

+ func (UnimplementedCapabilitiesRegistryServer) Add(context.Context, *AddRequest) (*emptypb.Empty, 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) GetLocalNode(context.Context, *emptypb.Empty) (*GetLocalNodeReply, 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)

+ type UnimplementedChainReaderServer struct

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

+ 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 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 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) 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 UnsafeChainReaderServer interface

+ type UnsafeChainWriterServer interface

+ type UnsafeCodecServer interface

+ type UnsafeContractConfigTrackerServer 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 string

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

+ func (*ValueComparator) ProtoMessage()

+ func (x *ValueComparator) GetOperator() ComparisonOperator

+ func (x *ValueComparator) GetValue() string

+ 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

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