server

package
v0.5.1 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var StreamSemaphore = make(chan struct{}, 100)

Functions

func CRDEnvToDomain 

func CRDEnvToDomain(crd *v1alpha1.Environment) (*domain.Environment, error)

CRDEnvToDomain maps a CRD Environment to the protobuf domain type.

func CRDPgToDomain 

func CRDPgToDomain(crd *v1alpha1.PreviewGroup) (*domain.PreviewGroup, error)

CRDPgToDomain maps a CRD PreviewGroup to the protobuf domain type.

func DomainEnvToCRD 

func DomainEnvToCRD(dom *domain.Environment) (*v1alpha1.Environment, error)

DomainEnvToCRD maps a protobuf domain Environment to the CRD type.

func DomainPgToCRD 

func DomainPgToCRD(dom *domain.PreviewGroup) (*v1alpha1.PreviewGroup, error)

DomainPgToCRD maps a protobuf domain PreviewGroup to the CRD type.

func GetBroadcasterMetrics added in v0.5.0 

func GetBroadcasterMetrics() streaming.BroadcasterMetrics

func NewAuthInterceptor 

func NewAuthInterceptor(authAttempts *prometheus.CounterVec) connect.Interceptor

func NewAuthService 

func NewAuthService() divergev1alpha1connect.AuthServiceHandler

func NewClusterService 

func NewClusterService() divergev1alpha1connect.ClusterServiceHandler

func NewEnvironmentService 

func NewEnvironmentService(c client.Client, informerMgr *streaming.InformerManager, logStreamer *streaming.LogStreamer) divergev1alpha1connect.EnvironmentServiceHandler

func NewMetricsInterceptor added in v0.5.0 

func NewMetricsInterceptor() connect.Interceptor

func NewPreviewGroupService 

func NewPreviewGroupService(c client.Client, informerMgr *streaming.InformerManager) divergev1alpha1connect.PreviewGroupServiceHandler

func NewServeMux 

func NewServeMux(c client.Client, informerMgr *streaming.InformerManager, logStreamer *streaming.LogStreamer) *http.ServeMux

Types

type AuthService 

type AuthService struct{}

func (*AuthService) GetCurrentUser 

func (s *AuthService) GetCurrentUser(ctx context.Context, req *connect.Request[pb.GetCurrentUserRequest]) (*connect.Response[pb.GetCurrentUserResponse], error)

func (*AuthService) ListPermissions 

func (s *AuthService) ListPermissions(ctx context.Context, req *connect.Request[pb.ListPermissionsRequest]) (*connect.Response[pb.ListPermissionsResponse], error)

type ClusterService 

type ClusterService struct{}

func (*ClusterService) GetClusterInfo 

func (s *ClusterService) GetClusterInfo(ctx context.Context, req *connect.Request[pb.GetClusterInfoRequest]) (*connect.Response[pb.GetClusterInfoResponse], error)

type EnvironmentService 

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

func (*EnvironmentService) CreateEnvironment 

func (s *EnvironmentService) CreateEnvironment(ctx context.Context, req *connect.Request[pb.CreateEnvironmentRequest]) (*connect.Response[pb.CreateEnvironmentResponse], error)

func (*EnvironmentService) DeleteEnvironment 

func (s *EnvironmentService) DeleteEnvironment(ctx context.Context, req *connect.Request[pb.DeleteEnvironmentRequest]) (*connect.Response[pb.DeleteEnvironmentResponse], error)

func (*EnvironmentService) ExtendTTL 

func (s *EnvironmentService) ExtendTTL(ctx context.Context, req *connect.Request[pb.ExtendTTLRequest]) (*connect.Response[pb.ExtendTTLResponse], error)

func (*EnvironmentService) GetEnvironment 

func (s *EnvironmentService) GetEnvironment(ctx context.Context, req *connect.Request[pb.GetEnvironmentRequest]) (*connect.Response[pb.GetEnvironmentResponse], error)

func (*EnvironmentService) ListEnvironments 

func (s *EnvironmentService) ListEnvironments(ctx context.Context, req *connect.Request[pb.ListEnvironmentsRequest]) (*connect.Response[pb.ListEnvironmentsResponse], error)

func (*EnvironmentService) StreamLogs 

func (s *EnvironmentService) StreamLogs(ctx context.Context, req *connect.Request[pb.StreamLogsRequest], stream *connect.ServerStream[pb.StreamLogsResponse]) error

func (*EnvironmentService) UpdateEnvironment 

func (s *EnvironmentService) UpdateEnvironment(ctx context.Context, req *connect.Request[pb.UpdateEnvironmentRequest]) (*connect.Response[pb.UpdateEnvironmentResponse], error)

func (*EnvironmentService) WatchEnvironments 

func (s *EnvironmentService) WatchEnvironments(ctx context.Context, req *connect.Request[pb.WatchEnvironmentsRequest], stream *connect.ServerStream[pb.WatchEnvironmentsResponse]) error

type PreviewGroupService 

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

func (*PreviewGroupService) CreatePreviewGroup 

func (s *PreviewGroupService) CreatePreviewGroup(ctx context.Context, req *connect.Request[pb.CreatePreviewGroupRequest]) (*connect.Response[pb.CreatePreviewGroupResponse], error)

func (*PreviewGroupService) DeletePreviewGroup 

func (s *PreviewGroupService) DeletePreviewGroup(ctx context.Context, req *connect.Request[pb.DeletePreviewGroupRequest]) (*connect.Response[pb.DeletePreviewGroupResponse], error)

func (*PreviewGroupService) GetPreviewGroup 

func (s *PreviewGroupService) GetPreviewGroup(ctx context.Context, req *connect.Request[pb.GetPreviewGroupRequest]) (*connect.Response[pb.GetPreviewGroupResponse], error)

func (*PreviewGroupService) ListPreviewGroups 

func (s *PreviewGroupService) ListPreviewGroups(ctx context.Context, req *connect.Request[pb.ListPreviewGroupsRequest]) (*connect.Response[pb.ListPreviewGroupsResponse], error)

func (*PreviewGroupService) WatchPreviewGroups 

func (s *PreviewGroupService) WatchPreviewGroups(ctx context.Context, req *connect.Request[pb.WatchPreviewGroupsRequest], stream *connect.ServerStream[pb.WatchPreviewGroupsResponse]) error

Source Files

View all Source files

Directories

Path Synopsis

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.