node

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Dec 16, 2024 License: MIT Imports: 10 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	NodeService_DisableNode_FullMethodName          = "/api.node.v1.NodeService/DisableNode"
	NodeService_EnableNode_FullMethodName           = "/api.node.v1.NodeService/EnableNode"
	NodeService_GetNode_FullMethodName              = "/api.node.v1.NodeService/GetNode"
	NodeService_ListNodes_FullMethodName            = "/api.node.v1.NodeService/ListNodes"
	NodeService_ListNodeChainConfigs_FullMethodName = "/api.node.v1.NodeService/ListNodeChainConfigs"
	NodeService_RegisterNode_FullMethodName         = "/api.node.v1.NodeService/RegisterNode"
	NodeService_UpdateNode_FullMethodName           = "/api.node.v1.NodeService/UpdateNode"
)

Variables

View Source 
var (
	ChainType_name = map[int32]string{
		0: "CHAIN_TYPE_UNSPECIFIED",
		1: "CHAIN_TYPE_EVM",
		2: "CHAIN_TYPE_SOLANA",
		3: "CHAIN_TYPE_STARKNET",
		4: "CHAIN_TYPE_APTOS",
		5: "CHAIN_TYPE_TRON",
	}
	ChainType_value = map[string]int32{
		"CHAIN_TYPE_UNSPECIFIED": 0,
		"CHAIN_TYPE_EVM":         1,
		"CHAIN_TYPE_SOLANA":      2,
		"CHAIN_TYPE_STARKNET":    3,
		"CHAIN_TYPE_APTOS":       4,
		"CHAIN_TYPE_TRON":        5,
	}
)

Enum value maps for ChainType.

View Source 
var (
	EnableState_name = map[int32]string{
		0: "ENABLE_STATE_UNSPECIFIED",
		1: "ENABLE_STATE_ENABLED",
		2: "ENABLE_STATE_DISABLED",
	}
	EnableState_value = map[string]int32{
		"ENABLE_STATE_UNSPECIFIED": 0,
		"ENABLE_STATE_ENABLED":     1,
		"ENABLE_STATE_DISABLED":    2,
	}
)

Enum value maps for EnableState.

View Source 
var File_job_distributor_v1_node_node_proto protoreflect.FileDescriptor
View Source 
var NodeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.node.v1.NodeService",
	HandlerType: (*NodeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DisableNode",
			Handler:    _NodeService_DisableNode_Handler,
		},
		{
			MethodName: "EnableNode",
			Handler:    _NodeService_EnableNode_Handler,
		},
		{
			MethodName: "GetNode",
			Handler:    _NodeService_GetNode_Handler,
		},
		{
			MethodName: "ListNodes",
			Handler:    _NodeService_ListNodes_Handler,
		},
		{
			MethodName: "ListNodeChainConfigs",
			Handler:    _NodeService_ListNodeChainConfigs_Handler,
		},
		{
			MethodName: "RegisterNode",
			Handler:    _NodeService_RegisterNode_Handler,
		},
		{
			MethodName: "UpdateNode",
			Handler:    _NodeService_UpdateNode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "job-distributor/v1/node/node.proto",
}

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

Functions

func RegisterNodeServiceServer 

func RegisterNodeServiceServer(s grpc.ServiceRegistrar, srv NodeServiceServer)

Types

type Chain 

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=api.node.v1.ChainType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Chain) Descriptor deprecated 

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

Deprecated: Use Chain.ProtoReflect.Descriptor instead.

func (*Chain) GetId 

func (x *Chain) GetId() string

func (*Chain) GetType 

func (x *Chain) GetType() ChainType

func (*Chain) ProtoMessage 

func (*Chain) ProtoMessage()

func (*Chain) ProtoReflect 

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

func (*Chain) Reset 

func (x *Chain) Reset()

func (*Chain) String 

func (x *Chain) String() string

