api

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server 

type Server struct {
	proto.UnimplementedWarrenAPIServer
	// contains filtered or unexported fields
}

Server implements the WarrenAPI gRPC service

func NewServer 

func NewServer(mgr *manager.Manager) (*Server, error)

NewServer creates a new API server with mTLS

func (*Server) CreateIngress 

func (s *Server) CreateIngress(ctx context.Context, req *proto.CreateIngressRequest) (*proto.CreateIngressResponse, error)

CreateIngress creates a new ingress

func (*Server) CreateSecret 

func (s *Server) CreateSecret(ctx context.Context, req *proto.CreateSecretRequest) (*proto.CreateSecretResponse, error)

CreateSecret creates a new secret

func (*Server) CreateService 

func (s *Server) CreateService(ctx context.Context, req *proto.CreateServiceRequest) (*proto.CreateServiceResponse, error)

CreateService creates a new service

func (*Server) CreateTLSCertificate 

func (s *Server) CreateTLSCertificate(ctx context.Context, req *proto.CreateTLSCertificateRequest) (*proto.CreateTLSCertificateResponse, error)

CreateTLSCertificate creates a new TLS certificate

func (*Server) CreateVolume 

func (s *Server) CreateVolume(ctx context.Context, req *proto.CreateVolumeRequest) (*proto.CreateVolumeResponse, error)

CreateVolume creates a new volume

func (*Server) DeleteIngress 

func (s *Server) DeleteIngress(ctx context.Context, req *proto.DeleteIngressRequest) (*proto.DeleteIngressResponse, error)

DeleteIngress deletes an ingress

func (*Server) DeleteSecret 

func (s *Server) DeleteSecret(ctx context.Context, req *proto.DeleteSecretRequest) (*proto.DeleteSecretResponse, error)

DeleteSecret deletes a secret

func (*Server) DeleteService 

func (s *Server) DeleteService(ctx context.Context, req *proto.DeleteServiceRequest) (*proto.DeleteServiceResponse, error)

DeleteService deletes a service

func (*Server) DeleteTLSCertificate 

func (s *Server) DeleteTLSCertificate(ctx context.Context, req *proto.DeleteTLSCertificateRequest) (*proto.DeleteTLSCertificateResponse, error)

DeleteTLSCertificate deletes a TLS certificate

func (*Server) DeleteVolume 

func (s *Server) DeleteVolume(ctx context.Context, req *proto.DeleteVolumeRequest) (*proto.DeleteVolumeResponse, error)

DeleteVolume deletes a volume

func (*Server) GenerateJoinToken 

func (s *Server) GenerateJoinToken(ctx context.Context, req *proto.GenerateJoinTokenRequest) (*proto.GenerateJoinTokenResponse, error)

GenerateJoinToken generates a join token for adding nodes

func (*Server) GetClusterInfo 

func (s *Server) GetClusterInfo(ctx context.Context, req *proto.GetClusterInfoRequest) (*proto.GetClusterInfoResponse, error)

GetClusterInfo returns information about the Raft cluster

func (*Server) GetIngress 

func (s *Server) GetIngress(ctx context.Context, req *proto.GetIngressRequest) (*proto.GetIngressResponse, error)

GetIngress retrieves an ingress

func (*Server) GetNode 

func (s *Server) GetNode(ctx context.Context, req *proto.GetNodeRequest) (*proto.GetNodeResponse, error)

GetNode returns a specific node by ID

func (*Server) GetSecretByName 

func (s *Server) GetSecretByName(ctx context.Context, req *proto.GetSecretByNameRequest) (*proto.GetSecretByNameResponse, error)

GetSecretByName retrieves a secret by name (includes encrypted data for workers)

func (*Server) GetService 

func (s *Server) GetService(ctx context.Context, req *proto.GetServiceRequest) (*proto.GetServiceResponse, error)

GetService returns a specific service

func (*Server) GetTLSCertificate 

func (s *Server) GetTLSCertificate(ctx context.Context, req *proto.GetTLSCertificateRequest) (*proto.GetTLSCertificateResponse, error)

GetTLSCertificate retrieves a TLS certificate

func (*Server) GetTask 

func (s *Server) GetTask(ctx context.Context, req *proto.GetTaskRequest) (*proto.GetTaskResponse, error)

GetTask returns a specific task

func (*Server) GetVolumeByName 

