server

package
v0.5.15 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2026 License: AGPL-3.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AlreadyExists 

func AlreadyExists(resource string) error

func InvalidPageToken 

func InvalidPageToken(err error) error

func NotFound 

func NotFound(resource string) error

func PermissionDenied 

func PermissionDenied() error

Types

type AlreadyExistsError 

type AlreadyExistsError struct {
	Resource string
}

func (*AlreadyExistsError) Error 

func (e *AlreadyExistsError) Error() string

type InvalidPageTokenError 

type InvalidPageTokenError struct {
	Err error
}

func (*InvalidPageTokenError) Error 

func (e *InvalidPageTokenError) Error() string

func (*InvalidPageTokenError) Unwrap 

func (e *InvalidPageTokenError) Unwrap() error

type NotFoundError 

type NotFoundError struct {
	Resource string
}

func (*NotFoundError) Error 

func (e *NotFoundError) Error() string

type Options 

type Options struct {
	Pool                 dbPool
	IdentityClient       identityv1.IdentityServiceClient
	AuthorizationClient  authorizationv1.AuthorizationServiceClient
	AgentsClient         agentsClient
	ZitiManagementClient zitimanagementv1.ZitiManagementServiceClient
	NotificationsClient  notificationsv1.NotificationsServiceClient
	ZitiDialer           ZitiDialer
}

Options defines required inputs for constructing a Server.

type PermissionDeniedError 

type PermissionDeniedError struct{}

func (*PermissionDeniedError) Error 

func (e *PermissionDeniedError) Error() string

type Server 

type Server struct {
	runnersv1.UnimplementedRunnersServiceServer
	// contains filtered or unexported fields
}

Server implements the RunnersService gRPC API.

func New 

func New(options Options) *Server

New constructs a RunnersService server.

func (*Server) BatchUpdateVolumeSampledAt 

func (s *Server) BatchUpdateVolumeSampledAt(ctx context.Context, req *runnersv1.BatchUpdateVolumeSampledAtRequest) (*runnersv1.BatchUpdateVolumeSampledAtResponse, error)

func (*Server) BatchUpdateWorkloadSampledAt 

func (s *Server) BatchUpdateWorkloadSampledAt(ctx context.Context, req *runnersv1.BatchUpdateWorkloadSampledAtRequest) (*runnersv1.BatchUpdateWorkloadSampledAtResponse, error)

func (*Server) CreateVolume 

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

func (*Server) CreateWorkload 

func (s *Server) CreateWorkload(ctx context.Context, req *runnersv1.CreateWorkloadRequest) (*runnersv1.CreateWorkloadResponse, error)

func (*Server) DeleteRunner 

func (s *Server) DeleteRunner(ctx context.Context, req *runnersv1.DeleteRunnerRequest) (*runnersv1.DeleteRunnerResponse, error)

func (*Server) DeleteWorkload 

func (s *Server) DeleteWorkload(ctx context.Context, req *runnersv1.DeleteWorkloadRequest) (*runnersv1.DeleteWorkloadResponse, error)

func (*Server) EnrollRunner 

func (s *Server) EnrollRunner(ctx context.Context, req *runnersv1.EnrollRunnerRequest) (*runnersv1.EnrollRunnerResponse, error)

func (*Server) GetRunner 

func (s *Server) GetRunner(ctx context.Context, req *runnersv1.GetRunnerRequest) (*runnersv1.GetRunnerResponse, error)

func (*Server) GetVolume 

func (s *Server) GetVolume(ctx context.Context, req *runnersv1.GetVolumeRequest) (*runnersv1.GetVolumeResponse, error)

GetVolume reads one volume on the same terms the list RPCs read many: an identified caller must be allowed to view its organization's volumes, while an internal caller holds no identity and is served. Requiring one here left the Orchestrator, which strips its identity for exactly these reads, unable to inspect a volume record it had just been told already exists -- so every retried start failed on the read rather than the write.

func (*Server) GetWorkload 

func (s *Server) GetWorkload(ctx context.Context, req *runnersv1.GetWorkloadRequest) (*runnersv1.GetWorkloadResponse, error)

func (*Server) ListFlavors added in v0.5.13 

func (s *Server) ListFlavors(ctx context.Context, req *runnersv1.ListFlavorsRequest) (*runnersv1.ListFlavorsResponse, error)

ListFlavors returns catalog entries, optionally narrowed to one runner. Deprecated entries are hidden unless asked for: they still resolve and schedule, but pickers should steer new references away from them.

