endpoints

Documentation

Index

• Variables
• type Babysitter
• type Distributor
• type GetLoadReply
  • func (*GetLoadReply) Descriptor() ([]byte, []int)
  • 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
  • func (*GetLoadRequest) Descriptor() ([]byte, []int)
  • func (*GetLoadRequest) ProtoMessage()
  • func (x *GetLoadRequest) ProtoReflect() protoreflect.Message
  • func (x *GetLoadRequest) Reset()
  • func (x *GetLoadRequest) String() string
• type Manager

Variables

var File_internal_endpoints_babysitter_proto protoreflect.FileDescriptor

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

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
	// contains filtered or unexported fields
}

GetLoadReply is a reply to a GetLoadRequest.

func (*GetLoadReply) Descriptor

func (*GetLoadReply) Descriptor() ([]byte, []int)

Deprecated: Use GetLoadReply.ProtoReflect.Descriptor instead.

func (*GetLoadReply) GetLoad

func (x *GetLoadReply) GetLoad() *protos.LoadReport

func (*GetLoadReply) GetWeaveletAddr

func (x *GetLoadReply) GetWeaveletAddr() string

func (*GetLoadReply) ProtoMessage

func (*GetLoadReply) ProtoMessage()

func (*GetLoadReply) ProtoReflect

func (x *GetLoadReply) ProtoReflect() protoreflect.Message

func (*GetLoadReply) Reset

func (x *GetLoadReply) Reset()

func (*GetLoadReply) String

func (x *GetLoadReply) String() string

type GetLoadRequest

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

func (*GetLoadRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetLoadRequest.ProtoReflect.Descriptor instead.

func (*GetLoadRequest) ProtoMessage

func (*GetLoadRequest) ProtoMessage()

func (*GetLoadRequest) ProtoReflect

func (x *GetLoadRequest) ProtoReflect() protoreflect.Message

func (*GetLoadRequest) Reset

func (x *GetLoadRequest) Reset()

func (*GetLoadRequest) String

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.