service

package

v0.0.0-...-10084c7 Latest Latest Go to latest Published: Aug 22, 2025 License: Apache-2.0 Imports: 58 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/the78mole/jumpstarter-mono

Links

Open Source Insights

Documentation ¶

Index ¶

func Forward(ctx context.Context, a pb.RouterService_StreamServer, ...) error
func MatchLabels(candidate map[string]string, target map[string]string) int
func NewSelfSignedCertificate(commonName string, dnsnames []string, ipaddresses []net.IP) (*tls.Certificate, error)
type ControllerService
type DashboardService
type OIDCService
type RouterService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Forward ¶

func Forward(ctx context.Context, a pb.RouterService_StreamServer, b pb.RouterService_StreamServer) error

func MatchLabels ¶

func MatchLabels(candidate map[string]string, target map[string]string) int

func NewSelfSignedCertificate ¶

func NewSelfSignedCertificate(commonName string, dnsnames []string, ipaddresses []net.IP) (*tls.Certificate, error)

Types ¶

type ControllerService ¶

type ControllerService struct {
	pb.UnimplementedControllerServiceServer
	Client       client.WithWatch
	Scheme       *runtime.Scheme
	Authn        authentication.ContextAuthenticator
	Authz        authorizer.Authorizer
	Attr         authorization.ContextAttributesGetter
	ServerOption grpc.ServerOption
	Router       config.Router
	// contains filtered or unexported fields
}

ControllerService exposes a gRPC service

func (*ControllerService) Dial ¶

func (s *ControllerService) Dial(ctx context.Context, req *pb.DialRequest) (*pb.DialResponse, error)

func (*ControllerService) GetLease ¶

func (s *ControllerService) GetLease(
	ctx context.Context,
	req *pb.GetLeaseRequest,
) (*pb.GetLeaseResponse, error)

func (*ControllerService) ListLeases ¶

func (s *ControllerService) ListLeases(
	ctx context.Context,
	req *pb.ListLeasesRequest,
) (*pb.ListLeasesResponse, error)

func (*ControllerService) Listen ¶

func (s *ControllerService) Listen(req *pb.ListenRequest, stream pb.ControllerService_ListenServer) error

func (*ControllerService) Register ¶

func (s *ControllerService) Register(ctx context.Context, req *pb.RegisterRequest) (*pb.RegisterResponse, error)

func (*ControllerService) ReleaseLease ¶

func (s *ControllerService) ReleaseLease(
	ctx context.Context,
	req *pb.ReleaseLeaseRequest,
) (*pb.ReleaseLeaseResponse, error)

func (*ControllerService) RequestLease ¶

func (s *ControllerService) RequestLease(
	ctx context.Context,
	req *pb.RequestLeaseRequest,
) (*pb.RequestLeaseResponse, error)

func (*ControllerService) SetupWithManager ¶

func (s *ControllerService) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*ControllerService) Start ¶

func (s *ControllerService) Start(ctx context.Context) error

func (*ControllerService) Status ¶

func (s *ControllerService) Status(req *pb.StatusRequest, stream pb.ControllerService_StatusServer) error

Status is a stream of status updates for the exporter. It is used to:

Notify the exporter of the current status of the lease
Track the exporter's last seen time

func (*ControllerService) Unregister ¶

func (s *ControllerService) Unregister(
	ctx context.Context,
	req *pb.UnregisterRequest,
) (
	*pb.UnregisterResponse,
	error,
)

type DashboardService ¶

type DashboardService struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*DashboardService) NeedLeaderElection ¶

func (s *DashboardService) NeedLeaderElection() bool

func (*DashboardService) SetupWithManager ¶

func (s *DashboardService) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*DashboardService) Start ¶

func (s *DashboardService) Start(ctx context.Context) error

type OIDCService ¶

type OIDCService struct {
	Signer *oidc.Signer
	Cert   *tls.Certificate
}

RouterService exposes a gRPC service

func (*OIDCService) NeedLeaderElection ¶

func (s *OIDCService) NeedLeaderElection() bool

func (*OIDCService) SetupWithManager ¶

func (s *OIDCService) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*OIDCService) Start ¶

func (s *OIDCService) Start(ctx context.Context) error

type RouterService ¶

type RouterService struct {
	pb.UnimplementedRouterServiceServer
	ServerOption grpc.ServerOption
	// contains filtered or unexported fields
}

RouterService exposes a gRPC service

func (*RouterService) SetupWithManager ¶

func (s *RouterService) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*RouterService) Start ¶

func (s *RouterService) Start(ctx context.Context) error

func (*RouterService) Stream ¶

func (s *RouterService) Stream(stream pb.RouterService_StreamServer) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
auth
client
v1
utils

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