netctrlv1

package
v0.0.0-...-4cc87ec Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package netctrlv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package netctrlv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package netctrlv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	AgentService_RegisterAgent_FullMethodName           = "/netctrl.v1.AgentService/RegisterAgent"
	AgentService_GetAgent_FullMethodName                = "/netctrl.v1.AgentService/GetAgent"
	AgentService_ListAgents_FullMethodName              = "/netctrl.v1.AgentService/ListAgents"
	AgentService_UnregisterAgent_FullMethodName         = "/netctrl.v1.AgentService/UnregisterAgent"
	AgentService_GetInstructions_FullMethodName         = "/netctrl.v1.AgentService/GetInstructions"
	AgentService_SubmitInstructionResult_FullMethodName = "/netctrl.v1.AgentService/SubmitInstructionResult"
)
View Source 
const (
	ClusterService_CreateCluster_FullMethodName = "/netctrl.v1.ClusterService/CreateCluster"
	ClusterService_GetCluster_FullMethodName    = "/netctrl.v1.ClusterService/GetCluster"
	ClusterService_ListClusters_FullMethodName  = "/netctrl.v1.ClusterService/ListClusters"
	ClusterService_UpdateCluster_FullMethodName = "/netctrl.v1.ClusterService/UpdateCluster"
	ClusterService_DeleteCluster_FullMethodName = "/netctrl.v1.ClusterService/DeleteCluster"
)
View Source 
const (
	HealthService_Check_FullMethodName = "/netctrl.v1.HealthService/Check"
	HealthService_Ready_FullMethodName = "/netctrl.v1.HealthService/Ready"
)

Variables

View Source 
var (
	AgentStatus_name = map[int32]string{
		0: "AGENT_STATUS_UNSPECIFIED",
		1: "AGENT_STATUS_ACTIVE",
		2: "AGENT_STATUS_INACTIVE",
	}
	AgentStatus_value = map[string]int32{
		"AGENT_STATUS_UNSPECIFIED": 0,
		"AGENT_STATUS_ACTIVE":      1,
		"AGENT_STATUS_INACTIVE":    2,
	}
)

Enum value maps for AgentStatus.

View Source 
var (
	PortState_name = map[int32]string{
		0: "PORT_STATE_UNSPECIFIED",
		1: "PORT_STATE_DOWN",
		2: "PORT_STATE_UP",
		3: "PORT_STATE_TESTING",
	}
	PortState_value = map[string]int32{
		"PORT_STATE_UNSPECIFIED": 0,
		"PORT_STATE_DOWN":        1,
		"PORT_STATE_UP":          2,
		"PORT_STATE_TESTING":     3,
	}
)

Enum value maps for PortState.

View Source 
var (
	PortSpeed_name = map[int32]string{
		0:   "PORT_SPEED_UNSPECIFIED",
		1:   "PORT_SPEED_1G",
		10:  "PORT_SPEED_10G",
		25:  "PORT_SPEED_25G",
		40:  "PORT_SPEED_40G",
		50:  "PORT_SPEED_50G",
		100: "PORT_SPEED_100G",
		200: "PORT_SPEED_200G",
		400: "PORT_SPEED_400G",
	}
	PortSpeed_value = map[string]int32{
		"PORT_SPEED_UNSPECIFIED": 0,
		"PORT_SPEED_1G":          1,
		"PORT_SPEED_10G":         10,
		"PORT_SPEED_25G":         25,
		"PORT_SPEED_40G":         40,
		"PORT_SPEED_50G":         50,
		"PORT_SPEED_100G":        100,
		"PORT_SPEED_200G":        200,
		"PORT_SPEED_400G":        400,
	}
)

Enum value maps for PortSpeed.

View Source 
var (
	InstructionType_name = map[int32]string{
		0: "INSTRUCTION_TYPE_UNSPECIFIED",
		1: "INSTRUCTION_TYPE_POLL_INTERVAL",
		2: "INSTRUCTION_TYPE_HEALTH_CHECK",
		3: "INSTRUCTION_TYPE_COLLECT_HARDWARE",
	}
	InstructionType_value = map[string]int32{
		"INSTRUCTION_TYPE_UNSPECIFIED":      0,
		"INSTRUCTION_TYPE_POLL_INTERVAL":    1,
		"INSTRUCTION_TYPE_HEALTH_CHECK":     2,
		"INSTRUCTION_TYPE_COLLECT_HARDWARE": 3,
	}
)

Enum value maps for InstructionType.

View Source 
var (
	HealthStatus_name = map[int32]string{
		0: "HEALTH_STATUS_UNSPECIFIED",
		1: "HEALTH_STATUS_HEALTHY",
		2: "HEALTH_STATUS_UNHEALTHY",
	}
	HealthStatus_value = map[string]int32{
		"HEALTH_STATUS_UNSPECIFIED": 0,
		"HEALTH_STATUS_HEALTHY":     1,
		"HEALTH_STATUS_UNHEALTHY":   2,
	}
)

Enum value maps for HealthStatus.

View Source 
var (
	ReadinessStatus_name = map[int32]string{
		0: "READINESS_STATUS_UNSPECIFIED",
		1: "READINESS_STATUS_READY",
		2: "READINESS_STATUS_NOT_READY",
	}
	ReadinessStatus_value = map[string]int32{
		"READINESS_STATUS_UNSPECIFIED": 0,
		"READINESS_STATUS_READY":       1,
		"READINESS_STATUS_NOT_READY":   2,
	}
)

Enum value maps for ReadinessStatus.

View Source 
var AgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "netctrl.v1.AgentService",
	HandlerType: (*AgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterAgent",
			Handler:    _AgentService_RegisterAgent_Handler,
		},
		{
			MethodName: "GetAgent",
			Handler:    _AgentService_GetAgent_Handler,
		},
		{
			MethodName: "ListAgents",
			Handler:    _AgentService_ListAgents_Handler,
		},
		{
			MethodName: "UnregisterAgent",
			Handler:    _AgentService_UnregisterAgent_Handler,
		},
		{
			MethodName: "GetInstructions",
			Handler:    _AgentService_GetInstructions_Handler,
		},
		{
			MethodName: "SubmitInstructionResult",
			Handler:    _AgentService_SubmitInstructionResult_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1/agent.proto",
}

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

View Source 
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "netctrl.v1.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCluster",
			Handler:    _ClusterService_CreateCluster_Handler,
		},
		{
			MethodName: "GetCluster",
			Handler:    _ClusterService_GetCluster_Handler,
		},
		{
			MethodName: "ListClusters",
			Handler:    _ClusterService_ListClusters_Handler,
		},
		{
			MethodName: "UpdateCluster",
			Handler:    _ClusterService_UpdateCluster_Handler,
		},
		{
			MethodName: "DeleteCluster",
			Handler:    _ClusterService_DeleteCluster_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1/cluster.proto",
}

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

View Source 
var File_v1_agent_proto protoreflect.FileDescriptor
View Source 
var File_v1_cluster_proto protoreflect.FileDescriptor
View Source 
var File_v1_health_proto protoreflect.FileDescriptor
View Source 
var HealthService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "netctrl.v1.HealthService",
	HandlerType: (*HealthServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Check",
			Handler:    _HealthService_Check_Handler,
		},
		{
			MethodName: "Ready",
			Handler:    _HealthService_Ready_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1/health.proto",
}

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