func (s *Server) GetVolumeByName(ctx context.Context, req *proto.GetVolumeByNameRequest) (*proto.GetVolumeByNameResponse, error)

GetVolumeByName retrieves a volume by name

func (*Server) Heartbeat 

func (s *Server) Heartbeat(ctx context.Context, req *proto.HeartbeatRequest) (*proto.HeartbeatResponse, error)

Heartbeat processes heartbeat from a worker node

func (*Server) JoinCluster 

func (s *Server) JoinCluster(ctx context.Context, req *proto.JoinClusterRequest) (*proto.JoinClusterResponse, error)

JoinCluster handles a manager join request

func (*Server) ListIngresses 

func (s *Server) ListIngresses(ctx context.Context, req *proto.ListIngressesRequest) (*proto.ListIngressesResponse, error)

ListIngresses lists all ingresses

func (*Server) ListNodes 

func (s *Server) ListNodes(ctx context.Context, req *proto.ListNodesRequest) (*proto.ListNodesResponse, error)

ListNodes returns all nodes in the cluster

func (*Server) ListSecrets 

func (s *Server) ListSecrets(ctx context.Context, req *proto.ListSecretsRequest) (*proto.ListSecretsResponse, error)

ListSecrets returns all secrets (without data)

func (*Server) ListServices 

func (s *Server) ListServices(ctx context.Context, req *proto.ListServicesRequest) (*proto.ListServicesResponse, error)

ListServices returns all services

func (*Server) ListTLSCertificates 

func (s *Server) ListTLSCertificates(ctx context.Context, req *proto.ListTLSCertificatesRequest) (*proto.ListTLSCertificatesResponse, error)

ListTLSCertificates lists all TLS certificates

func (*Server) ListTasks 

func (s *Server) ListTasks(ctx context.Context, req *proto.ListTasksRequest) (*proto.ListTasksResponse, error)

ListTasks returns tasks, optionally filtered by service or node

func (*Server) ListVolumes 

func (s *Server) ListVolumes(ctx context.Context, req *proto.ListVolumesRequest) (*proto.ListVolumesResponse, error)

ListVolumes returns all volumes

func (*Server) RegisterNode 

func (s *Server) RegisterNode(ctx context.Context, req *proto.RegisterNodeRequest) (*proto.RegisterNodeResponse, error)

RegisterNode registers a new node (worker or manager) with the cluster

func (*Server) RemoveNode 

func (s *Server) RemoveNode(ctx context.Context, req *proto.RemoveNodeRequest) (*proto.RemoveNodeResponse, error)

RemoveNode removes a node from the cluster

func (*Server) ReportTaskHealth 

func (s *Server) ReportTaskHealth(ctx context.Context, req *proto.ReportTaskHealthRequest) (*proto.ReportTaskHealthResponse, error)

ReportTaskHealth reports the health status of a task

func (*Server) RequestCertificate 

func (s *Server) RequestCertificate(ctx context.Context, req *proto.RequestCertificateRequest) (*proto.RequestCertificateResponse, error)

RequestCertificate issues a certificate for a node joining the cluster

func (*Server) Start 

func (s *Server) Start(addr string) error

Start starts the gRPC server

func (*Server) Stop 

func (s *Server) Stop()

Stop gracefully stops the gRPC server

func (*Server) StreamEvents 

func (s *Server) StreamEvents(req *proto.StreamEventsRequest, stream proto.WarrenAPI_StreamEventsServer) error

StreamEvents streams cluster events to the client TODO: Complete implementation

func (*Server) UpdateIngress 

func (s *Server) UpdateIngress(ctx context.Context, req *proto.UpdateIngressRequest) (*proto.UpdateIngressResponse, error)

UpdateIngress updates an existing ingress

func (*Server) UpdateService 

func (s *Server) UpdateService(ctx context.Context, req *proto.UpdateServiceRequest) (*proto.UpdateServiceResponse, error)

UpdateService updates an existing service

func (*Server) UpdateTaskStatus 

func (s *Server) UpdateTaskStatus(ctx context.Context, req *proto.UpdateTaskStatusRequest) (*proto.UpdateTaskStatusResponse, error)

UpdateTaskStatus updates the status of a task

func (*Server) WatchTasks 

func (s *Server) WatchTasks(req *proto.WatchTasksRequest, stream proto.WarrenAPI_WatchTasksServer) error

WatchTasks streams task events to a worker node

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.