type ChainConfig 

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"`
	// For EVM chains, we do not need this value and it is kept in the node's
	// keystore. For starknet, because the wallet address needs to be deployed
	// using this value and this pub key needs to be passed into the starknet
	// relayer, we request the node to send this directly to CLO.
	AccountAddressPublicKey *string `` /* 140-byte string literal not displayed */
	NodeId                  string  `protobuf:"bytes,8,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainConfig) Descriptor deprecated 

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

Deprecated: Use ChainConfig.ProtoReflect.Descriptor instead.

func (*ChainConfig) GetAccountAddress 

func (x *ChainConfig) GetAccountAddress() string

func (*ChainConfig) GetAccountAddressPublicKey 

func (x *ChainConfig) GetAccountAddressPublicKey() string

func (*ChainConfig) GetAdminAddress 

func (x *ChainConfig) GetAdminAddress() string

func (*ChainConfig) GetChain 

func (x *ChainConfig) GetChain() *Chain

func (*ChainConfig) GetFluxMonitorConfig 

func (x *ChainConfig) GetFluxMonitorConfig() *FluxMonitorConfig

func (*ChainConfig) GetNodeId added in v0.4.0 

func (x *ChainConfig) GetNodeId() string

func (*ChainConfig) GetOcr1Config 

func (x *ChainConfig) GetOcr1Config() *OCR1Config

func (*ChainConfig) GetOcr2Config 

func (x *ChainConfig) GetOcr2Config() *OCR2Config

func (*ChainConfig) ProtoMessage 

func (*ChainConfig) ProtoMessage()

func (*ChainConfig) ProtoReflect 

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

func (*ChainConfig) Reset 

func (x *ChainConfig) Reset()

func (*ChainConfig) String 

func (x *ChainConfig) String() string

type ChainType 

type ChainType int32
const (
	ChainType_CHAIN_TYPE_UNSPECIFIED ChainType = 0
	ChainType_CHAIN_TYPE_EVM         ChainType = 1
	ChainType_CHAIN_TYPE_SOLANA      ChainType = 2
	ChainType_CHAIN_TYPE_STARKNET    ChainType = 3
	ChainType_CHAIN_TYPE_APTOS       ChainType = 4
	ChainType_CHAIN_TYPE_TRON        ChainType = 5
)

func (ChainType) Descriptor 

func (ChainType) Descriptor() protoreflect.EnumDescriptor

func (ChainType) Enum 

func (x ChainType) Enum() *ChainType

func (ChainType) EnumDescriptor deprecated 

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

Deprecated: Use ChainType.Descriptor instead.

func (ChainType) Number 

func (x ChainType) Number() protoreflect.EnumNumber

func (ChainType) String 

func (x ChainType) String() string

func (ChainType) Type 

func (ChainType) Type() protoreflect.EnumType

type DisableNodeRequest 

type DisableNodeRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier of the node to disable.
	// contains filtered or unexported fields
}

DisableNodeRequest is used to mark a node as disabled.

func (*DisableNodeRequest) Descriptor deprecated 

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

Deprecated: Use DisableNodeRequest.ProtoReflect.Descriptor instead.

func (*DisableNodeRequest) GetId 

func (x *DisableNodeRequest) GetId() string

func (*DisableNodeRequest) ProtoMessage 

func (*DisableNodeRequest) ProtoMessage()

func (*DisableNodeRequest) ProtoReflect 

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

func (*DisableNodeRequest) Reset 

func (x *DisableNodeRequest) Reset()

func (*DisableNodeRequest) String 

func (x *DisableNodeRequest) String() string

type DisableNodeResponse 

type DisableNodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // Disabled node details.
	// contains filtered or unexported fields
}

DisableNodeResponse returns the disabled node.

func (*DisableNodeResponse) Descriptor deprecated 

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

Deprecated: Use DisableNodeResponse.ProtoReflect.Descriptor instead.

func (*DisableNodeResponse) GetNode 

func (x *DisableNodeResponse) GetNode() *Node

func (*DisableNodeResponse) ProtoMessage 

func (*DisableNodeResponse) ProtoMessage()

func (*DisableNodeResponse) ProtoReflect 

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

func (*DisableNodeResponse) Reset 

func (x *DisableNodeResponse) Reset()

func (*DisableNodeResponse) String 

func (x *DisableNodeResponse) String() string

type EnableNodeRequest 

type EnableNodeRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier of the node to enable.
	// contains filtered or unexported fields
}

EnableNodeRequest is used to reactivate a disabled node.

func (*EnableNodeRequest) Descriptor deprecated 

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

Deprecated: Use EnableNodeRequest.ProtoReflect.Descriptor instead.

func (*EnableNodeRequest) GetId 

func (x *EnableNodeRequest) GetId() string

func (*EnableNodeRequest) ProtoMessage 

func (*EnableNodeRequest) ProtoMessage()

func (*EnableNodeRequest) ProtoReflect 

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

func (*EnableNodeRequest) Reset 

func (x *EnableNodeRequest) Reset()

func (*EnableNodeRequest) String 

func (x *EnableNodeRequest) String() string

type EnableNodeResponse 

type EnableNodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // Enabled node details.
	// contains filtered or unexported fields
}

EnableNodeResponse returns the enabled node.

func (*EnableNodeResponse) Descriptor deprecated 

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

Deprecated: Use EnableNodeResponse.ProtoReflect.Descriptor instead.

func (*EnableNodeResponse) GetNode 

func (x *EnableNodeResponse) GetNode() *Node

func (*EnableNodeResponse) ProtoMessage 

func (*EnableNodeResponse) ProtoMessage()

func (*EnableNodeResponse) ProtoReflect 

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

func (*EnableNodeResponse) Reset 

func (x *EnableNodeResponse) Reset()

func (*EnableNodeResponse) String 

func (x *EnableNodeResponse) String() string

type EnableState 

type EnableState int32

EnableState represents the enabled state of the node. 

const (
	EnableState_ENABLE_STATE_UNSPECIFIED EnableState = 0
	EnableState_ENABLE_STATE_ENABLED     EnableState = 1
	EnableState_ENABLE_STATE_DISABLED    EnableState = 2
)

func (EnableState) Descriptor 

func (EnableState) Descriptor() protoreflect.EnumDescriptor

func (EnableState) Enum 

func (x EnableState) Enum() *EnableState

func (EnableState) EnumDescriptor deprecated 

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

Deprecated: Use EnableState.Descriptor instead.

func (EnableState) Number 

func (x EnableState) Number() protoreflect.EnumNumber

func (EnableState) String 

func (x EnableState) String() string

func (EnableState) Type 

func (EnableState) Type() protoreflect.EnumType

type FluxMonitorConfig 

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 

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

Deprecated: Use FluxMonitorConfig.ProtoReflect.Descriptor instead.

func (*FluxMonitorConfig) GetEnabled 

func (x *FluxMonitorConfig) GetEnabled() bool

func (*FluxMonitorConfig) ProtoMessage 

func (*FluxMonitorConfig) ProtoMessage()

func (*FluxMonitorConfig) ProtoReflect 

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

func (*FluxMonitorConfig) Reset 

func (x *FluxMonitorConfig) Reset()

func (*FluxMonitorConfig) String 

func (x *FluxMonitorConfig) String() string

type GetNodeRequest 

type GetNodeRequest struct {
	Id        string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                      // Unique identifier of the node to retrieve.
	PublicKey *string `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3,oneof" json:"public_key,omitempty"` // Public Key of the node to retrieve.
	// contains filtered or unexported fields
}

