Documentation
¶
Index ¶
- Variables
- type Babysitter
- type Distributor
- type GetLoadReply
- func (*GetLoadReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetLoadReply) GetHealthyComponents() []string
- func (x *GetLoadReply) GetLoad() *protos.LoadReport
- func (x *GetLoadReply) GetWeaveletAddr() string
- func (*GetLoadReply) ProtoMessage()
- func (x *GetLoadReply) ProtoReflect() protoreflect.Message
- func (x *GetLoadReply) Reset()
- func (x *GetLoadReply) String() string
- type GetLoadRequest
- type Manager
Constants ¶
This section is empty.
Variables ¶
View Source
var File_internal_endpoints_babysitter_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Babysitter ¶
type Babysitter interface {
GetLoad(context.Context, *GetLoadRequest) (*GetLoadReply, error)
RunProfiling(context.Context, *protos.GetProfileRequest) (*protos.GetProfileReply, error)
}
Babysitter is an interface for a babysitter.
type Distributor ¶
type Distributor interface {
Distribute(context.Context, *nanny.ApplicationDistributionRequest) error
Cleanup(context.Context, *nanny.ApplicationCleanupRequest) error
GetApplicationState(context.Context, *nanny.ApplicationStateAtDistributorRequest) (*nanny.ApplicationStateAtDistributor, error)
GetPublicTrafficAssignment(context.Context) (*nanny.TrafficAssignment, error)
GetPrivateTrafficAssignment(context.Context) (*nanny.TrafficAssignment, error)
RunProfiling(context.Context, *nanny.GetProfileRequest) (*protos.GetProfileReply, error)
}
Distributor is an interface for a distributor.
type GetLoadReply ¶ added in v0.22.1
type GetLoadReply struct {
Load *protos.LoadReport `protobuf:"bytes,1,opt,name=load,proto3" json:"load,omitempty"` // weavelet load information
WeaveletAddr string `protobuf:"bytes,2,opt,name=weavelet_addr,json=weaveletAddr,proto3" json:"weavelet_addr,omitempty"` // self-reported weavelet internal address
HealthyComponents []string `protobuf:"bytes,3,rep,name=healthy_components,json=healthyComponents,proto3" json:"healthy_components,omitempty"` // components that are healthy
// contains filtered or unexported fields
}
GetLoadReply is a reply to a GetLoadRequest.
func (*GetLoadReply) Descriptor
deprecated
added in
v0.22.1
func (*GetLoadReply) Descriptor() ([]byte, []int)
Deprecated: Use GetLoadReply.ProtoReflect.Descriptor instead.
func (*GetLoadReply) GetHealthyComponents ¶ added in v0.24.1
func (x *GetLoadReply) GetHealthyComponents() []string
func (*GetLoadReply) GetLoad ¶ added in v0.22.1
func (x *GetLoadReply) GetLoad() *protos.LoadReport
func (*GetLoadReply) GetWeaveletAddr ¶ added in v0.22.1
func (x *GetLoadReply) GetWeaveletAddr() string
func (*GetLoadReply) ProtoMessage ¶ added in v0.22.1
func (*GetLoadReply) ProtoMessage()
func (*GetLoadReply) ProtoReflect ¶ added in v0.22.1
func (x *GetLoadReply) ProtoReflect() protoreflect.Message
func (*GetLoadReply) Reset ¶ added in v0.22.1
func (x *GetLoadReply) Reset()
func (*GetLoadReply) String ¶ added in v0.22.1
func (x *GetLoadReply) String() string
type GetLoadRequest ¶ added in v0.22.1
type GetLoadRequest struct {
// contains filtered or unexported fields
}
GetLoadRequest is a request from a manager to the babysitter for a weavelet's load report.
func (*GetLoadRequest) Descriptor
deprecated
added in
v0.22.1
func (*GetLoadRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLoadRequest.ProtoReflect.Descriptor instead.
func (*GetLoadRequest) ProtoMessage ¶ added in v0.22.1
func (*GetLoadRequest) ProtoMessage()
func (*GetLoadRequest) ProtoReflect ¶ added in v0.22.1
func (x *GetLoadRequest) ProtoReflect() protoreflect.Message
func (*GetLoadRequest) Reset ¶ added in v0.22.1
func (x *GetLoadRequest) Reset()
func (*GetLoadRequest) String ¶ added in v0.22.1
func (x *GetLoadRequest) String() string
type Manager ¶
type Manager interface {
Deploy(context.Context, *nanny.ApplicationDeploymentRequest) error
Stop(context.Context, *nanny.ApplicationStopRequest) error
Delete(context.Context, *nanny.ApplicationDeleteRequest) error
GetReplicaSets(context.Context, *nanny.GetReplicaSetsRequest) (*nanny.GetReplicaSetsReply, error)
ActivateComponent(context.Context, *nanny.ActivateComponentRequest) error
GetListenerAddress(context.Context, *nanny.GetListenerAddressRequest) (*protos.GetListenerAddressReply, error)
ExportListener(context.Context, *nanny.ExportListenerRequest) (*protos.ExportListenerReply, error)
GetRoutingInfo(context.Context, *nanny.GetRoutingRequest) (*nanny.GetRoutingReply, error)
GetComponentsToStart(context.Context, *nanny.GetComponentsRequest) (*nanny.GetComponentsReply, error)
}
Manager is an interface for a manager.
Click to show internal directories.
Click to hide internal directories.