api

package

Go to main page

Versions in this module

v1

v1.6.0

Oct 15, 2025

v1.5.0

Oct 15, 2025

v1.4.0

Oct 15, 2025

Changes in this version

+ const DefaultUnixSocket

+ const UnixSocketPermissions

+ func ReadOnlyInterceptor() grpc.UnaryServerInterceptor

+ type HealthResponse struct

+ Status string

+ Timestamp time.Time

+ Version string

+ type HealthServer struct

+ func NewHealthServer(mgr *manager.Manager) *HealthServer

+ func (hs *HealthServer) GetHandler() http.Handler

+ func (hs *HealthServer) Start(addr string) error

+ type ReadyResponse struct

+ Checks map[string]string

+ Message string

+ Status string

+ Timestamp time.Time

type Server

+ func (s *Server) StartUnix() error

v1.3.0

Oct 14, 2025

Changes in this version

type Server

+ func (s *Server) RollbackService(ctx context.Context, req *proto.RollbackServiceRequest) (*proto.RollbackServiceResponse, error)

+ func (s *Server) UpdateServiceImage(ctx context.Context, req *proto.UpdateServiceImageRequest) (*proto.UpdateServiceImageResponse, error)

v1.1.1

Oct 13, 2025

Changes in this version

type Server

+ func (s *Server) GetContainer(ctx context.Context, req *proto.GetContainerRequest) (*proto.GetContainerResponse, error)

+ func (s *Server) ListContainers(ctx context.Context, req *proto.ListContainersRequest) (*proto.ListContainersResponse, error)

+ func (s *Server) ReportContainerHealth(ctx context.Context, req *proto.ReportContainerHealthRequest) (*proto.ReportContainerHealthResponse, error)

+ func (s *Server) UpdateContainerStatus(ctx context.Context, req *proto.UpdateContainerStatusRequest) (*proto.UpdateContainerStatusResponse, error)

+ func (s *Server) WatchContainers(req *proto.WatchContainersRequest, ...) error

v1.1.0

Oct 12, 2025

Changes in this version

+ type Server struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (s *Server) Stop()

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

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

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

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

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

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