clients

Apr 5, 2023

Changes in this version

+ const LoadReportInterval

type ManagerClient

+ ActivateComponent func(context.Context, *nanny.ActivateComponentRequest) error

+ GetReplicaSetState func(context.Context, *nanny.GetReplicaSetStateRequest) (*nanny.ReplicaSetState, error)

Mar 14, 2023

Changes in this version

type ManagerClient

+ GetGroupState func(context.Context, *nanny.GroupStateRequest) (*nanny.GroupState, error)

+ GetListenerAddress func(context.Context, *nanny.GetListenerAddressRequest) (*protos.GetAddressReply, error)

Feb 28, 2023

Changes in this version

+ var File_internal_clients_babysitter_proto protoreflect.FileDescriptor

+ type BabysitterClient interface

+ CheckHealth func(ctx context.Context, status *HealthCheck) (*protos.HealthReport, error)

+ RunProfiling func(context.Context, *protos.RunProfiling) (*protos.Profile, error)

+ type DistributorClient interface

+ Cleanup func(ctx context.Context, req *nanny.ApplicationCleanupRequest) error

+ Distribute func(ctx context.Context, req *nanny.ApplicationDistributionRequest) error

+ GetApplicationState func(ctx context.Context, req *nanny.ApplicationStateAtDistributorRequest) (*nanny.ApplicationStateAtDistributor, error)

+ GetPrivateTrafficAssignment func(ctx context.Context) (*nanny.TrafficAssignment, error)

+ GetPublicTrafficAssignment func(ctx context.Context) (*nanny.TrafficAssignment, error)

+ RunProfiling func(context.Context, *protos.RunProfiling) (*protos.Profile, error)

+ type HealthCheck struct

+ Addr string

+ Process string

+ Timeout *durationpb.Duration

+ func (*HealthCheck) Descriptor() ([]byte, []int)

+ func (*HealthCheck) ProtoMessage()

+ func (x *HealthCheck) GetAddr() string

+ func (x *HealthCheck) GetProcess() string

+ func (x *HealthCheck) GetTimeout() *durationpb.Duration

+ func (x *HealthCheck) ProtoReflect() protoreflect.Message

+ func (x *HealthCheck) Reset()

+ func (x *HealthCheck) String() string

+ type ManagerClient interface

+ Delete func(context.Context, *nanny.ApplicationDeleteRequest) error

+ Deploy func(context.Context, *nanny.ApplicationDeploymentRequest) error

+ ExportListener func(context.Context, *nanny.ExportListenerRequest) (*protos.ExportListenerReply, error)

+ GetComponentsToStart func(context.Context, *protos.GetComponentsToStart) (*protos.ComponentsToStart, error)

+ GetProcessState func(context.Context, *nanny.ProcessStateRequest) (*nanny.ProcessState, error)

+ GetProcessesToStart func(context.Context, *protos.GetProcessesToStartRequest) (*protos.GetProcessesToStartReply, error)

+ GetRoutingInfo func(context.Context, *protos.GetRoutingInfo) (*protos.RoutingInfo, error)

+ RegisterReplica func(context.Context, *nanny.ReplicaToRegister) error

+ ReportLoad func(context.Context, *protos.WeaveletLoadReport) error

+ StartColocationGroup func(context.Context, *nanny.ColocationGroupStartRequest) error

+ StartComponent func(context.Context, *protos.ComponentToStart) error

+ Stop func(context.Context, *nanny.ApplicationStopRequest) error