Functions

func RegisterAgentServiceHandler 

func RegisterAgentServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAgentServiceHandler registers the http handlers for service AgentService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAgentServiceHandlerClient 

func RegisterAgentServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AgentServiceClient) error

RegisterAgentServiceHandlerClient registers the http handlers for service AgentService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AgentServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AgentServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AgentServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterAgentServiceHandlerFromEndpoint 

func RegisterAgentServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAgentServiceHandlerFromEndpoint is same as RegisterAgentServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAgentServiceHandlerServer 

func RegisterAgentServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AgentServiceServer) error

RegisterAgentServiceHandlerServer registers the http handlers for service AgentService to "mux". UnaryRPC :call AgentServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAgentServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterAgentServiceServer 

func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)

func RegisterClusterServiceHandler 

func RegisterClusterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterClusterServiceHandler registers the http handlers for service ClusterService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterClusterServiceHandlerClient 

func RegisterClusterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClusterServiceClient) error

RegisterClusterServiceHandlerClient registers the http handlers for service ClusterService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ClusterServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ClusterServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ClusterServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterClusterServiceHandlerFromEndpoint 

func RegisterClusterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterClusterServiceHandlerFromEndpoint is same as RegisterClusterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterClusterServiceHandlerServer 

func RegisterClusterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ClusterServiceServer) error

RegisterClusterServiceHandlerServer registers the http handlers for service ClusterService to "mux". UnaryRPC :call ClusterServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterClusterServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

func RegisterHealthServiceHandler 

func RegisterHealthServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterHealthServiceHandler registers the http handlers for service HealthService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterHealthServiceHandlerClient 

func RegisterHealthServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client HealthServiceClient) error

RegisterHealthServiceHandlerClient registers the http handlers for service HealthService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "HealthServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "HealthServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "HealthServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterHealthServiceHandlerFromEndpoint 

func RegisterHealthServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterHealthServiceHandlerFromEndpoint is same as RegisterHealthServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterHealthServiceHandlerServer 

func RegisterHealthServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server HealthServiceServer) error

RegisterHealthServiceHandlerServer registers the http handlers for service HealthService to "mux". UnaryRPC :call HealthServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterHealthServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterHealthServiceServer 

func RegisterHealthServiceServer(s grpc.ServiceRegistrar, srv HealthServiceServer)

Types

type Agent 