GetNodeRequest is the request to retrieve a single node by either its ID or public key (but not both).

func (*GetNodeRequest) Descriptor deprecated 

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

Deprecated: Use GetNodeRequest.ProtoReflect.Descriptor instead.

func (*GetNodeRequest) GetId 

func (x *GetNodeRequest) GetId() string

func (*GetNodeRequest) GetPublicKey added in v0.8.0 

func (x *GetNodeRequest) GetPublicKey() string

func (*GetNodeRequest) ProtoMessage 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) ProtoReflect 

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

func (*GetNodeRequest) Reset 

func (x *GetNodeRequest) Reset()

func (*GetNodeRequest) String 

func (x *GetNodeRequest) String() string

type GetNodeResponse 

type GetNodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // Details of the retrieved node.
	// contains filtered or unexported fields
}

GetNodeResponse is the response containing the requested node.

func (*GetNodeResponse) Descriptor deprecated 

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

Deprecated: Use GetNodeResponse.ProtoReflect.Descriptor instead.

func (*GetNodeResponse) GetNode 

func (x *GetNodeResponse) GetNode() *Node

func (*GetNodeResponse) ProtoMessage 

func (*GetNodeResponse) ProtoMessage()

func (*GetNodeResponse) ProtoReflect 

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

func (*GetNodeResponse) Reset 

func (x *GetNodeResponse) Reset()

func (*GetNodeResponse) String 

func (x *GetNodeResponse) String() string

type ListNodeChainConfigsRequest 

type ListNodeChainConfigsRequest struct {
	Filter *ListNodeChainConfigsRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodeChainConfigsRequest) Descriptor deprecated 

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

Deprecated: Use ListNodeChainConfigsRequest.ProtoReflect.Descriptor instead.

func (*ListNodeChainConfigsRequest) GetFilter 

func (x *ListNodeChainConfigsRequest) GetFilter() *ListNodeChainConfigsRequest_Filter

func (*ListNodeChainConfigsRequest) ProtoMessage 

func (*ListNodeChainConfigsRequest) ProtoMessage()

func (*ListNodeChainConfigsRequest) ProtoReflect 

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

func (*ListNodeChainConfigsRequest) Reset 

func (x *ListNodeChainConfigsRequest) Reset()

func (*ListNodeChainConfigsRequest) String 

func (x *ListNodeChainConfigsRequest) String() string

type ListNodeChainConfigsRequest_Filter 

