service

Documentation

Index

• type PodManagerImpl
  • func InitializePodManager(ctx context.Context, httpSender comms.CommsSender, ...) (*PodManagerImpl, error)
  • func (p *PodManagerImpl) RefreshConfiguration(ctx context.Context, w comms.ResponseWriter, r comms.Request)
  • func (p *PodManagerImpl) Start(ctx context.Context, signals <-chan os.Signal) error
  • func (p *PodManagerImpl) Stop(ctx context.Context)
  • func (p *PodManagerImpl) TestCallback(ctx context.Context, w comms.ResponseWriter, r comms.Request)

Types

type PodManagerImpl

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

func InitializePodManager

func InitializePodManager(ctx context.Context, httpSender comms.CommsSender, httpReceiver comms.CommsReceiver) (*PodManagerImpl, error)

Initializes a new PodManagerImpl object

func (*PodManagerImpl) RefreshConfiguration

func (p *PodManagerImpl) RefreshConfiguration(ctx context.Context, w comms.ResponseWriter, r comms.Request)

RefreshConfiguration is a callback function that is called when a refresh request is received

func (*PodManagerImpl) Start

func (p *PodManagerImpl) Start(ctx context.Context, signals <-chan os.Signal) error

Start the pod manager

func (*PodManagerImpl) Stop

func (p *PodManagerImpl) Stop(ctx context.Context)

Stop the pod manager

func (*PodManagerImpl) TestCallback

func (p *PodManagerImpl) TestCallback(ctx context.Context, w comms.ResponseWriter, r comms.Request)

Dummy function for testing purposes