type Agent struct {

	// Agent-generated UUID (hardware-based identifier)
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Cluster ID this agent belongs to
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Node hostname
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Node IP address
	IpAddress string `protobuf:"bytes,4,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	// Agent version
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// Agent status
	Status AgentStatus `protobuf:"varint,6,opt,name=status,proto3,enum=netctrl.v1.AgentStatus" json:"status,omitempty"`
	// Last registration or update time
	LastSeen *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	// Creation timestamp
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Last update timestamp
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Mellanox NICs reported by agent (populated via hardware collection instruction)
	NetworkInterfaces []*MellanoxNIC `protobuf:"bytes,10,rep,name=network_interfaces,json=networkInterfaces,proto3" json:"network_interfaces,omitempty"`
	// Whether hardware collection has been completed (true even if no NICs found)
	HardwareCollected bool `protobuf:"varint,11,opt,name=hardware_collected,json=hardwareCollected,proto3" json:"hardware_collected,omitempty"`
	// contains filtered or unexported fields
}

Agent represents a node agent registered to a cluster

func (*Agent) Descriptor deprecated 

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

Deprecated: Use Agent.ProtoReflect.Descriptor instead.

func (*Agent) GetClusterId 

func (x *Agent) GetClusterId() string

func (*Agent) GetCreatedAt 

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

func (*Agent) GetHardwareCollected 

func (x *Agent) GetHardwareCollected() bool

func (*Agent) GetHostname 

func (x *Agent) GetHostname() string

func (*Agent) GetId 

func (x *Agent) GetId() string

func (*Agent) GetIpAddress 

func (x *Agent) GetIpAddress() string

func (*Agent) GetLastSeen 

func (x *Agent) GetLastSeen() *timestamppb.Timestamp

func (*Agent) GetNetworkInterfaces 

func (x *Agent) GetNetworkInterfaces() []*MellanoxNIC

func (*Agent) GetStatus 

func (x *Agent) GetStatus() AgentStatus

func (*Agent) GetUpdatedAt 

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

func (*Agent) GetVersion 

func (x *Agent) GetVersion() string

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) ProtoReflect 

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

func (*Agent) Reset 

func (x *Agent) Reset()

func (*Agent) String 

func (x *Agent) String() string

type AgentServiceClient 

type AgentServiceClient interface {
	// RegisterAgent registers or updates an agent to a cluster
	RegisterAgent(ctx context.Context, in *RegisterAgentRequest, opts ...grpc.CallOption) (*RegisterAgentResponse, error)
	// GetAgent retrieves an agent by ID
	GetAgent(ctx context.Context, in *GetAgentRequest, opts ...grpc.CallOption) (*GetAgentResponse, error)
	// ListAgents lists all agents, optionally filtered by cluster
	ListAgents(ctx context.Context, in *ListAgentsRequest, opts ...grpc.CallOption) (*ListAgentsResponse, error)
	// UnregisterAgent removes an agent
	UnregisterAgent(ctx context.Context, in *UnregisterAgentRequest, opts ...grpc.CallOption) (*UnregisterAgentResponse, error)
	// GetInstructions polls for pending instructions
	// This serves as instruction delivery and implicit healthcheck
	GetInstructions(ctx context.Context, in *GetInstructionsRequest, opts ...grpc.CallOption) (*GetInstructionsResponse, error)
	// SubmitInstructionResult submits the result of a completed instruction
	SubmitInstructionResult(ctx context.Context, in *SubmitInstructionResultRequest, opts ...grpc.CallOption) (*SubmitInstructionResultResponse, error)
}

AgentServiceClient is the client API for AgentService 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.

AgentService provides operations for agent registration and management

func NewAgentServiceClient 

func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient

type AgentServiceServer 

type AgentServiceServer interface {
	// RegisterAgent registers or updates an agent to a cluster
	RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
	// GetAgent retrieves an agent by ID
	GetAgent(context.Context, *GetAgentRequest) (*GetAgentResponse, error)
	// ListAgents lists all agents, optionally filtered by cluster
	ListAgents(context.Context, *ListAgentsRequest) (*ListAgentsResponse, error)
	// UnregisterAgent removes an agent
	UnregisterAgent(context.Context, *UnregisterAgentRequest) (*UnregisterAgentResponse, error)
	// GetInstructions polls for pending instructions
	// This serves as instruction delivery and implicit healthcheck
	GetInstructions(context.Context, *GetInstructionsRequest) (*GetInstructionsResponse, error)
	// SubmitInstructionResult submits the result of a completed instruction
	SubmitInstructionResult(context.Context, *SubmitInstructionResultRequest) (*SubmitInstructionResultResponse, error)
	// contains filtered or unexported methods
}

AgentServiceServer is the server API for AgentService service. All implementations must embed UnimplementedAgentServiceServer for forward compatibility.

AgentService provides operations for agent registration and management

type AgentStatus 

type AgentStatus int32

AgentStatus represents the current state of an agent 

const (
	AgentStatus_AGENT_STATUS_UNSPECIFIED AgentStatus = 0
	AgentStatus_AGENT_STATUS_ACTIVE      AgentStatus = 1
	AgentStatus_AGENT_STATUS_INACTIVE    AgentStatus = 2
)

func (AgentStatus) Descriptor 

func (AgentStatus) Descriptor() protoreflect.EnumDescriptor

func (AgentStatus) Enum 

func (x AgentStatus) Enum() *AgentStatus

func (AgentStatus) EnumDescriptor deprecated 

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

Deprecated: Use AgentStatus.Descriptor instead.

func (AgentStatus) Number 

func (x AgentStatus) Number() protoreflect.EnumNumber

func (AgentStatus) String 

func (x AgentStatus) String() string

func (AgentStatus) Type 

func (AgentStatus) Type() protoreflect.EnumType

type Cluster 

type Cluster struct {

	// Unique identifier for the cluster
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Human-readable name for the cluster
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Optional description of the cluster
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Creation timestamp
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Last update timestamp
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Cluster represents a cluster configuration

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetCreatedAt 

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

func (*Cluster) GetDescription 

func (x *Cluster) GetDescription() string

func (*Cluster) GetId 

func (x *Cluster) GetId() string

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetUpdatedAt 

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

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type ClusterServiceClient 

type ClusterServiceClient interface {
	// CreateCluster creates a new cluster
	CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*CreateClusterResponse, error)
	// GetCluster retrieves a cluster by ID
	GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*GetClusterResponse, error)
	// ListClusters lists all clusters
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// UpdateCluster updates an existing cluster
	UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*UpdateClusterResponse, error)
	// DeleteCluster deletes a cluster by ID
	DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*DeleteClusterResponse, error)
}

ClusterServiceClient is the client API for ClusterService 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.

ClusterService provides CRUD operations for managing clusters

func NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceServer 

type ClusterServiceServer interface {
	// CreateCluster creates a new cluster
	CreateCluster(context.Context, *CreateClusterRequest) (*CreateClusterResponse, error)
	// GetCluster retrieves a cluster by ID
	GetCluster(context.Context, *GetClusterRequest) (*GetClusterResponse, error)
	// ListClusters lists all clusters
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// UpdateCluster updates an existing cluster
	UpdateCluster(context.Context, *UpdateClusterRequest) (*UpdateClusterResponse, error)
	// DeleteCluster deletes a cluster by ID
	DeleteCluster(context.Context, *DeleteClusterRequest) (*DeleteClusterResponse, error)
	// contains filtered or unexported methods
}

ClusterServiceServer is the server API for ClusterService service. All implementations must embed UnimplementedClusterServiceServer for forward compatibility.

ClusterService provides CRUD operations for managing clusters

type CreateClusterRequest 

type CreateClusterRequest struct {

	// Name of the cluster (required)
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the cluster
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

CreateClusterRequest contains parameters for creating a cluster

func (*CreateClusterRequest) Descriptor deprecated 

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

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetDescription 

func (x *CreateClusterRequest) GetDescription() string

func (*CreateClusterRequest) GetName 

func (x *CreateClusterRequest) GetName() string

func (*CreateClusterRequest) ProtoMessage 

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect 

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

func (*CreateClusterRequest) Reset 

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String 

func (x *CreateClusterRequest) String() string

type CreateClusterResponse 

type CreateClusterResponse struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

CreateClusterResponse returns the created cluster

func (*CreateClusterResponse) Descriptor deprecated 

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

Deprecated: Use CreateClusterResponse.ProtoReflect.Descriptor instead.

func (*CreateClusterResponse) GetCluster 

func (x *CreateClusterResponse) GetCluster() *Cluster

func (*CreateClusterResponse) ProtoMessage 

func (*CreateClusterResponse) ProtoMessage()

func (*CreateClusterResponse) ProtoReflect 

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

func (*CreateClusterResponse) Reset 

func (x *CreateClusterResponse) Reset()

func (*CreateClusterResponse) String 

func (x *CreateClusterResponse) String() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {

	// ID of the cluster to delete
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

DeleteClusterRequest contains parameters for deleting a cluster

func (*DeleteClusterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetId 

func (x *DeleteClusterRequest) GetId() string

func (*DeleteClusterRequest) ProtoMessage 

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) ProtoReflect 

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

func (*DeleteClusterRequest) Reset 

func (x *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String 

func (x *DeleteClusterRequest) String() string

type DeleteClusterResponse 

type DeleteClusterResponse struct {

	// Whether the deletion was successful
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

DeleteClusterResponse confirms deletion

func (*DeleteClusterResponse) Descriptor deprecated 

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

Deprecated: Use DeleteClusterResponse.ProtoReflect.Descriptor instead.

func (*DeleteClusterResponse) GetSuccess 

func (x *DeleteClusterResponse) GetSuccess() bool

func (*DeleteClusterResponse) ProtoMessage 

func (*DeleteClusterResponse) ProtoMessage()

func (*DeleteClusterResponse) ProtoReflect 

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

func (*DeleteClusterResponse) Reset 

func (x *DeleteClusterResponse) Reset()

func (*DeleteClusterResponse) String 

func (x *DeleteClusterResponse) String() string

type GetAgentRequest 

type GetAgentRequest struct {

	// ID of the agent to retrieve
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetAgentRequest contains parameters for retrieving an agent

func (*GetAgentRequest) Descriptor deprecated 

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

Deprecated: Use GetAgentRequest.ProtoReflect.Descriptor instead.

func (*GetAgentRequest) GetId 

func (x *GetAgentRequest) GetId() string

func (*GetAgentRequest) ProtoMessage 

func (*GetAgentRequest) ProtoMessage()

func (*GetAgentRequest) ProtoReflect 

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

func (*GetAgentRequest) Reset 

func (x *GetAgentRequest) Reset()

func (*GetAgentRequest) String 

func (x *GetAgentRequest) String() string

type GetAgentResponse 

type GetAgentResponse struct {
	Agent *Agent `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	// contains filtered or unexported fields
}

GetAgentResponse returns the requested agent

func (*GetAgentResponse) Descriptor deprecated 

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

Deprecated: Use GetAgentResponse.ProtoReflect.Descriptor instead.

func (*GetAgentResponse) GetAgent 

func (x *GetAgentResponse) GetAgent() *Agent

func (*GetAgentResponse) ProtoMessage 

func (*GetAgentResponse) ProtoMessage()

func (*GetAgentResponse) ProtoReflect 

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

func (*GetAgentResponse) Reset 

func (x *GetAgentResponse) Reset()

func (*GetAgentResponse) String 

func (x *GetAgentResponse) String() string

type GetClusterRequest 