type ListNodeChainConfigsRequest_Filter struct {
	NodeIds []string `protobuf:"bytes,1,rep,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodeChainConfigsRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListNodeChainConfigsRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListNodeChainConfigsRequest_Filter) GetNodeIds 

func (x *ListNodeChainConfigsRequest_Filter) GetNodeIds() []string

func (*ListNodeChainConfigsRequest_Filter) ProtoMessage 

func (*ListNodeChainConfigsRequest_Filter) ProtoMessage()

func (*ListNodeChainConfigsRequest_Filter) ProtoReflect 

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

func (*ListNodeChainConfigsRequest_Filter) Reset 

func (x *ListNodeChainConfigsRequest_Filter) Reset()

func (*ListNodeChainConfigsRequest_Filter) String 

func (x *ListNodeChainConfigsRequest_Filter) String() string

type ListNodeChainConfigsResponse 

type ListNodeChainConfigsResponse struct {
	ChainConfigs []*ChainConfig `protobuf:"bytes,1,rep,name=chain_configs,json=chainConfigs,proto3" json:"chain_configs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodeChainConfigsResponse) Descriptor deprecated 

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

Deprecated: Use ListNodeChainConfigsResponse.ProtoReflect.Descriptor instead.

func (*ListNodeChainConfigsResponse) GetChainConfigs 

func (x *ListNodeChainConfigsResponse) GetChainConfigs() []*ChainConfig

func (*ListNodeChainConfigsResponse) ProtoMessage 

func (*ListNodeChainConfigsResponse) ProtoMessage()

func (*ListNodeChainConfigsResponse) ProtoReflect 

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

func (*ListNodeChainConfigsResponse) Reset 

func (x *ListNodeChainConfigsResponse) Reset()

func (*ListNodeChainConfigsResponse) String 

func (x *ListNodeChainConfigsResponse) String() string

type ListNodesRequest 

type ListNodesRequest struct {
	Filter *ListNodesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

* ListNodesRequest is the request object for the ListNodes method.

Provide a filter to return a subset of data. Nodes can be filtered by:

  • ids - A list of node ids.
  • archived - The archived state of the node.
  • selectors - A list of selectors to filter nodes by their labels.
  • public_keys - A list of node public keys.

If no filter is provided, all nodes are returned.

func (*ListNodesRequest) Descriptor deprecated 

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

Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.

func (*ListNodesRequest) GetFilter 

func (x *ListNodesRequest) GetFilter() *ListNodesRequest_Filter

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) ProtoReflect 

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

func (*ListNodesRequest) Reset 

func (x *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (x *ListNodesRequest) String() string

type ListNodesRequest_Filter 

type ListNodesRequest_Filter struct {
	Ids        []string           `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Enabled    EnableState        `protobuf:"varint,2,opt,name=enabled,proto3,enum=api.node.v1.EnableState" json:"enabled,omitempty"`
	Selectors  []*ptypes.Selector `protobuf:"bytes,3,rep,name=selectors,proto3" json:"selectors,omitempty"`
	PublicKeys []string           `protobuf:"bytes,4,rep,name=public_keys,json=publicKeys,proto3" json:"public_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodesRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListNodesRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListNodesRequest_Filter) GetEnabled 

func (x *ListNodesRequest_Filter) GetEnabled() EnableState

func (*ListNodesRequest_Filter) GetIds 

func (x *ListNodesRequest_Filter) GetIds() []string

func (*ListNodesRequest_Filter) GetPublicKeys added in v0.8.0 

func (x *ListNodesRequest_Filter) GetPublicKeys() []string

func (*ListNodesRequest_Filter) GetSelectors 

func (x *ListNodesRequest_Filter) GetSelectors() []*ptypes.Selector

func (*ListNodesRequest_Filter) ProtoMessage 

func (*ListNodesRequest_Filter) ProtoMessage()

func (*ListNodesRequest_Filter) ProtoReflect 

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

func (*ListNodesRequest_Filter) Reset 

func (x *ListNodesRequest_Filter) Reset()

func (*ListNodesRequest_Filter) String 

func (x *ListNodesRequest_Filter) String() string

type ListNodesResponse 

type ListNodesResponse struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"` // List of nodes.
	// contains filtered or unexported fields
}

* ListNodesResponse is the response object for the ListNodes method.

It returns a list of nodes that match the filter criteria.

func (*ListNodesResponse) Descriptor deprecated 

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

Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.

func (*ListNodesResponse) GetNodes 

func (x *ListNodesResponse) GetNodes() []*Node

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) ProtoReflect 

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

func (*ListNodesResponse) Reset 

func (x *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (x *ListNodesResponse) String() string

type Node 

type Node struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                            // Unique identifier for the node.
	Name        string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                                        // Human-readable name for the node.
	PublicKey   string                 `protobuf:"bytes,3,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`             // Public key used for secure communications.
	IsEnabled   bool                   `protobuf:"varint,4,opt,name=is_enabled,json=isEnabled,proto3" json:"is_enabled,omitempty"`            // Indicates if the node is currently enabled.
	IsConnected bool                   `protobuf:"varint,5,opt,name=is_connected,json=isConnected,proto3" json:"is_connected,omitempty"`      // Indicates if the node is currently connected to the network.
	Labels      []*ptypes.Label        `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty"`                                    // Set of labels associated with the node.
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`             // Timestamp when the node was created.
	UpdatedAt   *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`             // Timestamp when the node was last updated.
	WorkflowKey *string                `protobuf:"bytes,9,opt,name=workflow_key,json=workflowKey,proto3,oneof" json:"workflow_key,omitempty"` // Workflow Public key
	// contains filtered or unexported fields
}

Node represents a node within the Job Distributor system.

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetCreatedAt 

func (x *Node) GetCreatedAt() *timestamppb.Timestamp

func (*Node) GetId 

func (x *Node) GetId() string

func (*Node) GetIsConnected 

func (x *Node) GetIsConnected() bool

func (*Node) GetIsEnabled 

func (x *Node) GetIsEnabled() bool

func (*Node) GetLabels 

func (x *Node) GetLabels() []*ptypes.Label

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetPublicKey 

func (x *Node) GetPublicKey() string

func (*Node) GetUpdatedAt 

func (x *Node) GetUpdatedAt() *timestamppb.Timestamp

func (*Node) GetWorkflowKey added in v0.7.0 

func (x *Node) GetWorkflowKey() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeServiceClient 

type NodeServiceClient interface {
	// DisableNode marks a node as disabled, disabling any active operations on it.
	DisableNode(ctx context.Context, in *DisableNodeRequest, opts ...grpc.CallOption) (*DisableNodeResponse, error)
	// EnableNode enabled a disabled node, allowing operations to resume.
	EnableNode(ctx context.Context, in *EnableNodeRequest, opts ...grpc.CallOption) (*EnableNodeResponse, error)
	// GetNode retrieves the details of a node by its unique identifier.
	GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*GetNodeResponse, error)
	// ListNodes returns a list of nodes, optionally filtered by the provided criteria.
	ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesResponse, error)
	ListNodeChainConfigs(ctx context.Context, in *ListNodeChainConfigsRequest, opts ...grpc.CallOption) (*ListNodeChainConfigsResponse, error)
	// RegisterNode registers a new node to the system.
	RegisterNode(ctx context.Context, in *RegisterNodeRequest, opts ...grpc.CallOption) (*RegisterNodeResponse, error)
	// UpdateNode updates the details of an existing node.
	UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*UpdateNodeResponse, error)
}

