control

package
v0.0.0-...-af9fdb0 Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2026 License: GPL-3.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FullHealthServer 

type FullHealthServer struct {
	healthpb.UnimplementedHealthServer
	// contains filtered or unexported fields
}

func NewFullHealthServer 

func NewFullHealthServer() *FullHealthServer

func (*FullHealthServer) Check 

func (s *FullHealthServer) Check(ctx context.Context, req *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)

func (*FullHealthServer) List 

func (s *FullHealthServer) List(ctx context.Context, req *healthpb.HealthListRequest) (*healthpb.HealthListResponse, error)

func (*FullHealthServer) SetServingStatus 

func (s *FullHealthServer) SetServingStatus(service string, status healthpb.HealthCheckResponse_ServingStatus)

func (*FullHealthServer) Watch 

func (s *FullHealthServer) Watch(req *healthpb.HealthCheckRequest, stream healthpb.Health_WatchServer) error

type Server 

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

func NewServer 

func NewServer(serverState *state.ServerState, settingsState *state.SettingsState, logger *slog.Logger, distributionState *state.DistributionState, eventBus *events.EventBus) *Server

func (*Server) IsRunning 

func (s *Server) IsRunning() bool

func (*Server) Start 

func (s *Server) Start(address string, stopChan chan struct{}) error

func (*Server) Stop 

func (s *Server) Stop() error

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.