manager

Documentation

Index

• func Start(ctx context.Context, mux *http.ServeMux, store store.Store, ...) error
• type HttpClient
  • func (h *HttpClient) ActivateComponent(ctx context.Context, req *nanny.ActivateComponentRequest) error
  • func (h *HttpClient) Delete(ctx context.Context, req *nanny.ApplicationDeleteRequest) error
  • func (h *HttpClient) Deploy(ctx context.Context, req *nanny.ApplicationDeploymentRequest) error
  • func (h *HttpClient) ExportListener(ctx context.Context, req *nanny.ExportListenerRequest) (*protos.ExportListenerReply, error)
  • func (h *HttpClient) GetComponentsToStart(ctx context.Context, req *nanny.GetComponentsRequest) (*nanny.GetComponentsReply, error)
  • func (h *HttpClient) GetListenerAddress(ctx context.Context, req *nanny.GetListenerAddressRequest) (*protos.GetListenerAddressReply, error)
  • func (h *HttpClient) GetReplicaSetState(ctx context.Context, req *nanny.GetReplicaSetStateRequest) (*nanny.ReplicaSetState, error)
  • func (h *HttpClient) GetRoutingInfo(ctx context.Context, req *nanny.GetRoutingRequest) (*nanny.GetRoutingReply, error)
  • func (h *HttpClient) RegisterReplica(ctx context.Context, req *nanny.RegisterReplicaRequest) error
  • func (h *HttpClient) ReportLoad(ctx context.Context, req *nanny.LoadReport) error
  • func (h *HttpClient) Stop(ctx context.Context, req *nanny.ApplicationStopRequest) error

Functions

func Start

func Start(ctx context.Context,
	mux *http.ServeMux,
	store store.Store,
	logger *slog.Logger,
	dialAddr string,
	babysitterConstructor func(string) clients.BabysitterClient,
	replicaExists func(context.Context, string) (bool, error),
	getListenerPort func(context.Context, *config.GKEConfig, string, string) (int, error),
	exportListener func(context.Context, *config.GKEConfig, string, *nanny.Listener) (*protos.ExportListenerReply, error),
	startReplicaSet func(context.Context, *config.GKEConfig, string) error,
	stopAppVersions func(context.Context, string, []string) error,
	deleteAppVersions func(context.Context, string, []string) error) error

Start starts the manager service and registers its handlers with the given request multiplexer.

Types

type HttpClient

type HttpClient struct {
	Addr string // manager address
}

HttpClient is a Client that executes requests over HTTP.

func (*HttpClient) ActivateComponent

func (h *HttpClient) ActivateComponent(ctx context.Context, req *nanny.ActivateComponentRequest) error

ActivateComponent implements the clients.ManagerClient interface.

func (*HttpClient) Delete

func (h *HttpClient) Delete(ctx context.Context, req *nanny.ApplicationDeleteRequest) error

Delete implements the clients.ManagerClient interface.

func (*HttpClient) Deploy

func (h *HttpClient) Deploy(ctx context.Context, req *nanny.ApplicationDeploymentRequest) error

Deploy implements the clients.ManagerClient interface.

func (*HttpClient) ExportListener

func (h *HttpClient) ExportListener(ctx context.Context, req *nanny.ExportListenerRequest) (*protos.ExportListenerReply, error)

ExportListener implements the clients.ManagerClient interface.

func (*HttpClient) GetComponentsToStart

func (h *HttpClient) GetComponentsToStart(ctx context.Context, req *nanny.GetComponentsRequest) (
	*nanny.GetComponentsReply, error)

GetComponentsToStart implements the clients.ManagerClient interface.

func (*HttpClient) GetListenerAddress

func (h *HttpClient) GetListenerAddress(ctx context.Context, req *nanny.GetListenerAddressRequest) (*protos.GetListenerAddressReply, error)

GetListenerAddress implements the clients.ManagerClient interface.

func (*HttpClient) GetReplicaSetState

func (h *HttpClient) GetReplicaSetState(ctx context.Context, req *nanny.GetReplicaSetStateRequest) (*nanny.ReplicaSetState, error)

GetReplicaSetState implements the clients.ManagerClient interface.

func (*HttpClient) GetRoutingInfo

func (h *HttpClient) GetRoutingInfo(ctx context.Context, req *nanny.GetRoutingRequest) (*nanny.GetRoutingReply, error)

GetRoutingInfo implements the clients.ManagerClient interface.

func (*HttpClient) RegisterReplica

func (h *HttpClient) RegisterReplica(ctx context.Context, req *nanny.RegisterReplicaRequest) error

RegisterReplica implements the clients.ManagerClient interface.

func (*HttpClient) ReportLoad

func (h *HttpClient) ReportLoad(ctx context.Context, req *nanny.LoadReport) error

ReportLoad implements the clients.ManagerClient interface.

func (*HttpClient) Stop

func (h *HttpClient) Stop(ctx context.Context, req *nanny.ApplicationStopRequest) error

Stop implements the clients.ManagerClient interface.