NodeServiceClient is the client API for NodeService service.

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

NodeService provides RPCs for managing nodes within the Job Distributor.

func NewNodeServiceClient 

func NewNodeServiceClient(cc grpc.ClientConnInterface) NodeServiceClient

type NodeServiceServer 

type NodeServiceServer interface {
	// DisableNode marks a node as disabled, disabling any active operations on it.
	DisableNode(context.Context, *DisableNodeRequest) (*DisableNodeResponse, error)
	// EnableNode enabled a disabled node, allowing operations to resume.
	EnableNode(context.Context, *EnableNodeRequest) (*EnableNodeResponse, error)
	// GetNode retrieves the details of a node by its unique identifier.
	GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)
	// ListNodes returns a list of nodes, optionally filtered by the provided criteria.
	ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
	ListNodeChainConfigs(context.Context, *ListNodeChainConfigsRequest) (*ListNodeChainConfigsResponse, error)
	// RegisterNode registers a new node to the system.
	RegisterNode(context.Context, *RegisterNodeRequest) (*RegisterNodeResponse, error)
	// UpdateNode updates the details of an existing node.
	UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeResponse, error)
	// contains filtered or unexported methods
}

NodeServiceServer is the server API for NodeService service. All implementations must embed UnimplementedNodeServiceServer for forward compatibility.

NodeService provides RPCs for managing nodes within the Job Distributor.

type OCR1Config 

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 

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

Deprecated: Use OCR1Config.ProtoReflect.Descriptor instead.

func (*OCR1Config) GetEnabled 

func (x *OCR1Config) GetEnabled() bool

func (*OCR1Config) GetIsBootstrap 

func (x *OCR1Config) GetIsBootstrap() bool

func (*OCR1Config) GetMultiaddr 

func (x *OCR1Config) GetMultiaddr() string

func (*OCR1Config) GetOcrKeyBundle 

func (x *OCR1Config) GetOcrKeyBundle() *OCR1Config_OCRKeyBundle

func (*OCR1Config) GetP2PKeyBundle 

