clients

Documentation

Index

• Variables
• type BabysitterClient
• type DistributorClient
• type HealthCheck
  • func (*HealthCheck) Descriptor() ([]byte, []int)
  • func (x *HealthCheck) GetAddr() string
  • func (x *HealthCheck) GetTimeout() *durationpb.Duration
  • func (*HealthCheck) ProtoMessage()
  • func (x *HealthCheck) ProtoReflect() protoreflect.Message
  • func (x *HealthCheck) Reset()
  • func (x *HealthCheck) String() string
• type ManagerClient

Variables

var File_internal_clients_babysitter_proto protoreflect.FileDescriptor

Types

type BabysitterClient

type BabysitterClient interface {
	CheckHealth(ctx context.Context, status *HealthCheck) (*protos.HealthReport, error)
	RunProfiling(context.Context, *protos.RunProfiling) (*protos.Profile, error)
}

BabysitterClient is a client to a babysitter.

type DistributorClient

type DistributorClient interface {
	Distribute(ctx context.Context, req *nanny.ApplicationDistributionRequest) error
	Cleanup(ctx context.Context, req *nanny.ApplicationCleanupRequest) error
	GetApplicationState(ctx context.Context, req *nanny.ApplicationStateAtDistributorRequest) (*nanny.ApplicationStateAtDistributor, error)
	GetPublicTrafficAssignment(ctx context.Context) (*nanny.TrafficAssignment, error)
	GetPrivateTrafficAssignment(ctx context.Context) (*nanny.TrafficAssignment, error)
	RunProfiling(context.Context, *protos.RunProfiling) (*protos.Profile, error)
}

DistributorClient is a client to a distributor.

type HealthCheck

type HealthCheck struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// Duration after which the check is declared as failed.
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

HealthCheck is a request to the babysitter to check the health status for a given colocation group replica.

func (*HealthCheck) Descriptor

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

Deprecated: Use HealthCheck.ProtoReflect.Descriptor instead.

func (*HealthCheck) GetAddr

func (x *HealthCheck) GetAddr() string

func (*HealthCheck) GetTimeout

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

func (*HealthCheck) ProtoMessage

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) ProtoReflect

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

func (*HealthCheck) Reset

func (x *HealthCheck) Reset()

func (*HealthCheck) String

func (x *HealthCheck) String() string

type ManagerClient

type ManagerClient interface {
	Deploy(context.Context, *nanny.ApplicationDeploymentRequest) error
	Stop(context.Context, *nanny.ApplicationStopRequest) error
	Delete(context.Context, *nanny.ApplicationDeleteRequest) error
	GetGroupState(context.Context, *nanny.GroupStateRequest) (*nanny.GroupState, error)
	StartComponent(context.Context, *protos.ComponentToStart) error
	StartColocationGroup(context.Context, *nanny.ColocationGroupStartRequest) error
	RegisterReplica(context.Context, *nanny.ReplicaToRegister) error
	ReportLoad(context.Context, *protos.WeaveletLoadReport) error
	GetListenerAddress(context.Context, *nanny.GetListenerAddressRequest) (*protos.GetAddressReply, error)
	ExportListener(context.Context, *nanny.ExportListenerRequest) (*protos.ExportListenerReply, error)
	GetRoutingInfo(context.Context, *protos.GetRoutingInfo) (*protos.RoutingInfo, error)
	GetComponentsToStart(context.Context, *protos.GetComponentsToStart) (*protos.ComponentsToStart, error)
}

ManagerClient is a client to a manager.

TODO(mwhittaker): Refactor the manager so that it also implements the Client interface.