Documentation ¶
Index ¶
- Variables
- func RegisterFeedsManagerServer(s wsrpc.ServiceRegistrar, srv FeedsManagerServer)
- func RegisterNodeServiceServer(s wsrpc.ServiceRegistrar, srv NodeServiceServer)
- type Account
- func (*Account) Descriptor() ([]byte, []int)deprecated
- func (x *Account) GetAddress() string
- func (x *Account) GetChainId() string
- func (x *Account) GetChainType() ChainType
- func (*Account) ProtoMessage()
- func (x *Account) ProtoReflect() protoreflect.Message
- func (x *Account) Reset()
- func (x *Account) String() string
- type ApprovedJobRequest
- func (*ApprovedJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApprovedJobRequest) GetUuid() string
- func (x *ApprovedJobRequest) GetVersion() int64
- func (*ApprovedJobRequest) ProtoMessage()
- func (x *ApprovedJobRequest) ProtoReflect() protoreflect.Message
- func (x *ApprovedJobRequest) Reset()
- func (x *ApprovedJobRequest) String() string
- type ApprovedJobResponse
- type CancelledJobRequest
- func (*CancelledJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelledJobRequest) GetUuid() string
- func (x *CancelledJobRequest) GetVersion() int64
- func (*CancelledJobRequest) ProtoMessage()
- func (x *CancelledJobRequest) ProtoReflect() protoreflect.Message
- func (x *CancelledJobRequest) Reset()
- func (x *CancelledJobRequest) String() string
- type CancelledJobResponse
- type Chain
- type ChainConfig
- func (*ChainConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ChainConfig) GetAccountAddress() string
- func (x *ChainConfig) GetAdminAddress() string
- func (x *ChainConfig) GetChain() *Chain
- func (x *ChainConfig) GetFluxMonitorConfig() *FluxMonitorConfig
- func (x *ChainConfig) GetOcr1Config() *OCR1Config
- func (x *ChainConfig) GetOcr2Config() *OCR2Config
- func (*ChainConfig) ProtoMessage()
- func (x *ChainConfig) ProtoReflect() protoreflect.Message
- func (x *ChainConfig) Reset()
- func (x *ChainConfig) String() string
- type ChainType
- type FeedsManagerClient
- type FeedsManagerServer
- type FluxMonitorConfig
- type HealthcheckRequest
- type HealthcheckResponse
- type JobType
- type NodeServiceClient
- type NodeServiceServer
- type OCR1Config
- func (*OCR1Config) Descriptor() ([]byte, []int)deprecated
- func (x *OCR1Config) GetEnabled() bool
- func (x *OCR1Config) GetIsBootstrap() bool
- func (x *OCR1Config) GetMultiaddr() string
- func (x *OCR1Config) GetOcrKeyBundle() *OCR1Config_OCRKeyBundle
- func (x *OCR1Config) GetP2PKeyBundle() *OCR1Config_P2PKeyBundle
- func (*OCR1Config) ProtoMessage()
- func (x *OCR1Config) ProtoReflect() protoreflect.Message
- func (x *OCR1Config) Reset()
- func (x *OCR1Config) String() string
- type OCR1Config_OCRKeyBundle
- func (*OCR1Config_OCRKeyBundle) Descriptor() ([]byte, []int)deprecated
- func (x *OCR1Config_OCRKeyBundle) GetBundleId() string
- func (x *OCR1Config_OCRKeyBundle) GetConfigPublicKey() string
- func (x *OCR1Config_OCRKeyBundle) GetOffchainPublicKey() string
- func (x *OCR1Config_OCRKeyBundle) GetOnchainSigningAddress() string
- func (*OCR1Config_OCRKeyBundle) ProtoMessage()
- func (x *OCR1Config_OCRKeyBundle) ProtoReflect() protoreflect.Message
- func (x *OCR1Config_OCRKeyBundle) Reset()
- func (x *OCR1Config_OCRKeyBundle) String() string
- type OCR1Config_P2PKeyBundle
- func (*OCR1Config_P2PKeyBundle) Descriptor() ([]byte, []int)deprecated
- func (x *OCR1Config_P2PKeyBundle) GetPeerId() string
- func (x *OCR1Config_P2PKeyBundle) GetPublicKey() string
- func (*OCR1Config_P2PKeyBundle) ProtoMessage()
- func (x *OCR1Config_P2PKeyBundle) ProtoReflect() protoreflect.Message
- func (x *OCR1Config_P2PKeyBundle) Reset()
- func (x *OCR1Config_P2PKeyBundle) String() string
- type OCR2Config
- func (*OCR2Config) Descriptor() ([]byte, []int)deprecated
- func (x *OCR2Config) GetEnabled() bool
- func (x *OCR2Config) GetIsBootstrap() bool
- func (x *OCR2Config) GetMultiaddr() string
- func (x *OCR2Config) GetOcrKeyBundle() *OCR2Config_OCRKeyBundle
- func (x *OCR2Config) GetP2PKeyBundle() *OCR2Config_P2PKeyBundle
- func (*OCR2Config) ProtoMessage()
- func (x *OCR2Config) ProtoReflect() protoreflect.Message
- func (x *OCR2Config) Reset()
- func (x *OCR2Config) String() string
- type OCR2Config_OCRKeyBundle
- func (*OCR2Config_OCRKeyBundle) Descriptor() ([]byte, []int)deprecated
- func (x *OCR2Config_OCRKeyBundle) GetBundleId() string
- func (x *OCR2Config_OCRKeyBundle) GetConfigPublicKey() string
- func (x *OCR2Config_OCRKeyBundle) GetOffchainPublicKey() string
- func (x *OCR2Config_OCRKeyBundle) GetOnchainSigningAddress() string
- func (*OCR2Config_OCRKeyBundle) ProtoMessage()
- func (x *OCR2Config_OCRKeyBundle) ProtoReflect() protoreflect.Message
- func (x *OCR2Config_OCRKeyBundle) Reset()
- func (x *OCR2Config_OCRKeyBundle) String() string
- type OCR2Config_P2PKeyBundle
- func (*OCR2Config_P2PKeyBundle) Descriptor() ([]byte, []int)deprecated
- func (x *OCR2Config_P2PKeyBundle) GetPeerId() string
- func (x *OCR2Config_P2PKeyBundle) GetPublicKey() string
- func (*OCR2Config_P2PKeyBundle) ProtoMessage()
- func (x *OCR2Config_P2PKeyBundle) ProtoReflect() protoreflect.Message
- func (x *OCR2Config_P2PKeyBundle) Reset()
- func (x *OCR2Config_P2PKeyBundle) String() string
- type ProposeJobRequest
- func (*ProposeJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProposeJobRequest) GetId() string
- func (x *ProposeJobRequest) GetMultiaddrs() []string
- func (x *ProposeJobRequest) GetSpec() string
- func (x *ProposeJobRequest) GetVersion() int64
- func (*ProposeJobRequest) ProtoMessage()
- func (x *ProposeJobRequest) ProtoReflect() protoreflect.Message
- func (x *ProposeJobRequest) Reset()
- func (x *ProposeJobRequest) String() string
- type ProposeJobResponse
- type RejectedJobRequest
- func (*RejectedJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RejectedJobRequest) GetUuid() string
- func (x *RejectedJobRequest) GetVersion() int64
- func (*RejectedJobRequest) ProtoMessage()
- func (x *RejectedJobRequest) ProtoReflect() protoreflect.Message
- func (x *RejectedJobRequest) Reset()
- func (x *RejectedJobRequest) String() string
- type RejectedJobResponse
- type UpdateNodeRequest
- func (*UpdateNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNodeRequest) GetAccountAddresses() []string
- func (x *UpdateNodeRequest) GetAccounts() []*Account
- func (x *UpdateNodeRequest) GetBootstrapMultiaddr() string
- func (x *UpdateNodeRequest) GetChainConfigs() []*ChainConfig
- func (x *UpdateNodeRequest) GetChainId() int64
- func (x *UpdateNodeRequest) GetChainIds() []int64
- func (x *UpdateNodeRequest) GetChains() []*Chain
- func (x *UpdateNodeRequest) GetIsBootstrapPeer() bool
- func (x *UpdateNodeRequest) GetJobTypes() []JobType
- func (x *UpdateNodeRequest) GetVersion() string
- func (*UpdateNodeRequest) ProtoMessage()
- func (x *UpdateNodeRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateNodeRequest) Reset()
- func (x *UpdateNodeRequest) String() string
- type UpdateNodeResponse
Constants ¶
This section is empty.
Variables ¶
var ( JobType_name = map[int32]string{ 0: "JOB_TYPE_UNSPECIFIED", 1: "JOB_TYPE_FLUX_MONITOR", 2: "JOB_TYPE_OCR", 3: "JOB_TYPE_OCR2", } JobType_value = map[string]int32{ "JOB_TYPE_UNSPECIFIED": 0, "JOB_TYPE_FLUX_MONITOR": 1, "JOB_TYPE_OCR": 2, "JOB_TYPE_OCR2": 3, } )
Enum value maps for JobType.
var ( ChainType_name = map[int32]string{ 0: "CHAIN_TYPE_UNSPECIFIED", 1: "CHAIN_TYPE_EVM", 2: "CHAIN_TYPE_SOLANA", 3: "CHAIN_TYPE_TERRA", } ChainType_value = map[string]int32{ "CHAIN_TYPE_UNSPECIFIED": 0, "CHAIN_TYPE_EVM": 1, "CHAIN_TYPE_SOLANA": 2, "CHAIN_TYPE_TERRA": 3, } )
Enum value maps for ChainType.
var FeedsManager_ServiceDesc = wsrpc.ServiceDesc{ ServiceName: "cfm.FeedsManager", HandlerType: (*FeedsManagerServer)(nil), Methods: []wsrpc.MethodDesc{ { MethodName: "ApprovedJob", Handler: _FeedsManager_ApprovedJob_Handler, }, { MethodName: "UpdateNode", Handler: _FeedsManager_UpdateNode_Handler, }, { MethodName: "RejectedJob", Handler: _FeedsManager_RejectedJob_Handler, }, { MethodName: "CancelledJob", Handler: _FeedsManager_CancelledJob_Handler, }, }, }
FeedsManager_ServiceDesc is the wsrpc.ServiceDesc for FeedsManager service. It's only intended for direct use with wsrpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_pkg_noderpc_proto_feeds_manager_proto protoreflect.FileDescriptor
var NodeService_ServiceDesc = wsrpc.ServiceDesc{ ServiceName: "cfm.NodeService", HandlerType: (*NodeServiceServer)(nil), Methods: []wsrpc.MethodDesc{ { MethodName: "ProposeJob", Handler: _NodeService_ProposeJob_Handler, }, }, }
NodeService_ServiceDesc is the wsrpc.ServiceDesc for NodeService service. It's only intended for direct use with wsrpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterFeedsManagerServer ¶
func RegisterFeedsManagerServer(s wsrpc.ServiceRegistrar, srv FeedsManagerServer)
func RegisterNodeServiceServer ¶
func RegisterNodeServiceServer(s wsrpc.ServiceRegistrar, srv NodeServiceServer)
Types ¶
type Account ¶ added in v1.2.0
type Account struct { ChainType ChainType `protobuf:"varint,1,opt,name=chain_type,json=chainType,proto3,enum=cfm.ChainType" json:"chain_type,omitempty"` ChainId string `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
An account on a specific blockchain
func (*Account) Descriptor
deprecated
added in
v1.2.0
func (*Account) GetAddress ¶ added in v1.2.0
func (*Account) GetChainId ¶ added in v1.2.0
func (*Account) GetChainType ¶ added in v1.2.0
func (*Account) ProtoMessage ¶ added in v1.2.0
func (*Account) ProtoMessage()
func (*Account) ProtoReflect ¶ added in v1.2.0
func (x *Account) ProtoReflect() protoreflect.Message
type ApprovedJobRequest ¶ added in v0.10.10
type ApprovedJobRequest struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*ApprovedJobRequest) Descriptor
deprecated
added in
v0.10.10
func (*ApprovedJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApprovedJobRequest.ProtoReflect.Descriptor instead.
func (*ApprovedJobRequest) GetUuid ¶ added in v0.10.11
func (x *ApprovedJobRequest) GetUuid() string
func (*ApprovedJobRequest) GetVersion ¶ added in v1.2.0
func (x *ApprovedJobRequest) GetVersion() int64
func (*ApprovedJobRequest) ProtoMessage ¶ added in v0.10.10
func (*ApprovedJobRequest) ProtoMessage()
func (*ApprovedJobRequest) ProtoReflect ¶ added in v0.10.10
func (x *ApprovedJobRequest) ProtoReflect() protoreflect.Message
func (*ApprovedJobRequest) Reset ¶ added in v0.10.10
func (x *ApprovedJobRequest) Reset()
func (*ApprovedJobRequest) String ¶ added in v0.10.10
func (x *ApprovedJobRequest) String() string
type ApprovedJobResponse ¶ added in v0.10.10
type ApprovedJobResponse struct {
// contains filtered or unexported fields
}
func (*ApprovedJobResponse) Descriptor
deprecated
added in
v0.10.10
func (*ApprovedJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApprovedJobResponse.ProtoReflect.Descriptor instead.
func (*ApprovedJobResponse) ProtoMessage ¶ added in v0.10.10
func (*ApprovedJobResponse) ProtoMessage()
func (*ApprovedJobResponse) ProtoReflect ¶ added in v0.10.10
func (x *ApprovedJobResponse) ProtoReflect() protoreflect.Message
func (*ApprovedJobResponse) Reset ¶ added in v0.10.10
func (x *ApprovedJobResponse) Reset()
func (*ApprovedJobResponse) String ¶ added in v0.10.10
func (x *ApprovedJobResponse) String() string
type CancelledJobRequest ¶ added in v1.1.0
type CancelledJobRequest struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*CancelledJobRequest) Descriptor
deprecated
added in
v1.1.0
func (*CancelledJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelledJobRequest.ProtoReflect.Descriptor instead.
func (*CancelledJobRequest) GetUuid ¶ added in v1.1.0
func (x *CancelledJobRequest) GetUuid() string
func (*CancelledJobRequest) GetVersion ¶ added in v1.2.0
func (x *CancelledJobRequest) GetVersion() int64
func (*CancelledJobRequest) ProtoMessage ¶ added in v1.1.0
func (*CancelledJobRequest) ProtoMessage()
func (*CancelledJobRequest) ProtoReflect ¶ added in v1.1.0
func (x *CancelledJobRequest) ProtoReflect() protoreflect.Message
func (*CancelledJobRequest) Reset ¶ added in v1.1.0
func (x *CancelledJobRequest) Reset()
func (*CancelledJobRequest) String ¶ added in v1.1.0
func (x *CancelledJobRequest) String() string
type CancelledJobResponse ¶ added in v1.1.0
type CancelledJobResponse struct {
// contains filtered or unexported fields
}
func (*CancelledJobResponse) Descriptor
deprecated
added in
v1.1.0
func (*CancelledJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use CancelledJobResponse.ProtoReflect.Descriptor instead.
func (*CancelledJobResponse) ProtoMessage ¶ added in v1.1.0
func (*CancelledJobResponse) ProtoMessage()
func (*CancelledJobResponse) ProtoReflect ¶ added in v1.1.0
func (x *CancelledJobResponse) ProtoReflect() protoreflect.Message
func (*CancelledJobResponse) Reset ¶ added in v1.1.0
func (x *CancelledJobResponse) Reset()
func (*CancelledJobResponse) String ¶ added in v1.1.0
func (x *CancelledJobResponse) String() string
type Chain ¶ added in v1.2.0
type Chain struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type ChainType `protobuf:"varint,2,opt,name=type,proto3,enum=cfm.ChainType" json:"type,omitempty"` // contains filtered or unexported fields }
func (*Chain) Descriptor
deprecated
added in
v1.2.0
func (*Chain) ProtoMessage ¶ added in v1.2.0
func (*Chain) ProtoMessage()
func (*Chain) ProtoReflect ¶ added in v1.2.0
func (x *Chain) ProtoReflect() protoreflect.Message
type ChainConfig ¶ added in v1.5.0
type ChainConfig struct { Chain *Chain `protobuf:"bytes,1,opt,name=chain,proto3" json:"chain,omitempty"` AccountAddress string `protobuf:"bytes,2,opt,name=account_address,json=accountAddress,proto3" json:"account_address,omitempty"` AdminAddress string `protobuf:"bytes,3,opt,name=admin_address,json=adminAddress,proto3" json:"admin_address,omitempty"` FluxMonitorConfig *FluxMonitorConfig `protobuf:"bytes,4,opt,name=flux_monitor_config,json=fluxMonitorConfig,proto3" json:"flux_monitor_config,omitempty"` Ocr1Config *OCR1Config `protobuf:"bytes,5,opt,name=ocr1_config,json=ocr1Config,proto3" json:"ocr1_config,omitempty"` Ocr2Config *OCR2Config `protobuf:"bytes,6,opt,name=ocr2_config,json=ocr2Config,proto3" json:"ocr2_config,omitempty"` // contains filtered or unexported fields }
func (*ChainConfig) Descriptor
deprecated
added in
v1.5.0
func (*ChainConfig) Descriptor() ([]byte, []int)
Deprecated: Use ChainConfig.ProtoReflect.Descriptor instead.
func (*ChainConfig) GetAccountAddress ¶ added in v1.5.0
func (x *ChainConfig) GetAccountAddress() string
func (*ChainConfig) GetAdminAddress ¶ added in v1.5.0
func (x *ChainConfig) GetAdminAddress() string
func (*ChainConfig) GetChain ¶ added in v1.5.0
func (x *ChainConfig) GetChain() *Chain
func (*ChainConfig) GetFluxMonitorConfig ¶ added in v1.5.0
func (x *ChainConfig) GetFluxMonitorConfig() *FluxMonitorConfig
func (*ChainConfig) GetOcr1Config ¶ added in v1.5.0
func (x *ChainConfig) GetOcr1Config() *OCR1Config
func (*ChainConfig) GetOcr2Config ¶ added in v1.5.0
func (x *ChainConfig) GetOcr2Config() *OCR2Config
func (*ChainConfig) ProtoMessage ¶ added in v1.5.0
func (*ChainConfig) ProtoMessage()
func (*ChainConfig) ProtoReflect ¶ added in v1.5.0
func (x *ChainConfig) ProtoReflect() protoreflect.Message
func (*ChainConfig) Reset ¶ added in v1.5.0
func (x *ChainConfig) Reset()
func (*ChainConfig) String ¶ added in v1.5.0
func (x *ChainConfig) String() string
type ChainType ¶ added in v1.2.0
type ChainType int32
func (ChainType) Descriptor ¶ added in v1.2.0
func (ChainType) Descriptor() protoreflect.EnumDescriptor
func (ChainType) EnumDescriptor
deprecated
added in
v1.2.0
func (ChainType) Number ¶ added in v1.2.0
func (x ChainType) Number() protoreflect.EnumNumber
func (ChainType) Type ¶ added in v1.2.0
func (ChainType) Type() protoreflect.EnumType
type FeedsManagerClient ¶
type FeedsManagerClient interface { ApprovedJob(ctx context.Context, in *ApprovedJobRequest) (*ApprovedJobResponse, error) UpdateNode(ctx context.Context, in *UpdateNodeRequest) (*UpdateNodeResponse, error) RejectedJob(ctx context.Context, in *RejectedJobRequest) (*RejectedJobResponse, error) CancelledJob(ctx context.Context, in *CancelledJobRequest) (*CancelledJobResponse, error) }
FeedsManagerClient is the client API for FeedsManager service.
func NewFeedsManagerClient ¶
func NewFeedsManagerClient(cc wsrpc.ClientInterface) FeedsManagerClient
type FeedsManagerServer ¶
type FeedsManagerServer interface { ApprovedJob(context.Context, *ApprovedJobRequest) (*ApprovedJobResponse, error) UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeResponse, error) RejectedJob(context.Context, *RejectedJobRequest) (*RejectedJobResponse, error) CancelledJob(context.Context, *CancelledJobRequest) (*CancelledJobResponse, error) }
FeedsManagerServer is the server API for FeedsManager service.
type FluxMonitorConfig ¶ added in v1.5.0
type FluxMonitorConfig struct { Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` // contains filtered or unexported fields }
The config for Flux Monitor on a specific chain
func (*FluxMonitorConfig) Descriptor
deprecated
added in
v1.5.0
func (*FluxMonitorConfig) Descriptor() ([]byte, []int)
Deprecated: Use FluxMonitorConfig.ProtoReflect.Descriptor instead.
func (*FluxMonitorConfig) GetEnabled ¶ added in v1.5.0
func (x *FluxMonitorConfig) GetEnabled() bool
func (*FluxMonitorConfig) ProtoMessage ¶ added in v1.5.0
func (*FluxMonitorConfig) ProtoMessage()
func (*FluxMonitorConfig) ProtoReflect ¶ added in v1.5.0
func (x *FluxMonitorConfig) ProtoReflect() protoreflect.Message
func (*FluxMonitorConfig) Reset ¶ added in v1.5.0
func (x *FluxMonitorConfig) Reset()
func (*FluxMonitorConfig) String ¶ added in v1.5.0
func (x *FluxMonitorConfig) String() string
type HealthcheckRequest ¶ added in v1.2.0
type HealthcheckRequest struct {
// contains filtered or unexported fields
}
func (*HealthcheckRequest) Descriptor
deprecated
added in
v1.2.0
func (*HealthcheckRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthcheckRequest.ProtoReflect.Descriptor instead.
func (*HealthcheckRequest) ProtoMessage ¶ added in v1.2.0
func (*HealthcheckRequest) ProtoMessage()
func (*HealthcheckRequest) ProtoReflect ¶ added in v1.2.0
func (x *HealthcheckRequest) ProtoReflect() protoreflect.Message
func (*HealthcheckRequest) Reset ¶ added in v1.2.0
func (x *HealthcheckRequest) Reset()
func (*HealthcheckRequest) String ¶ added in v1.2.0
func (x *HealthcheckRequest) String() string
type HealthcheckResponse ¶ added in v1.2.0
type HealthcheckResponse struct {
// contains filtered or unexported fields
}
func (*HealthcheckResponse) Descriptor
deprecated
added in
v1.2.0
func (*HealthcheckResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthcheckResponse.ProtoReflect.Descriptor instead.
func (*HealthcheckResponse) ProtoMessage ¶ added in v1.2.0
func (*HealthcheckResponse) ProtoMessage()
func (*HealthcheckResponse) ProtoReflect ¶ added in v1.2.0
func (x *HealthcheckResponse) ProtoReflect() protoreflect.Message
func (*HealthcheckResponse) Reset ¶ added in v1.2.0
func (x *HealthcheckResponse) Reset()
func (*HealthcheckResponse) String ¶ added in v1.2.0
func (x *HealthcheckResponse) String() string
type JobType ¶ added in v0.10.10
type JobType int32
Defines the allowed job types
func (JobType) Descriptor ¶ added in v0.10.10
func (JobType) Descriptor() protoreflect.EnumDescriptor
func (JobType) EnumDescriptor
deprecated
added in
v0.10.10
func (JobType) Number ¶ added in v0.10.10
func (x JobType) Number() protoreflect.EnumNumber
func (JobType) Type ¶ added in v0.10.10
func (JobType) Type() protoreflect.EnumType
type NodeServiceClient ¶
type NodeServiceClient interface {
ProposeJob(ctx context.Context, in *ProposeJobRequest) (*ProposeJobResponse, error)
}
NodeServiceClient is the client API for NodeService service.
func NewNodeServiceClient ¶
func NewNodeServiceClient(cc wsrpc.ClientInterface) NodeServiceClient
type NodeServiceServer ¶
type NodeServiceServer interface {
ProposeJob(context.Context, *ProposeJobRequest) (*ProposeJobResponse, error)
}
NodeServiceServer is the server API for NodeService service.
type OCR1Config ¶ added in v1.5.0
type OCR1Config struct { Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` IsBootstrap bool `protobuf:"varint,2,opt,name=is_bootstrap,json=isBootstrap,proto3" json:"is_bootstrap,omitempty"` P2PKeyBundle *OCR1Config_P2PKeyBundle `protobuf:"bytes,3,opt,name=p2p_key_bundle,json=p2pKeyBundle,proto3" json:"p2p_key_bundle,omitempty"` OcrKeyBundle *OCR1Config_OCRKeyBundle `protobuf:"bytes,4,opt,name=ocr_key_bundle,json=ocrKeyBundle,proto3" json:"ocr_key_bundle,omitempty"` Multiaddr string `protobuf:"bytes,5,opt,name=multiaddr,proto3" json:"multiaddr,omitempty"` // contains filtered or unexported fields }
The config for OCR1 on a specific chain
func (*OCR1Config) Descriptor
deprecated
added in
v1.5.0
func (*OCR1Config) Descriptor() ([]byte, []int)
Deprecated: Use OCR1Config.ProtoReflect.Descriptor instead.
func (*OCR1Config) GetEnabled ¶ added in v1.5.0
func (x *OCR1Config) GetEnabled() bool
func (*OCR1Config) GetIsBootstrap ¶ added in v1.5.0
func (x *OCR1Config) GetIsBootstrap() bool
func (*OCR1Config) GetMultiaddr ¶ added in v1.5.0
func (x *OCR1Config) GetMultiaddr() string
func (*OCR1Config) GetOcrKeyBundle ¶ added in v1.5.0
func (x *OCR1Config) GetOcrKeyBundle() *OCR1Config_OCRKeyBundle
func (*OCR1Config) GetP2PKeyBundle ¶ added in v1.5.0
func (x *OCR1Config) GetP2PKeyBundle() *OCR1Config_P2PKeyBundle
func (*OCR1Config) ProtoMessage ¶ added in v1.5.0
func (*OCR1Config) ProtoMessage()
func (*OCR1Config) ProtoReflect ¶ added in v1.5.0
func (x *OCR1Config) ProtoReflect() protoreflect.Message
func (*OCR1Config) Reset ¶ added in v1.5.0
func (x *OCR1Config) Reset()
func (*OCR1Config) String ¶ added in v1.5.0
func (x *OCR1Config) String() string
type OCR1Config_OCRKeyBundle ¶ added in v1.5.0
type OCR1Config_OCRKeyBundle struct { BundleId string `protobuf:"bytes,1,opt,name=bundle_id,json=bundleId,proto3" json:"bundle_id,omitempty"` ConfigPublicKey string `protobuf:"bytes,2,opt,name=config_public_key,json=configPublicKey,proto3" json:"config_public_key,omitempty"` OffchainPublicKey string `protobuf:"bytes,3,opt,name=offchain_public_key,json=offchainPublicKey,proto3" json:"offchain_public_key,omitempty"` OnchainSigningAddress string `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
func (*OCR1Config_OCRKeyBundle) Descriptor
deprecated
added in
v1.5.0
func (*OCR1Config_OCRKeyBundle) Descriptor() ([]byte, []int)
Deprecated: Use OCR1Config_OCRKeyBundle.ProtoReflect.Descriptor instead.
func (*OCR1Config_OCRKeyBundle) GetBundleId ¶ added in v1.5.0
func (x *OCR1Config_OCRKeyBundle) GetBundleId() string
func (*OCR1Config_OCRKeyBundle) GetConfigPublicKey ¶ added in v1.5.0
func (x *OCR1Config_OCRKeyBundle) GetConfigPublicKey() string
func (*OCR1Config_OCRKeyBundle) GetOffchainPublicKey ¶ added in v1.5.0
func (x *OCR1Config_OCRKeyBundle) GetOffchainPublicKey() string
func (*OCR1Config_OCRKeyBundle) GetOnchainSigningAddress ¶ added in v1.5.0
func (x *OCR1Config_OCRKeyBundle) GetOnchainSigningAddress() string
func (*OCR1Config_OCRKeyBundle) ProtoMessage ¶ added in v1.5.0
func (*OCR1Config_OCRKeyBundle) ProtoMessage()
func (*OCR1Config_OCRKeyBundle) ProtoReflect ¶ added in v1.5.0
func (x *OCR1Config_OCRKeyBundle) ProtoReflect() protoreflect.Message
func (*OCR1Config_OCRKeyBundle) Reset ¶ added in v1.5.0
func (x *OCR1Config_OCRKeyBundle) Reset()
func (*OCR1Config_OCRKeyBundle) String ¶ added in v1.5.0
func (x *OCR1Config_OCRKeyBundle) String() string
type OCR1Config_P2PKeyBundle ¶ added in v1.5.0
type OCR1Config_P2PKeyBundle struct { PeerId string `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"` PublicKey string `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` // contains filtered or unexported fields }
func (*OCR1Config_P2PKeyBundle) Descriptor
deprecated
added in
v1.5.0
func (*OCR1Config_P2PKeyBundle) Descriptor() ([]byte, []int)
Deprecated: Use OCR1Config_P2PKeyBundle.ProtoReflect.Descriptor instead.
func (*OCR1Config_P2PKeyBundle) GetPeerId ¶ added in v1.5.0
func (x *OCR1Config_P2PKeyBundle) GetPeerId() string
func (*OCR1Config_P2PKeyBundle) GetPublicKey ¶ added in v1.5.0
func (x *OCR1Config_P2PKeyBundle) GetPublicKey() string
func (*OCR1Config_P2PKeyBundle) ProtoMessage ¶ added in v1.5.0
func (*OCR1Config_P2PKeyBundle) ProtoMessage()
func (*OCR1Config_P2PKeyBundle) ProtoReflect ¶ added in v1.5.0
func (x *OCR1Config_P2PKeyBundle) ProtoReflect() protoreflect.Message
func (*OCR1Config_P2PKeyBundle) Reset ¶ added in v1.5.0
func (x *OCR1Config_P2PKeyBundle) Reset()
func (*OCR1Config_P2PKeyBundle) String ¶ added in v1.5.0
func (x *OCR1Config_P2PKeyBundle) String() string
type OCR2Config ¶ added in v1.5.0
type OCR2Config struct { Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` IsBootstrap bool `protobuf:"varint,2,opt,name=is_bootstrap,json=isBootstrap,proto3" json:"is_bootstrap,omitempty"` P2PKeyBundle *OCR2Config_P2PKeyBundle `protobuf:"bytes,3,opt,name=p2p_key_bundle,json=p2pKeyBundle,proto3" json:"p2p_key_bundle,omitempty"` OcrKeyBundle *OCR2Config_OCRKeyBundle `protobuf:"bytes,4,opt,name=ocr_key_bundle,json=ocrKeyBundle,proto3" json:"ocr_key_bundle,omitempty"` Multiaddr string `protobuf:"bytes,5,opt,name=multiaddr,proto3" json:"multiaddr,omitempty"` // contains filtered or unexported fields }
The config for OCR2 on a specific chain
func (*OCR2Config) Descriptor
deprecated
added in
v1.5.0
func (*OCR2Config) Descriptor() ([]byte, []int)
Deprecated: Use OCR2Config.ProtoReflect.Descriptor instead.
func (*OCR2Config) GetEnabled ¶ added in v1.5.0
func (x *OCR2Config) GetEnabled() bool
func (*OCR2Config) GetIsBootstrap ¶ added in v1.5.0
func (x *OCR2Config) GetIsBootstrap() bool
func (*OCR2Config) GetMultiaddr ¶ added in v1.5.0
func (x *OCR2Config) GetMultiaddr() string
func (*OCR2Config) GetOcrKeyBundle ¶ added in v1.5.0
func (x *OCR2Config) GetOcrKeyBundle() *OCR2Config_OCRKeyBundle
func (*OCR2Config) GetP2PKeyBundle ¶ added in v1.5.0
func (x *OCR2Config) GetP2PKeyBundle() *OCR2Config_P2PKeyBundle
func (*OCR2Config) ProtoMessage ¶ added in v1.5.0
func (*OCR2Config) ProtoMessage()
func (*OCR2Config) ProtoReflect ¶ added in v1.5.0
func (x *OCR2Config) ProtoReflect() protoreflect.Message
func (*OCR2Config) Reset ¶ added in v1.5.0
func (x *OCR2Config) Reset()
func (*OCR2Config) String ¶ added in v1.5.0
func (x *OCR2Config) String() string
type OCR2Config_OCRKeyBundle ¶ added in v1.5.0
type OCR2Config_OCRKeyBundle struct { BundleId string `protobuf:"bytes,1,opt,name=bundle_id,json=bundleId,proto3" json:"bundle_id,omitempty"` ConfigPublicKey string `protobuf:"bytes,2,opt,name=config_public_key,json=configPublicKey,proto3" json:"config_public_key,omitempty"` OffchainPublicKey string `protobuf:"bytes,3,opt,name=offchain_public_key,json=offchainPublicKey,proto3" json:"offchain_public_key,omitempty"` OnchainSigningAddress string `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
func (*OCR2Config_OCRKeyBundle) Descriptor
deprecated
added in
v1.5.0
func (*OCR2Config_OCRKeyBundle) Descriptor() ([]byte, []int)
Deprecated: Use OCR2Config_OCRKeyBundle.ProtoReflect.Descriptor instead.
func (*OCR2Config_OCRKeyBundle) GetBundleId ¶ added in v1.5.0
func (x *OCR2Config_OCRKeyBundle) GetBundleId() string
func (*OCR2Config_OCRKeyBundle) GetConfigPublicKey ¶ added in v1.5.0
func (x *OCR2Config_OCRKeyBundle) GetConfigPublicKey() string
func (*OCR2Config_OCRKeyBundle) GetOffchainPublicKey ¶ added in v1.5.0
func (x *OCR2Config_OCRKeyBundle) GetOffchainPublicKey() string
func (*OCR2Config_OCRKeyBundle) GetOnchainSigningAddress ¶ added in v1.5.0
func (x *OCR2Config_OCRKeyBundle) GetOnchainSigningAddress() string
func (*OCR2Config_OCRKeyBundle) ProtoMessage ¶ added in v1.5.0
func (*OCR2Config_OCRKeyBundle) ProtoMessage()
func (*OCR2Config_OCRKeyBundle) ProtoReflect ¶ added in v1.5.0
func (x *OCR2Config_OCRKeyBundle) ProtoReflect() protoreflect.Message
func (*OCR2Config_OCRKeyBundle) Reset ¶ added in v1.5.0
func (x *OCR2Config_OCRKeyBundle) Reset()
func (*OCR2Config_OCRKeyBundle) String ¶ added in v1.5.0
func (x *OCR2Config_OCRKeyBundle) String() string
type OCR2Config_P2PKeyBundle ¶ added in v1.5.0
type OCR2Config_P2PKeyBundle struct { PeerId string `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"` PublicKey string `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` // contains filtered or unexported fields }
func (*OCR2Config_P2PKeyBundle) Descriptor
deprecated
added in
v1.5.0
func (*OCR2Config_P2PKeyBundle) Descriptor() ([]byte, []int)
Deprecated: Use OCR2Config_P2PKeyBundle.ProtoReflect.Descriptor instead.
func (*OCR2Config_P2PKeyBundle) GetPeerId ¶ added in v1.5.0
func (x *OCR2Config_P2PKeyBundle) GetPeerId() string
func (*OCR2Config_P2PKeyBundle) GetPublicKey ¶ added in v1.5.0
func (x *OCR2Config_P2PKeyBundle) GetPublicKey() string
func (*OCR2Config_P2PKeyBundle) ProtoMessage ¶ added in v1.5.0
func (*OCR2Config_P2PKeyBundle) ProtoMessage()
func (*OCR2Config_P2PKeyBundle) ProtoReflect ¶ added in v1.5.0
func (x *OCR2Config_P2PKeyBundle) ProtoReflect() protoreflect.Message
func (*OCR2Config_P2PKeyBundle) Reset ¶ added in v1.5.0
func (x *OCR2Config_P2PKeyBundle) Reset()
func (*OCR2Config_P2PKeyBundle) String ¶ added in v1.5.0
func (x *OCR2Config_P2PKeyBundle) String() string
type ProposeJobRequest ¶
type ProposeJobRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Spec string `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` Multiaddrs []string `protobuf:"bytes,3,rep,name=multiaddrs,proto3" json:"multiaddrs,omitempty"` Version int64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*ProposeJobRequest) Descriptor
deprecated
func (*ProposeJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProposeJobRequest.ProtoReflect.Descriptor instead.
func (*ProposeJobRequest) GetId ¶
func (x *ProposeJobRequest) GetId() string
func (*ProposeJobRequest) GetMultiaddrs ¶ added in v1.0.0
func (x *ProposeJobRequest) GetMultiaddrs() []string
func (*ProposeJobRequest) GetSpec ¶
func (x *ProposeJobRequest) GetSpec() string
func (*ProposeJobRequest) GetVersion ¶ added in v1.2.0
func (x *ProposeJobRequest) GetVersion() int64
func (*ProposeJobRequest) ProtoMessage ¶
func (*ProposeJobRequest) ProtoMessage()
func (*ProposeJobRequest) ProtoReflect ¶
func (x *ProposeJobRequest) ProtoReflect() protoreflect.Message
func (*ProposeJobRequest) Reset ¶
func (x *ProposeJobRequest) Reset()
func (*ProposeJobRequest) String ¶
func (x *ProposeJobRequest) String() string
type ProposeJobResponse ¶
type ProposeJobResponse struct { Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*ProposeJobResponse) Descriptor
deprecated
func (*ProposeJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProposeJobResponse.ProtoReflect.Descriptor instead.
func (*ProposeJobResponse) GetId ¶
func (x *ProposeJobResponse) GetId() string
func (*ProposeJobResponse) ProtoMessage ¶
func (*ProposeJobResponse) ProtoMessage()
func (*ProposeJobResponse) ProtoReflect ¶
func (x *ProposeJobResponse) ProtoReflect() protoreflect.Message
func (*ProposeJobResponse) Reset ¶
func (x *ProposeJobResponse) Reset()
func (*ProposeJobResponse) String ¶
func (x *ProposeJobResponse) String() string
type RejectedJobRequest ¶ added in v0.10.10
type RejectedJobRequest struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*RejectedJobRequest) Descriptor
deprecated
added in
v0.10.10
func (*RejectedJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use RejectedJobRequest.ProtoReflect.Descriptor instead.
func (*RejectedJobRequest) GetUuid ¶ added in v0.10.11
func (x *RejectedJobRequest) GetUuid() string
func (*RejectedJobRequest) GetVersion ¶ added in v1.2.0
func (x *RejectedJobRequest) GetVersion() int64
func (*RejectedJobRequest) ProtoMessage ¶ added in v0.10.10
func (*RejectedJobRequest) ProtoMessage()
func (*RejectedJobRequest) ProtoReflect ¶ added in v0.10.10
func (x *RejectedJobRequest) ProtoReflect() protoreflect.Message
func (*RejectedJobRequest) Reset ¶ added in v0.10.10
func (x *RejectedJobRequest) Reset()
func (*RejectedJobRequest) String ¶ added in v0.10.10
func (x *RejectedJobRequest) String() string
type RejectedJobResponse ¶ added in v0.10.10
type RejectedJobResponse struct {
// contains filtered or unexported fields
}
func (*RejectedJobResponse) Descriptor
deprecated
added in
v0.10.10
func (*RejectedJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use RejectedJobResponse.ProtoReflect.Descriptor instead.
func (*RejectedJobResponse) ProtoMessage ¶ added in v0.10.10
func (*RejectedJobResponse) ProtoMessage()
func (*RejectedJobResponse) ProtoReflect ¶ added in v0.10.10
func (x *RejectedJobResponse) ProtoReflect() protoreflect.Message
func (*RejectedJobResponse) Reset ¶ added in v0.10.10
func (x *RejectedJobResponse) Reset()
func (*RejectedJobResponse) String ¶ added in v0.10.10
func (x *RejectedJobResponse) String() string
type UpdateNodeRequest ¶ added in v0.10.10
type UpdateNodeRequest struct { JobTypes []JobType `protobuf:"varint,1,rep,packed,name=job_types,json=jobTypes,proto3,enum=cfm.JobType" json:"job_types,omitempty"` ChainId int64 `protobuf:"varint,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // To be removed when all nodes are upgraded to 1.2 AccountAddresses []string `protobuf:"bytes,3,rep,name=account_addresses,json=accountAddresses,proto3" json:"account_addresses,omitempty"` IsBootstrapPeer bool `protobuf:"varint,4,opt,name=is_bootstrap_peer,json=isBootstrapPeer,proto3" json:"is_bootstrap_peer,omitempty"` BootstrapMultiaddr string `protobuf:"bytes,5,opt,name=bootstrap_multiaddr,json=bootstrapMultiaddr,proto3" json:"bootstrap_multiaddr,omitempty"` Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"` ChainIds []int64 `protobuf:"varint,7,rep,packed,name=chain_ids,json=chainIds,proto3" json:"chain_ids,omitempty"` Accounts []*Account `protobuf:"bytes,8,rep,name=accounts,proto3" json:"accounts,omitempty"` Chains []*Chain `protobuf:"bytes,9,rep,name=chains,proto3" json:"chains,omitempty"` ChainConfigs []*ChainConfig `protobuf:"bytes,10,rep,name=chain_configs,json=chainConfigs,proto3" json:"chain_configs,omitempty"` // contains filtered or unexported fields }
func (*UpdateNodeRequest) Descriptor
deprecated
added in
v0.10.10
func (*UpdateNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateNodeRequest.ProtoReflect.Descriptor instead.
func (*UpdateNodeRequest) GetAccountAddresses ¶ added in v0.10.11
func (x *UpdateNodeRequest) GetAccountAddresses() []string
func (*UpdateNodeRequest) GetAccounts ¶ added in v1.2.0
func (x *UpdateNodeRequest) GetAccounts() []*Account
func (*UpdateNodeRequest) GetBootstrapMultiaddr ¶ added in v0.10.11
func (x *UpdateNodeRequest) GetBootstrapMultiaddr() string
func (*UpdateNodeRequest) GetChainConfigs ¶ added in v1.5.0
func (x *UpdateNodeRequest) GetChainConfigs() []*ChainConfig
func (*UpdateNodeRequest) GetChainId ¶ added in v0.10.10
func (x *UpdateNodeRequest) GetChainId() int64
func (*UpdateNodeRequest) GetChainIds ¶ added in v1.0.0
func (x *UpdateNodeRequest) GetChainIds() []int64
func (*UpdateNodeRequest) GetChains ¶ added in v1.2.0
func (x *UpdateNodeRequest) GetChains() []*Chain
func (*UpdateNodeRequest) GetIsBootstrapPeer ¶ added in v0.10.11
func (x *UpdateNodeRequest) GetIsBootstrapPeer() bool
func (*UpdateNodeRequest) GetJobTypes ¶ added in v0.10.10
func (x *UpdateNodeRequest) GetJobTypes() []JobType
func (*UpdateNodeRequest) GetVersion ¶ added in v1.0.0
func (x *UpdateNodeRequest) GetVersion() string
func (*UpdateNodeRequest) ProtoMessage ¶ added in v0.10.10
func (*UpdateNodeRequest) ProtoMessage()
func (*UpdateNodeRequest) ProtoReflect ¶ added in v0.10.10
func (x *UpdateNodeRequest) ProtoReflect() protoreflect.Message
func (*UpdateNodeRequest) Reset ¶ added in v0.10.10
func (x *UpdateNodeRequest) Reset()
func (*UpdateNodeRequest) String ¶ added in v0.10.10
func (x *UpdateNodeRequest) String() string
type UpdateNodeResponse ¶ added in v0.10.10
type UpdateNodeResponse struct {
// contains filtered or unexported fields
}
func (*UpdateNodeResponse) Descriptor
deprecated
added in
v0.10.10
func (*UpdateNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateNodeResponse.ProtoReflect.Descriptor instead.
func (*UpdateNodeResponse) ProtoMessage ¶ added in v0.10.10
func (*UpdateNodeResponse) ProtoMessage()
func (*UpdateNodeResponse) ProtoReflect ¶ added in v0.10.10
func (x *UpdateNodeResponse) ProtoReflect() protoreflect.Message
func (*UpdateNodeResponse) Reset ¶ added in v0.10.10
func (x *UpdateNodeResponse) Reset()
func (*UpdateNodeResponse) String ¶ added in v0.10.10
func (x *UpdateNodeResponse) String() string