func (x *OCR1Config) GetP2PKeyBundle() *OCR1Config_P2PKeyBundle

func (*OCR1Config) ProtoMessage 

func (*OCR1Config) ProtoMessage()

func (*OCR1Config) ProtoReflect 

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

func (*OCR1Config) Reset 

func (x *OCR1Config) Reset()

func (*OCR1Config) String 

func (x *OCR1Config) String() string

type OCR1Config_OCRKeyBundle 

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 

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

Deprecated: Use OCR1Config_OCRKeyBundle.ProtoReflect.Descriptor instead.

func (*OCR1Config_OCRKeyBundle) GetBundleId 

func (x *OCR1Config_OCRKeyBundle) GetBundleId() string

func (*OCR1Config_OCRKeyBundle) GetConfigPublicKey 

func (x *OCR1Config_OCRKeyBundle) GetConfigPublicKey() string

func (*OCR1Config_OCRKeyBundle) GetOffchainPublicKey 

func (x *OCR1Config_OCRKeyBundle) GetOffchainPublicKey() string

func (*OCR1Config_OCRKeyBundle) GetOnchainSigningAddress 

func (x *OCR1Config_OCRKeyBundle) GetOnchainSigningAddress() string

func (*OCR1Config_OCRKeyBundle) ProtoMessage 

func (*OCR1Config_OCRKeyBundle) ProtoMessage()

func (*OCR1Config_OCRKeyBundle) ProtoReflect 

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

func (*OCR1Config_OCRKeyBundle) Reset 

func (x *OCR1Config_OCRKeyBundle) Reset()

func (*OCR1Config_OCRKeyBundle) String 

func (x *OCR1Config_OCRKeyBundle) String() string

type OCR1Config_P2PKeyBundle 

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 

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

Deprecated: Use OCR1Config_P2PKeyBundle.ProtoReflect.Descriptor instead.

func (*OCR1Config_P2PKeyBundle) GetPeerId 

func (x *OCR1Config_P2PKeyBundle) GetPeerId() string

func (*OCR1Config_P2PKeyBundle) GetPublicKey 

func (x *OCR1Config_P2PKeyBundle) GetPublicKey() string

func (*OCR1Config_P2PKeyBundle) ProtoMessage 

func (*OCR1Config_P2PKeyBundle) ProtoMessage()

func (*OCR1Config_P2PKeyBundle) ProtoReflect 

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

func (*OCR1Config_P2PKeyBundle) Reset 

func (x *OCR1Config_P2PKeyBundle) Reset()

func (*OCR1Config_P2PKeyBundle) String 

func (x *OCR1Config_P2PKeyBundle) String() string

type OCR2Config 

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"`
	Plugins          *OCR2Config_Plugins      `protobuf:"bytes,6,opt,name=plugins,proto3" json:"plugins,omitempty"`
	ForwarderAddress *string                  `protobuf:"bytes,7,opt,name=forwarder_address,json=forwarderAddress,proto3,oneof" json:"forwarder_address,omitempty"`
	// contains filtered or unexported fields
}

The config for OCR2 on a specific chain

func (*OCR2Config) Descriptor deprecated 

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

Deprecated: Use OCR2Config.ProtoReflect.Descriptor instead.

func (*OCR2Config) GetEnabled 

func (x *OCR2Config) GetEnabled() bool

func (*OCR2Config) GetForwarderAddress 

func (x *OCR2Config) GetForwarderAddress() string

func (*OCR2Config) GetIsBootstrap 

func (x *OCR2Config) GetIsBootstrap() bool

func (*OCR2Config) GetMultiaddr 

func (x *OCR2Config) GetMultiaddr() string

func (*OCR2Config) GetOcrKeyBundle 

func (x *OCR2Config) GetOcrKeyBundle() *OCR2Config_OCRKeyBundle

func (*OCR2Config) GetP2PKeyBundle 

func (x *OCR2Config) GetP2PKeyBundle() *OCR2Config_P2PKeyBundle

func (*OCR2Config) GetPlugins 

func (x *OCR2Config) GetPlugins() *OCR2Config_Plugins

func (*OCR2Config) ProtoMessage 

func (*OCR2Config) ProtoMessage()

func (*OCR2Config) ProtoReflect 

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

func (*OCR2Config) Reset 

func (x *OCR2Config) Reset()

func (*OCR2Config) String 

func (x *OCR2Config) String() string

type OCR2Config_OCRKeyBundle 

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 

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

Deprecated: Use OCR2Config_OCRKeyBundle.ProtoReflect.Descriptor instead.

func (*OCR2Config_OCRKeyBundle) GetBundleId 

func (x *OCR2Config_OCRKeyBundle) GetBundleId() string