type GetClusterRequest struct {

	// ID of the cluster to retrieve
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetClusterRequest contains parameters for retrieving a cluster

func (*GetClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.

func (*GetClusterRequest) GetId 

func (x *GetClusterRequest) GetId() string

func (*GetClusterRequest) ProtoMessage 

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) ProtoReflect 

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

func (*GetClusterRequest) Reset 

func (x *GetClusterRequest) Reset()

func (*GetClusterRequest) String 

func (x *GetClusterRequest) String() string

type GetClusterResponse 

type GetClusterResponse struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

GetClusterResponse returns the requested cluster

func (*GetClusterResponse) Descriptor deprecated 

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

Deprecated: Use GetClusterResponse.ProtoReflect.Descriptor instead.

func (*GetClusterResponse) GetCluster 

func (x *GetClusterResponse) GetCluster() *Cluster

func (*GetClusterResponse) ProtoMessage 

func (*GetClusterResponse) ProtoMessage()

func (*GetClusterResponse) ProtoReflect 

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

func (*GetClusterResponse) Reset 

func (x *GetClusterResponse) Reset()

func (*GetClusterResponse) String 

func (x *GetClusterResponse) String() string

type GetInstructionsRequest 

type GetInstructionsRequest struct {

	// ID of the agent requesting instructions
	AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

GetInstructionsRequest requests pending instructions for an agent

func (*GetInstructionsRequest) Descriptor deprecated 

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

Deprecated: Use GetInstructionsRequest.ProtoReflect.Descriptor instead.

func (*GetInstructionsRequest) GetAgentId 

func (x *GetInstructionsRequest) GetAgentId() string

func (*GetInstructionsRequest) ProtoMessage 

func (*GetInstructionsRequest) ProtoMessage()

func (*GetInstructionsRequest) ProtoReflect 

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

func (*GetInstructionsRequest) Reset 

func (x *GetInstructionsRequest) Reset()

func (*GetInstructionsRequest) String 

func (x *GetInstructionsRequest) String() string

type GetInstructionsResponse 

type GetInstructionsResponse struct {

	// List of pending instructions to execute
	Instructions []*Instruction `protobuf:"bytes,1,rep,name=instructions,proto3" json:"instructions,omitempty"`
	// Seconds to wait before the next poll
	// Default behavior: agent should poll after this interval
	PollIntervalSeconds int32 `protobuf:"varint,2,opt,name=poll_interval_seconds,json=pollIntervalSeconds,proto3" json:"poll_interval_seconds,omitempty"`
	// Server timestamp when response was generated
	ServerTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=server_time,json=serverTime,proto3" json:"server_time,omitempty"`
	// contains filtered or unexported fields
}

GetInstructionsResponse returns instructions and polling configuration

func (*GetInstructionsResponse) Descriptor deprecated 

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

Deprecated: Use GetInstructionsResponse.ProtoReflect.Descriptor instead.

func (*GetInstructionsResponse) GetInstructions 

func (x *GetInstructionsResponse) GetInstructions() []*Instruction

func (*GetInstructionsResponse) GetPollIntervalSeconds 

func (x *GetInstructionsResponse) GetPollIntervalSeconds() int32

func (*GetInstructionsResponse) GetServerTime 

func (x *GetInstructionsResponse) GetServerTime() *timestamppb.Timestamp

func (*GetInstructionsResponse) ProtoMessage 

func (*GetInstructionsResponse) ProtoMessage()

func (*GetInstructionsResponse) ProtoReflect 

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

func (*GetInstructionsResponse) Reset 

func (x *GetInstructionsResponse) Reset()

func (*GetInstructionsResponse) String 

func (x *GetInstructionsResponse) String() string

type HardwareCollectionResult 

type HardwareCollectionResult struct {

	// Collected Mellanox NICs
	NetworkInterfaces []*MellanoxNIC `protobuf:"bytes,1,rep,name=network_interfaces,json=networkInterfaces,proto3" json:"network_interfaces,omitempty"`
	// contains filtered or unexported fields
}

HardwareCollectionResult contains the result of hardware collection

func (*HardwareCollectionResult) Descriptor deprecated 

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

Deprecated: Use HardwareCollectionResult.ProtoReflect.Descriptor instead.

func (*HardwareCollectionResult) GetNetworkInterfaces 

func (x *HardwareCollectionResult) GetNetworkInterfaces() []*MellanoxNIC

func (*HardwareCollectionResult) ProtoMessage 

func (*HardwareCollectionResult) ProtoMessage()

func (*HardwareCollectionResult) ProtoReflect 

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

func (*HardwareCollectionResult) Reset 

func (x *HardwareCollectionResult) Reset()

func (*HardwareCollectionResult) String 

func (x *HardwareCollectionResult) String() string

type HealthCheckRequest 

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

HealthCheckRequest is the request for health checks

func (*HealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type HealthCheckResponse 

type HealthCheckResponse struct {

	// Overall health status
	Status HealthStatus `protobuf:"varint,1,opt,name=status,proto3,enum=netctrl.v1.HealthStatus" json:"status,omitempty"`
	// Optional message providing additional context
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

HealthCheckResponse contains health status information

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetMessage 

func (x *HealthCheckResponse) GetMessage() string

func (*HealthCheckResponse) GetStatus 

func (x *HealthCheckResponse) GetStatus() HealthStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type HealthCheckResult 

type HealthCheckResult struct {

	// Health status
	Healthy bool `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
	// Optional error message if unhealthy
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

HealthCheckResult contains the result of a health check

func (*HealthCheckResult) Descriptor deprecated 

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

Deprecated: Use HealthCheckResult.ProtoReflect.Descriptor instead.

func (*HealthCheckResult) GetErrorMessage 

func (x *HealthCheckResult) GetErrorMessage() string

func (*HealthCheckResult) GetHealthy 

func (x *HealthCheckResult) GetHealthy() bool

func (*HealthCheckResult) ProtoMessage 

func (*HealthCheckResult) ProtoMessage()

func (*HealthCheckResult) ProtoReflect 

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

func (*HealthCheckResult) Reset 

func (x *HealthCheckResult) Reset()

func (*HealthCheckResult) String 

func (x *HealthCheckResult) String() string

type HealthServiceClient 

type HealthServiceClient interface {
	// Check returns the health status of the service
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// Ready returns the readiness status of the service
	Ready(ctx context.Context, in *ReadinessCheckRequest, opts ...grpc.CallOption) (*ReadinessCheckResponse, error)
}

HealthServiceClient is the client API for HealthService 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.

HealthService provides health check endpoints

func NewHealthServiceClient 

func NewHealthServiceClient(cc grpc.ClientConnInterface) HealthServiceClient

type HealthServiceServer 

type HealthServiceServer interface {
	// Check returns the health status of the service
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// Ready returns the readiness status of the service
	Ready(context.Context, *ReadinessCheckRequest) (*ReadinessCheckResponse, error)
	// contains filtered or unexported methods
}

HealthServiceServer is the server API for HealthService service. All implementations must embed UnimplementedHealthServiceServer for forward compatibility.

HealthService provides health check endpoints

type HealthStatus 

type HealthStatus int32

HealthStatus represents the health state of the service 

const (
	HealthStatus_HEALTH_STATUS_UNSPECIFIED HealthStatus = 0
	HealthStatus_HEALTH_STATUS_HEALTHY     HealthStatus = 1
	HealthStatus_HEALTH_STATUS_UNHEALTHY   HealthStatus = 2
)

func (HealthStatus) Descriptor 

func (HealthStatus) Descriptor() protoreflect.EnumDescriptor

func (HealthStatus) Enum 

func (x HealthStatus) Enum() *HealthStatus

func (HealthStatus) EnumDescriptor deprecated 

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

Deprecated: Use HealthStatus.Descriptor instead.

func (HealthStatus) Number 

func (x HealthStatus) Number() protoreflect.EnumNumber

func (HealthStatus) String 

func (x HealthStatus) String() string

func (HealthStatus) Type 

func (HealthStatus) Type() protoreflect.EnumType

type Instruction 

type Instruction struct {

	// Unique instruction ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Type of instruction
	Type InstructionType `protobuf:"varint,2,opt,name=type,proto3,enum=netctrl.v1.InstructionType" json:"type,omitempty"`
	// Instruction payload (type-specific data as JSON)
	Payload string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// When the instruction was created
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

Instruction represents a command or directive from the service to an agent

func (*Instruction) Descriptor deprecated 

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

Deprecated: Use Instruction.ProtoReflect.Descriptor instead.

func (*Instruction) GetCreatedAt 

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

func (*Instruction) GetId 

func (x *Instruction) GetId() string

func (*Instruction) GetPayload 

func (x *Instruction) GetPayload() string

func (*Instruction) GetType 

func (x *Instruction) GetType() InstructionType

func (*Instruction) ProtoMessage 

func (*Instruction) ProtoMessage()

func (*Instruction) ProtoReflect 

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

func (*Instruction) Reset 

func (x *Instruction) Reset()

func (*Instruction) String 

func (x *Instruction) String() string

type InstructionResult 

type InstructionResult struct {

	// Type of instruction that was executed
	InstructionType InstructionType `` /* 139-byte string literal not displayed */
	// Type-specific result data
	//
	// Types that are valid to be assigned to Result:
	//
	//	*InstructionResult_HardwareCollection
	//	*InstructionResult_HealthCheck
	Result isInstructionResult_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

InstructionResult represents the result of executing an instruction

func (*InstructionResult) Descriptor deprecated 

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

Deprecated: Use InstructionResult.ProtoReflect.Descriptor instead.

func (*InstructionResult) GetHardwareCollection 

func (x *InstructionResult) GetHardwareCollection() *HardwareCollectionResult

func (*InstructionResult) GetHealthCheck 

func (x *InstructionResult) GetHealthCheck() *HealthCheckResult

func (*InstructionResult) GetInstructionType 

func (x *InstructionResult) GetInstructionType() InstructionType

func (*InstructionResult) GetResult 

func (x *InstructionResult) GetResult() isInstructionResult_Result

func (*InstructionResult) ProtoMessage 

func (*InstructionResult) ProtoMessage()

func (*InstructionResult) ProtoReflect 

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

func (*InstructionResult) Reset 

func (x *InstructionResult) Reset()

func (*InstructionResult) String 

func (x *InstructionResult) String() string

type InstructionResult_HardwareCollection 

type InstructionResult_HardwareCollection struct {
	HardwareCollection *HardwareCollectionResult `protobuf:"bytes,2,opt,name=hardware_collection,json=hardwareCollection,proto3,oneof"`
}

type InstructionResult_HealthCheck 

type InstructionResult_HealthCheck struct {
	HealthCheck *HealthCheckResult `protobuf:"bytes,3,opt,name=health_check,json=healthCheck,proto3,oneof"` // Future result types can be added here
}

type InstructionType 

type InstructionType int32

InstructionType defines the type of instruction 

const (
	InstructionType_INSTRUCTION_TYPE_UNSPECIFIED InstructionType = 0
	// POLL_INTERVAL instructs the agent when to poll next
	InstructionType_INSTRUCTION_TYPE_POLL_INTERVAL InstructionType = 1
	// HEALTH_CHECK requests a health status report
	InstructionType_INSTRUCTION_TYPE_HEALTH_CHECK InstructionType = 2
	// COLLECT_HARDWARE requests hardware inventory (Mellanox NICs)
	InstructionType_INSTRUCTION_TYPE_COLLECT_HARDWARE InstructionType = 3
)

func (InstructionType) Descriptor 

func (InstructionType) Descriptor() protoreflect.EnumDescriptor

func (InstructionType) Enum 

func (x InstructionType) Enum() *InstructionType

func (InstructionType) EnumDescriptor deprecated 

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

Deprecated: Use InstructionType.Descriptor instead.

func (InstructionType) Number 

func (x InstructionType) Number() protoreflect.EnumNumber

func (InstructionType) String 

func (x InstructionType) String() string

func (InstructionType) Type 

func (InstructionType) Type() protoreflect.EnumType

type ListAgentsRequest 

type ListAgentsRequest struct {

	// Optional cluster ID filter
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

ListAgentsRequest contains parameters for listing agents

func (*ListAgentsRequest) Descriptor deprecated 

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

Deprecated: Use ListAgentsRequest.ProtoReflect.Descriptor instead.

func (*ListAgentsRequest) GetClusterId 

func (x *ListAgentsRequest) GetClusterId() string

func (*ListAgentsRequest) ProtoMessage 

func (*ListAgentsRequest) ProtoMessage()

func (*ListAgentsRequest) ProtoReflect 

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

func (*ListAgentsRequest) Reset 

func (x *ListAgentsRequest) Reset()

func (*ListAgentsRequest) String 

func (x *ListAgentsRequest) String() string

type ListAgentsResponse 

type ListAgentsResponse struct {
	Agents []*Agent `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

ListAgentsResponse returns a list of agents

func (*ListAgentsResponse) Descriptor deprecated 

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

Deprecated: Use ListAgentsResponse.ProtoReflect.Descriptor instead.

func (*ListAgentsResponse) GetAgents 

func (x *ListAgentsResponse) GetAgents() []*Agent

func (*ListAgentsResponse) ProtoMessage 

func (*ListAgentsResponse) ProtoMessage()

func (*ListAgentsResponse) ProtoReflect 

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

func (*ListAgentsResponse) Reset 

func (x *ListAgentsResponse) Reset()

func (*ListAgentsResponse) String 

func (x *ListAgentsResponse) String() string

type ListClustersRequest 

type ListClustersRequest struct {

	// Optional page size for pagination (future enhancement)
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional page token for pagination (future enhancement)
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

ListClustersRequest contains parameters for listing clusters

func (*ListClustersRequest) Descriptor deprecated 

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) GetPageSize 

func (x *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) GetPageToken 

func (x *ListClustersRequest) GetPageToken() string

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect 

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

func (*ListClustersRequest) Reset 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

type ListClustersResponse 

type ListClustersResponse struct {

	// List of clusters
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// Next page token for pagination (future enhancement)
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

ListClustersResponse returns a list of clusters

func (*ListClustersResponse) Descriptor deprecated 

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetClusters 

func (x *ListClustersResponse) GetClusters() []*Cluster

func (*ListClustersResponse) GetNextPageToken 

func (x *ListClustersResponse) GetNextPageToken() string

func (*ListClustersResponse) ProtoMessage 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect 

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

func (*ListClustersResponse) Reset 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) String 

func (x *ListClustersResponse) String() string

type MellanoxNIC 

type MellanoxNIC struct {

	// Device name (e.g., "mlx5_0")
	DeviceName string `protobuf:"bytes,1,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`
	// PCI address (e.g., "0000:03:00.0")
	PciAddress string `protobuf:"bytes,2,opt,name=pci_address,json=pciAddress,proto3" json:"pci_address,omitempty"`
	// Part number / model
	PartNumber string `protobuf:"bytes,3,opt,name=part_number,json=partNumber,proto3" json:"part_number,omitempty"`
	// Serial number
	SerialNumber string `protobuf:"bytes,4,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
	// Firmware version
	FirmwareVersion string `protobuf:"bytes,5,opt,name=firmware_version,json=firmwareVersion,proto3" json:"firmware_version,omitempty"`
	// Number of ports on this NIC
	PortCount int32 `protobuf:"varint,6,opt,name=port_count,json=portCount,proto3" json:"port_count,omitempty"`
	// Port details
	Ports []*MellanoxPort `protobuf:"bytes,7,rep,name=ports,proto3" json:"ports,omitempty"`
	// PSID (Parameter Set ID)
	Psid string `protobuf:"bytes,8,opt,name=psid,proto3" json:"psid,omitempty"`
	// contains filtered or unexported fields
}

MellanoxNIC represents a Mellanox network interface card

func (*MellanoxNIC) Descriptor deprecated 

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

Deprecated: Use MellanoxNIC.ProtoReflect.Descriptor instead.

func (*MellanoxNIC) GetDeviceName 

func (x *MellanoxNIC) GetDeviceName() string

func (*MellanoxNIC) GetFirmwareVersion 

func (x *MellanoxNIC) GetFirmwareVersion() string

func (*MellanoxNIC) GetPartNumber 

func (x *MellanoxNIC) GetPartNumber() string

func (*MellanoxNIC) GetPciAddress 

func (x *MellanoxNIC) GetPciAddress() string

func (*MellanoxNIC) GetPortCount 

func (x *MellanoxNIC) GetPortCount() int32

func (*MellanoxNIC) GetPorts 

func (x *MellanoxNIC) GetPorts() []*MellanoxPort

func (*MellanoxNIC) GetPsid 

func (x *MellanoxNIC) GetPsid() string

func (*MellanoxNIC) GetSerialNumber 

func (x *MellanoxNIC) GetSerialNumber() string

func (*MellanoxNIC) ProtoMessage 

func (*MellanoxNIC) ProtoMessage()

func (*MellanoxNIC) ProtoReflect 

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

func (*MellanoxNIC) Reset 

func (x *MellanoxNIC) Reset()

func (*MellanoxNIC) String 

func (x *MellanoxNIC) String() string

type MellanoxPort 

type MellanoxPort struct {

	// Port number (1-based)
	Number int32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// Port state (up/down)
	State PortState `protobuf:"varint,2,opt,name=state,proto3,enum=netctrl.v1.PortState" json:"state,omitempty"`
	// Link speed in Gbps
	Speed PortSpeed `protobuf:"varint,3,opt,name=speed,proto3,enum=netctrl.v1.PortSpeed" json:"speed,omitempty"`
	// MAC address
	MacAddress string `protobuf:"bytes,4,opt,name=mac_address,json=macAddress,proto3" json:"mac_address,omitempty"`
	// MTU size
	Mtu int32 `protobuf:"varint,5,opt,name=mtu,proto3" json:"mtu,omitempty"`
	// Port GUID
	Guid string `protobuf:"bytes,6,opt,name=guid,proto3" json:"guid,omitempty"`
	// PCI address for this port (e.g., "0000:03:00.1")
	PciAddress string `protobuf:"bytes,7,opt,name=pci_address,json=pciAddress,proto3" json:"pci_address,omitempty"`
	// Network interface name (e.g., "ens1f0")
	InterfaceName string `protobuf:"bytes,8,opt,name=interface_name,json=interfaceName,proto3" json:"interface_name,omitempty"`
	// contains filtered or unexported fields
}

MellanoxPort represents a single port on a Mellanox NIC

func (*MellanoxPort) Descriptor deprecated 

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

Deprecated: Use MellanoxPort.ProtoReflect.Descriptor instead.

func (*MellanoxPort) GetGuid 

func (x *MellanoxPort) GetGuid() string

func (*MellanoxPort) GetInterfaceName 

func (x *MellanoxPort) GetInterfaceName() string

func (*MellanoxPort) GetMacAddress 

func (x *MellanoxPort) GetMacAddress() string

func (*MellanoxPort) GetMtu 

func (x *MellanoxPort) GetMtu() int32

func (*MellanoxPort) GetNumber 

func (x *MellanoxPort) GetNumber() int32

func (*MellanoxPort) GetPciAddress 

func (x *MellanoxPort) GetPciAddress() string

func (*MellanoxPort) GetSpeed 

func (x *MellanoxPort) GetSpeed() PortSpeed

func (*MellanoxPort) GetState 

func (x *MellanoxPort) GetState() PortState

func (*MellanoxPort) ProtoMessage 

func (*MellanoxPort) ProtoMessage()

func (*MellanoxPort) ProtoReflect 

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

func (*MellanoxPort) Reset 

func (x *MellanoxPort) Reset()

func (*MellanoxPort) String 

func (x *MellanoxPort) String() string

type PortSpeed 

type PortSpeed int32

PortSpeed represents the link speed of a port 

const (
	PortSpeed_PORT_SPEED_UNSPECIFIED PortSpeed = 0
	PortSpeed_PORT_SPEED_1G          PortSpeed = 1
	PortSpeed_PORT_SPEED_10G         PortSpeed = 10
	PortSpeed_PORT_SPEED_25G         PortSpeed = 25
	PortSpeed_PORT_SPEED_40G         PortSpeed = 40
	PortSpeed_PORT_SPEED_50G         PortSpeed = 50
	PortSpeed_PORT_SPEED_100G        PortSpeed = 100
	PortSpeed_PORT_SPEED_200G        PortSpeed = 200
	PortSpeed_PORT_SPEED_400G        PortSpeed = 400
)

func (PortSpeed) Descriptor 

func (PortSpeed) Descriptor() protoreflect.EnumDescriptor

func (PortSpeed) Enum 

func (x PortSpeed) Enum() *PortSpeed

func (PortSpeed) EnumDescriptor deprecated 

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

Deprecated: Use PortSpeed.Descriptor instead.

func (PortSpeed) Number 

func (x PortSpeed) Number() protoreflect.EnumNumber

func (PortSpeed) String 

func (x PortSpeed) String() string

func (PortSpeed) Type 

func (PortSpeed) Type() protoreflect.EnumType

type PortState 

type PortState int32

PortState represents the operational state of a NIC port 

const (
	PortState_PORT_STATE_UNSPECIFIED PortState = 0
	PortState_PORT_STATE_DOWN        PortState = 1
	PortState_PORT_STATE_UP          PortState = 2
	PortState_PORT_STATE_TESTING     PortState = 3
)

func (PortState) Descriptor 

func (PortState) Descriptor() protoreflect.EnumDescriptor

func (PortState) Enum 

func (x PortState) Enum() *PortState

func (PortState) EnumDescriptor deprecated 

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

Deprecated: Use PortState.Descriptor instead.

func (PortState) Number 

func (x PortState) Number() protoreflect.EnumNumber

func (PortState) String 

func (x PortState) String() string

func (PortState) Type 

func (PortState) Type() protoreflect.EnumType

type ReadinessCheckRequest 

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

ReadinessCheckRequest is the request for readiness checks

func (*ReadinessCheckRequest) Descriptor deprecated 

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

Deprecated: Use ReadinessCheckRequest.ProtoReflect.Descriptor instead.

func (*ReadinessCheckRequest) ProtoMessage 

func (*ReadinessCheckRequest) ProtoMessage()

func (*ReadinessCheckRequest) ProtoReflect 

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

func (*ReadinessCheckRequest) Reset 

func (x *ReadinessCheckRequest) Reset()

func (*ReadinessCheckRequest) String 

func (x *ReadinessCheckRequest) String() string

type ReadinessCheckResponse 

type ReadinessCheckResponse struct {

	// Overall readiness status
	Status ReadinessStatus `protobuf:"varint,1,opt,name=status,proto3,enum=netctrl.v1.ReadinessStatus" json:"status,omitempty"`
	// Optional message providing additional context
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

ReadinessCheckResponse contains readiness status information

func (*ReadinessCheckResponse) Descriptor deprecated 

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

Deprecated: Use ReadinessCheckResponse.ProtoReflect.Descriptor instead.

func (*ReadinessCheckResponse) GetMessage 

func (x *ReadinessCheckResponse) GetMessage() string

func (*ReadinessCheckResponse) GetStatus 

func (x *ReadinessCheckResponse) GetStatus() ReadinessStatus

func (*ReadinessCheckResponse) ProtoMessage 

func (*ReadinessCheckResponse) ProtoMessage()

func (*ReadinessCheckResponse) ProtoReflect 

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

func (*ReadinessCheckResponse) Reset 

func (x *ReadinessCheckResponse) Reset()

func (*ReadinessCheckResponse) String 

func (x *ReadinessCheckResponse) String() string

type ReadinessStatus 

type ReadinessStatus int32

ReadinessStatus represents the readiness state of the service 

const (
	ReadinessStatus_READINESS_STATUS_UNSPECIFIED ReadinessStatus = 0
	ReadinessStatus_READINESS_STATUS_READY       ReadinessStatus = 1
	ReadinessStatus_READINESS_STATUS_NOT_READY   ReadinessStatus = 2
)

func (ReadinessStatus) Descriptor 

func (ReadinessStatus) Descriptor() protoreflect.EnumDescriptor

func (ReadinessStatus) Enum 

func (x ReadinessStatus) Enum() *ReadinessStatus

func (ReadinessStatus) EnumDescriptor deprecated 

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

Deprecated: Use ReadinessStatus.Descriptor instead.

func (ReadinessStatus) Number 

func (x ReadinessStatus) Number() protoreflect.EnumNumber

func (ReadinessStatus) String 

func (x ReadinessStatus) String() string

func (ReadinessStatus) Type 

func (ReadinessStatus) Type() protoreflect.EnumType

type RegisterAgentRequest 

type RegisterAgentRequest struct {

	// Agent-generated UUID (required)
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Cluster ID (required)
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Node hostname (optional)
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Node IP address (optional)
	IpAddress string `protobuf:"bytes,4,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	// Agent version (optional)
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

RegisterAgentRequest contains parameters for registering an agent

func (*RegisterAgentRequest) Descriptor deprecated 

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

Deprecated: Use RegisterAgentRequest.ProtoReflect.Descriptor instead.

func (*RegisterAgentRequest) GetClusterId 

func (x *RegisterAgentRequest) GetClusterId() string

func (*RegisterAgentRequest) GetHostname 

func (x *RegisterAgentRequest) GetHostname() string

func (*RegisterAgentRequest) GetId 

func (x *RegisterAgentRequest) GetId() string

func (*RegisterAgentRequest) GetIpAddress 

func (x *RegisterAgentRequest) GetIpAddress() string

func (*RegisterAgentRequest) GetVersion 

func (x *RegisterAgentRequest) GetVersion() string

func (*RegisterAgentRequest) ProtoMessage 

func (*RegisterAgentRequest) ProtoMessage()

func (*RegisterAgentRequest) ProtoReflect 

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

func (*RegisterAgentRequest) Reset 

func (x *RegisterAgentRequest) Reset()

func (*RegisterAgentRequest) String 

func (x *RegisterAgentRequest) String() string

type RegisterAgentResponse 

type RegisterAgentResponse struct {
	Agent *Agent `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	// contains filtered or unexported fields
}

RegisterAgentResponse returns the registered agent

func (*RegisterAgentResponse) Descriptor deprecated 

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

Deprecated: Use RegisterAgentResponse.ProtoReflect.Descriptor instead.

func (*RegisterAgentResponse) GetAgent 

func (x *RegisterAgentResponse) GetAgent() *Agent

func (*RegisterAgentResponse) ProtoMessage 

func (*RegisterAgentResponse) ProtoMessage()

func (*RegisterAgentResponse) ProtoReflect 

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

func (*RegisterAgentResponse) Reset 

func (x *RegisterAgentResponse) Reset()

func (*RegisterAgentResponse) String 

func (x *RegisterAgentResponse) String() string

type SubmitInstructionResultRequest 

type SubmitInstructionResultRequest struct {

	// ID of the agent submitting the result
	AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// ID of the instruction that was executed
	InstructionId string `protobuf:"bytes,2,opt,name=instruction_id,json=instructionId,proto3" json:"instruction_id,omitempty"`
	// Result of the instruction execution
	Result *InstructionResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

SubmitInstructionResultRequest submits the result of an instruction

func (*SubmitInstructionResultRequest) Descriptor deprecated 

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

Deprecated: Use SubmitInstructionResultRequest.ProtoReflect.Descriptor instead.

func (*SubmitInstructionResultRequest) GetAgentId 

func (x *SubmitInstructionResultRequest) GetAgentId() string

func (*SubmitInstructionResultRequest) GetInstructionId 

func (x *SubmitInstructionResultRequest) GetInstructionId() string

func (*SubmitInstructionResultRequest) GetResult 

func (x *SubmitInstructionResultRequest) GetResult() *InstructionResult

func (*SubmitInstructionResultRequest) ProtoMessage 

func (*SubmitInstructionResultRequest) ProtoMessage()

func (*SubmitInstructionResultRequest) ProtoReflect 

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

func (*SubmitInstructionResultRequest) Reset 

func (x *SubmitInstructionResultRequest) Reset()

func (*SubmitInstructionResultRequest) String 

func (x *SubmitInstructionResultRequest) String() string

type SubmitInstructionResultResponse 

type SubmitInstructionResultResponse struct {

	// Whether the result was successfully processed
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Optional message (error details or acknowledgment)
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

SubmitInstructionResultResponse confirms receipt of the instruction result

func (*SubmitInstructionResultResponse) Descriptor deprecated 

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

Deprecated: Use SubmitInstructionResultResponse.ProtoReflect.Descriptor instead.

func (*SubmitInstructionResultResponse) GetMessage 

func (x *SubmitInstructionResultResponse) GetMessage() string

func (*SubmitInstructionResultResponse) GetSuccess 

func (x *SubmitInstructionResultResponse) GetSuccess() bool

func (*SubmitInstructionResultResponse) ProtoMessage 

func (*SubmitInstructionResultResponse) ProtoMessage()

func (*SubmitInstructionResultResponse) ProtoReflect 

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

func (*SubmitInstructionResultResponse) Reset 

func (x *SubmitInstructionResultResponse) Reset()

func (*SubmitInstructionResultResponse) String 

func (x *SubmitInstructionResultResponse) String() string

type UnimplementedAgentServiceServer 

type UnimplementedAgentServiceServer struct{}

UnimplementedAgentServiceServer 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 (UnimplementedAgentServiceServer) GetAgent 

func (UnimplementedAgentServiceServer) GetAgent(context.Context, *GetAgentRequest) (*GetAgentResponse, error)

func (UnimplementedAgentServiceServer) GetInstructions 

func (UnimplementedAgentServiceServer) GetInstructions(context.Context, *GetInstructionsRequest) (*GetInstructionsResponse, error)

func (UnimplementedAgentServiceServer) ListAgents 

func (UnimplementedAgentServiceServer) ListAgents(context.Context, *ListAgentsRequest) (*ListAgentsResponse, error)

func (UnimplementedAgentServiceServer) RegisterAgent 

func (UnimplementedAgentServiceServer) RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)

func (UnimplementedAgentServiceServer) SubmitInstructionResult 

func (UnimplementedAgentServiceServer) SubmitInstructionResult(context.Context, *SubmitInstructionResultRequest) (*SubmitInstructionResultResponse, error)

func (UnimplementedAgentServiceServer) UnregisterAgent 

func (UnimplementedAgentServiceServer) UnregisterAgent(context.Context, *UnregisterAgentRequest) (*UnregisterAgentResponse, error)

type UnimplementedClusterServiceServer 

type UnimplementedClusterServiceServer struct{}

UnimplementedClusterServiceServer 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 (UnimplementedClusterServiceServer) CreateCluster 

func (UnimplementedClusterServiceServer) CreateCluster(context.Context, *CreateClusterRequest) (*CreateClusterResponse, error)

func (UnimplementedClusterServiceServer) DeleteCluster 

func (UnimplementedClusterServiceServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*DeleteClusterResponse, error)

func (UnimplementedClusterServiceServer) GetCluster 

func (UnimplementedClusterServiceServer) GetCluster(context.Context, *GetClusterRequest) (*GetClusterResponse, error)

func (UnimplementedClusterServiceServer) ListClusters 

func (UnimplementedClusterServiceServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

func (UnimplementedClusterServiceServer) UpdateCluster 

func (UnimplementedClusterServiceServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*UpdateClusterResponse, error)

type UnimplementedHealthServiceServer 

type UnimplementedHealthServiceServer struct{}

UnimplementedHealthServiceServer 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 (UnimplementedHealthServiceServer) Check 

func (UnimplementedHealthServiceServer) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

func (UnimplementedHealthServiceServer) Ready 

func (UnimplementedHealthServiceServer) Ready(context.Context, *ReadinessCheckRequest) (*ReadinessCheckResponse, error)

type UnregisterAgentRequest 

type UnregisterAgentRequest struct {

	// ID of the agent to unregister
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

UnregisterAgentRequest contains parameters for unregistering an agent

func (*UnregisterAgentRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterAgentRequest.ProtoReflect.Descriptor instead.

func (*UnregisterAgentRequest) GetId 

func (x *UnregisterAgentRequest) GetId() string

func (*UnregisterAgentRequest) ProtoMessage 

func (*UnregisterAgentRequest) ProtoMessage()

func (*UnregisterAgentRequest) ProtoReflect 

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

func (*UnregisterAgentRequest) Reset 

func (x *UnregisterAgentRequest) Reset()

func (*UnregisterAgentRequest) String 

func (x *UnregisterAgentRequest) String() string

type UnregisterAgentResponse 

type UnregisterAgentResponse struct {

	// Whether the unregistration was successful
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

UnregisterAgentResponse confirms unregistration

func (*UnregisterAgentResponse) Descriptor deprecated 

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

Deprecated: Use UnregisterAgentResponse.ProtoReflect.Descriptor instead.

func (*UnregisterAgentResponse) GetSuccess 

func (x *UnregisterAgentResponse) GetSuccess() bool

func (*UnregisterAgentResponse) ProtoMessage 

func (*UnregisterAgentResponse) ProtoMessage()

func (*UnregisterAgentResponse) ProtoReflect 

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

func (*UnregisterAgentResponse) Reset 

func (x *UnregisterAgentResponse) Reset()

func (*UnregisterAgentResponse) String 

func (x *UnregisterAgentResponse) String() string

type UnsafeAgentServiceServer 

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

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

type UnsafeClusterServiceServer 

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

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

type UnsafeHealthServiceServer 

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

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

type UpdateClusterRequest 

type UpdateClusterRequest struct {

	// ID of the cluster to update
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the cluster
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the cluster
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Field mask to specify which fields to update
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,4,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateClusterRequest contains parameters for updating a cluster

func (*UpdateClusterRequest) Descriptor deprecated 

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

Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterRequest) GetDescription 

func (x *UpdateClusterRequest) GetDescription() string

func (*UpdateClusterRequest) GetId 

func (x *UpdateClusterRequest) GetId() string

func (*UpdateClusterRequest) GetName 

func (x *UpdateClusterRequest) GetName() string

func (*UpdateClusterRequest) GetUpdateMask 

func (x *UpdateClusterRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateClusterRequest) ProtoMessage 

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) ProtoReflect 

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

func (*UpdateClusterRequest) Reset 

func (x *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) String 

func (x *UpdateClusterRequest) String() string

type UpdateClusterResponse 

type UpdateClusterResponse struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

UpdateClusterResponse returns the updated cluster

func (*UpdateClusterResponse) Descriptor deprecated 

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

Deprecated: Use UpdateClusterResponse.ProtoReflect.Descriptor instead.

func (*UpdateClusterResponse) GetCluster 

func (x *UpdateClusterResponse) GetCluster() *Cluster

func (*UpdateClusterResponse) ProtoMessage 

func (*UpdateClusterResponse) ProtoMessage()

func (*UpdateClusterResponse) ProtoReflect 

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

func (*UpdateClusterResponse) Reset 

func (x *UpdateClusterResponse) Reset()

func (*UpdateClusterResponse) String 

func (x *UpdateClusterResponse) 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.