func (*Server) ListRunners 

func (s *Server) ListRunners(ctx context.Context, req *runnersv1.ListRunnersRequest) (*runnersv1.ListRunnersResponse, error)

func (*Server) ListStorageClasses added in v0.5.13 

func (s *Server) ListStorageClasses(ctx context.Context, req *runnersv1.ListStorageClassesRequest) (*runnersv1.ListStorageClassesResponse, error)

ListStorageClasses mirrors ListFlavors for the storage half of the catalog.

func (*Server) ListVolumes 

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

func (*Server) ListVolumesByAgentInstance added in v0.5.13 

func (s *Server) ListVolumesByAgentInstance(ctx context.Context, req *runnersv1.ListVolumesByAgentInstanceRequest) (*runnersv1.ListVolumesByAgentInstanceResponse, error)

func (*Server) ListVolumesByThread 

func (s *Server) ListVolumesByThread(ctx context.Context, req *runnersv1.ListVolumesByThreadRequest) (*runnersv1.ListVolumesByThreadResponse, error)

func (*Server) ListWorkloads 

func (s *Server) ListWorkloads(ctx context.Context, req *runnersv1.ListWorkloadsRequest) (*runnersv1.ListWorkloadsResponse, error)

func (*Server) ListWorkloadsByAgentInstance added in v0.5.13 

func (s *Server) ListWorkloadsByAgentInstance(ctx context.Context, req *runnersv1.ListWorkloadsByAgentInstanceRequest) (*runnersv1.ListWorkloadsByAgentInstanceResponse, error)

func (*Server) ListWorkloadsByThread 

func (s *Server) ListWorkloadsByThread(ctx context.Context, req *runnersv1.ListWorkloadsByThreadRequest) (*runnersv1.ListWorkloadsByThreadResponse, error)

func (*Server) RegisterRunner 

func (s *Server) RegisterRunner(ctx context.Context, req *runnersv1.RegisterRunnerRequest) (*runnersv1.RegisterRunnerResponse, error)

func (*Server) ReportRunnerCatalog added in v0.5.13 

func (s *Server) ReportRunnerCatalog(ctx context.Context, req *runnersv1.ReportRunnerCatalogRequest) (*runnersv1.ReportRunnerCatalogResponse, error)

ReportRunnerCatalog replaces a runner's stored catalog with the reported state. The report is declarative and validated as a whole: any violation rejects it entirely and leaves the previously stored catalog in place, so a runner rolling out a bad configuration cannot half-apply it and strand the environments that reference the old entries.

func (*Server) RunWorkloadActivitySweep 

func (s *Server) RunWorkloadActivitySweep(ctx context.Context, interval, keepaliveGrace time.Duration)

func (*Server) StreamWorkloadLogs 

func (s *Server) StreamWorkloadLogs(req *runnerv1.StreamWorkloadLogsRequest, stream grpc.ServerStreamingServer[runnerv1.StreamWorkloadLogsResponse]) error

func (*Server) TouchWorkload 

func (s *Server) TouchWorkload(ctx context.Context, req *runnersv1.TouchWorkloadRequest) (*runnersv1.TouchWorkloadResponse, error)

func (*Server) UpdateRunner 

func (s *Server) UpdateRunner(ctx context.Context, req *runnersv1.UpdateRunnerRequest) (*runnersv1.UpdateRunnerResponse, error)

func (*Server) UpdateVolume 

func (s *Server) UpdateVolume(ctx context.Context, req *runnersv1.UpdateVolumeRequest) (*runnersv1.UpdateVolumeResponse, error)

func (*Server) UpdateWorkload 

func (s *Server) UpdateWorkload(ctx context.Context, req *runnersv1.UpdateWorkloadRequest) (*runnersv1.UpdateWorkloadResponse, error)

func (*Server) UpdateWorkloadStatus 

func (s *Server) UpdateWorkloadStatus(ctx context.Context, req *runnersv1.UpdateWorkloadStatusRequest) (*runnersv1.UpdateWorkloadStatusResponse, error)

func (*Server) ValidateServiceToken 

func (s *Server) ValidateServiceToken(ctx context.Context, req *runnersv1.ValidateServiceTokenRequest) (*runnersv1.ValidateServiceTokenResponse, error)

type ZitiDialer 

type ZitiDialer interface {
	DialContext(ctx context.Context, service string) (edge.Conn, error)
	NotifyAuthFailure(ctx context.Context)
}

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.