func (*OCR2Config_OCRKeyBundle) GetConfigPublicKey 

func (x *OCR2Config_OCRKeyBundle) GetConfigPublicKey() string

func (*OCR2Config_OCRKeyBundle) GetOffchainPublicKey 

func (x *OCR2Config_OCRKeyBundle) GetOffchainPublicKey() string

func (*OCR2Config_OCRKeyBundle) GetOnchainSigningAddress 

func (x *OCR2Config_OCRKeyBundle) GetOnchainSigningAddress() string

func (*OCR2Config_OCRKeyBundle) ProtoMessage 

func (*OCR2Config_OCRKeyBundle) ProtoMessage()

func (*OCR2Config_OCRKeyBundle) ProtoReflect 

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

func (*OCR2Config_OCRKeyBundle) Reset 

func (x *OCR2Config_OCRKeyBundle) Reset()

func (*OCR2Config_OCRKeyBundle) String 

func (x *OCR2Config_OCRKeyBundle) String() string

type OCR2Config_P2PKeyBundle 

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 

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

Deprecated: Use OCR2Config_P2PKeyBundle.ProtoReflect.Descriptor instead.

func (*OCR2Config_P2PKeyBundle) GetPeerId 

func (x *OCR2Config_P2PKeyBundle) GetPeerId() string

func (*OCR2Config_P2PKeyBundle) GetPublicKey 

func (x *OCR2Config_P2PKeyBundle) GetPublicKey() string

func (*OCR2Config_P2PKeyBundle) ProtoMessage 

func (*OCR2Config_P2PKeyBundle) ProtoMessage()

func (*OCR2Config_P2PKeyBundle) ProtoReflect 

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

func (*OCR2Config_P2PKeyBundle) Reset 

func (x *OCR2Config_P2PKeyBundle) Reset()

func (*OCR2Config_P2PKeyBundle) String 

func (x *OCR2Config_P2PKeyBundle) String() string

type OCR2Config_Plugins 

type OCR2Config_Plugins struct {
	Commit     bool `protobuf:"varint,1,opt,name=commit,proto3" json:"commit,omitempty"`
	Execute    bool `protobuf:"varint,2,opt,name=execute,proto3" json:"execute,omitempty"`
	Median     bool `protobuf:"varint,3,opt,name=median,proto3" json:"median,omitempty"`
	Mercury    bool `protobuf:"varint,4,opt,name=mercury,proto3" json:"mercury,omitempty"`
	Rebalancer bool `protobuf:"varint,5,opt,name=rebalancer,proto3" json:"rebalancer,omitempty"`
	// contains filtered or unexported fields
}

func (*OCR2Config_Plugins) Descriptor deprecated 

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

Deprecated: Use OCR2Config_Plugins.ProtoReflect.Descriptor instead.

func (*OCR2Config_Plugins) GetCommit 

func (x *OCR2Config_Plugins) GetCommit() bool

func (*OCR2Config_Plugins) GetExecute 

func (x *OCR2Config_Plugins) GetExecute() bool

func (*OCR2Config_Plugins) GetMedian 

func (x *OCR2Config_Plugins) GetMedian() bool

func (*OCR2Config_Plugins) GetMercury 

func (x *OCR2Config_Plugins) GetMercury() bool

func (*OCR2Config_Plugins) GetRebalancer 

func (x *OCR2Config_Plugins) GetRebalancer() bool

func (*OCR2Config_Plugins) ProtoMessage 

func (*OCR2Config_Plugins) ProtoMessage()

func (*OCR2Config_Plugins) ProtoReflect 

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

func (*OCR2Config_Plugins) Reset 

func (x *OCR2Config_Plugins) Reset()

func (*OCR2Config_Plugins) String 

func (x *OCR2Config_Plugins) String() string

type RegisterNodeRequest 

