worker

Documentation

Index

• func ListenAndServe(log *slog.Logger, bindAddress string, tlsConfig api.TLSConfig, ...) error
• func Serve(log *slog.Logger, tlsConfig api.TLSConfig, listener net.Listener, ...) error
• type CapacityService
  • func New() *CapacityService
  • func (s *CapacityService) AddRemaining(value int32)
  • func (s *CapacityService) GetCapacity() int32
  • func (s *CapacityService) GetRemaining() int32
  • func (s *CapacityService) Monitor(msg *api.MetricsRequest, connection api.MetricsService_MonitorServer) error
  • func (s *CapacityService) SetCapacity(value int32)
  • func (s *CapacityService) SetRemaining(value int32)

Functions

func ListenAndServe

func ListenAndServe(log *slog.Logger, bindAddress string, tlsConfig api.TLSConfig, service *CapacityService) error

func Serve

func Serve(log *slog.Logger, tlsConfig api.TLSConfig, listener net.Listener, service *CapacityService) error

Types

type CapacityService

type CapacityService struct {
	Log *slog.Logger
	// contains filtered or unexported fields
}

func New

func New() *CapacityService

func (*CapacityService) AddRemaining

func (s *CapacityService) AddRemaining(value int32)

func (*CapacityService) GetCapacity

func (s *CapacityService) GetCapacity() int32

func (*CapacityService) GetRemaining

func (s *CapacityService) GetRemaining() int32

func (*CapacityService) Monitor

func (s *CapacityService) Monitor(msg *api.MetricsRequest, connection api.MetricsService_MonitorServer) error

func (*CapacityService) SetCapacity

func (s *CapacityService) SetCapacity(value int32)

func (*CapacityService) SetRemaining

func (s *CapacityService) SetRemaining(value int32)