manager

Documentation

Index

• func Start(ctx context.Context, mux *http.ServeMux, store store.Store, ...) error
• type HttpClient
  • 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 *protos.GetComponentsToStart) (*protos.ComponentsToStart, error)
  • func (h *HttpClient) GetGroupState(ctx context.Context, req *nanny.GroupStateRequest) (*nanny.GroupState, error)
  • func (h *HttpClient) GetListenerAddress(ctx context.Context, req *nanny.GetListenerAddressRequest) (*protos.GetAddressReply, error)
  • func (h *HttpClient) GetRoutingInfo(ctx context.Context, req *protos.GetRoutingInfo) (*protos.RoutingInfo, error)
  • func (h *HttpClient) RegisterReplica(ctx context.Context, req *nanny.ReplicaToRegister) error
  • func (h *HttpClient) ReportLoad(ctx context.Context, req *protos.WeaveletLoadReport) error
  • func (h *HttpClient) StartColocationGroup(ctx context.Context, req *nanny.ColocationGroupStartRequest) error
  • func (h *HttpClient) StartComponent(ctx context.Context, req *protos.ComponentToStart) 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 *logging.FuncLogger,
	dialAddr string,
	babysitterConstructor func(string) clients.BabysitterClient,
	replicaExists func(context.Context, string) (bool, error),
	getListenerPort func(context.Context, *config.GKEConfig, *protos.ColocationGroup, string) (int, error),
	exportListener func(context.Context, *config.GKEConfig, *protos.ColocationGroup, *protos.Listener) (*protos.ExportListenerReply, error),
	startColocationGroup func(context.Context, *config.GKEConfig, *protos.ColocationGroup) 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) 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 *protos.GetComponentsToStart) (
	*protos.ComponentsToStart, error)

GetComponentsToStart implements the clients.ManagerClient interface.

func (*HttpClient) GetGroupState

func (h *HttpClient) GetGroupState(ctx context.Context, req *nanny.GroupStateRequest) (*nanny.GroupState, error)

GetGroupState implements the clients.ManagerClient interface.

func (*HttpClient) GetListenerAddress

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

func (*HttpClient) GetRoutingInfo

func (h *HttpClient) GetRoutingInfo(ctx context.Context, req *protos.GetRoutingInfo) (*protos.RoutingInfo, error)

GetRoutingInfo implements the clients.ManagerClient interface.

func (*HttpClient) RegisterReplica

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

RegisterReplica implements the clients.ManagerClient interface.

func (*HttpClient) ReportLoad

func (h *HttpClient) ReportLoad(ctx context.Context, req *protos.WeaveletLoadReport) error

ReportLoad implements the clients.ManagerClient interface.

func (*HttpClient) StartColocationGroup

func (h *HttpClient) StartColocationGroup(ctx context.Context, req *nanny.ColocationGroupStartRequest) error

StartColocationGroup implements the clients.ManagerClient interface.

func (*HttpClient) StartComponent

func (h *HttpClient) StartComponent(ctx context.Context, req *protos.ComponentToStart) error

StartComponent 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.