type RegisterNodeRequest struct {
	Name      string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                            // Desired name for the node.
	PublicKey string          `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` // Public key for the node.
	Labels    []*ptypes.Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`                        // Labels to associate with the node.
	// contains filtered or unexported fields
}

RegisterNodeRequest contains the information needed to register a new node.

func (*RegisterNodeRequest) Descriptor deprecated 

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

Deprecated: Use RegisterNodeRequest.ProtoReflect.Descriptor instead.

func (*RegisterNodeRequest) GetLabels 

func (x *RegisterNodeRequest) GetLabels() []*ptypes.Label

func (*RegisterNodeRequest) GetName 

func (x *RegisterNodeRequest) GetName() string

func (*RegisterNodeRequest) GetPublicKey 

func (x *RegisterNodeRequest) GetPublicKey() string

func (*RegisterNodeRequest) ProtoMessage 

func (*RegisterNodeRequest) ProtoMessage()

func (*RegisterNodeRequest) ProtoReflect 

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

func (*RegisterNodeRequest) Reset 

func (x *RegisterNodeRequest) Reset()

func (*RegisterNodeRequest) String 

func (x *RegisterNodeRequest) String() string

type RegisterNodeResponse 

type RegisterNodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // Details of the newly registered node.
	// contains filtered or unexported fields
}

RegisterNodeResponse returns the newly registered node.

func (*RegisterNodeResponse) Descriptor deprecated 

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

Deprecated: Use RegisterNodeResponse.ProtoReflect.Descriptor instead.

func (*RegisterNodeResponse) GetNode 

func (x *RegisterNodeResponse) GetNode() *Node

func (*RegisterNodeResponse) ProtoMessage 

func (*RegisterNodeResponse) ProtoMessage()

func (*RegisterNodeResponse) ProtoReflect 

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

func (*RegisterNodeResponse) Reset 

func (x *RegisterNodeResponse) Reset()

func (*RegisterNodeResponse) String 

func (x *RegisterNodeResponse) String() string

type UnimplementedNodeServiceServer 

type UnimplementedNodeServiceServer struct{}

UnimplementedNodeServiceServer must be embedded to have forward compatible implementations.

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

func (UnimplementedNodeServiceServer) DisableNode 

func (UnimplementedNodeServiceServer) DisableNode(context.Context, *DisableNodeRequest) (*DisableNodeResponse, error)

func (UnimplementedNodeServiceServer) EnableNode 

func (UnimplementedNodeServiceServer) EnableNode(context.Context, *EnableNodeRequest) (*EnableNodeResponse, error)

func (UnimplementedNodeServiceServer) GetNode 

func (UnimplementedNodeServiceServer) GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)

func (UnimplementedNodeServiceServer) ListNodeChainConfigs 

func (UnimplementedNodeServiceServer) ListNodeChainConfigs(context.Context, *ListNodeChainConfigsRequest) (*ListNodeChainConfigsResponse, error)

func (UnimplementedNodeServiceServer) ListNodes 

func (UnimplementedNodeServiceServer) ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)

func (UnimplementedNodeServiceServer) RegisterNode 

func (UnimplementedNodeServiceServer) RegisterNode(context.Context, *RegisterNodeRequest) (*RegisterNodeResponse, error)

func (UnimplementedNodeServiceServer) UpdateNode 

func (UnimplementedNodeServiceServer) UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeResponse, error)

type UnsafeNodeServiceServer 

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

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

type UpdateNodeRequest 

type UpdateNodeRequest struct {
	Id        string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                // Unique identifier of the node to update.
	Name      string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                            // New name for the node, if changing.
	PublicKey string          `protobuf:"bytes,3,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` // New public key for the node, if changing.
	Labels    []*ptypes.Label `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"`                        // New set of labels for the node, if changing.
	// contains filtered or unexported fields
}

UpdateNodeRequest contains the information necessary to update a node.

func (*UpdateNodeRequest) Descriptor deprecated 

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

Deprecated: Use UpdateNodeRequest.ProtoReflect.Descriptor instead.

func (*UpdateNodeRequest) GetId 

func (x *UpdateNodeRequest) GetId() string

func (*UpdateNodeRequest) GetLabels 

func (x *UpdateNodeRequest) GetLabels() []*ptypes.Label

func (*UpdateNodeRequest) GetName 

func (x *UpdateNodeRequest) GetName() string

func (*UpdateNodeRequest) GetPublicKey 

func (x *UpdateNodeRequest) GetPublicKey() string

func (*UpdateNodeRequest) ProtoMessage 

func (*UpdateNodeRequest) ProtoMessage()

func (*UpdateNodeRequest) ProtoReflect 

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

func (*UpdateNodeRequest) Reset 

func (x *UpdateNodeRequest) Reset()

func (*UpdateNodeRequest) String 

func (x *UpdateNodeRequest) String() string

type UpdateNodeResponse 

type UpdateNodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // Updated node details.
	// contains filtered or unexported fields
}

UpdateNodeResponse returns the updated node.

func (*UpdateNodeResponse) Descriptor deprecated 

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

Deprecated: Use UpdateNodeResponse.ProtoReflect.Descriptor instead.

func (*UpdateNodeResponse) GetNode 

func (x *UpdateNodeResponse) GetNode() *Node

func (*UpdateNodeResponse) ProtoMessage 

func (*UpdateNodeResponse) ProtoMessage()

func (*UpdateNodeResponse) ProtoReflect 

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

func (*UpdateNodeResponse) Reset 

func (x *UpdateNodeResponse) Reset()

func (*UpdateNodeResponse) String 

func (x *UpdateNodeResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.