nanny

package
v0.1.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 16, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_nanny_nanny_proto protoreflect.FileDescriptor

Functions

func Advance 

func Advance(s *Schedule) error

Advance advances the schedule to the next traffic fraction. A schedule can only be advanced if it's ready. See the Ready method.

func ChangeTimes 

func ChangeTimes(t *TargetFn, start time.Time) []time.Time

ChangeTimes returns the set of times at which the target function changes, assuming the target function is started at the provided time.

func Done 

func Done(s *Schedule) bool

Done returns whether the schedule has been fully applied.

func Fraction 

func Fraction(s *Schedule) float32

Fraction returns the current traffic fraction.

func IncrementAppliedDuration 

func IncrementAppliedDuration(s *Schedule, d time.Duration)

IncrementAppliedDuration increases the duration the current traffic fraction has been applied.

func Length 

func Length(t *TargetFn) time.Duration

Length returns the total length of the TargetFn.

func Ready 

func Ready(s *Schedule) bool

Ready returns whether the schedule is ready to be advanced. A schedule is ready to be advanced if the current traffic fraction has been applied for its specified duration.

Example usage: 

if Ready(schedule) {
    if err := Advance(schedule); err != nil {
        ...
    }
}

func Remaining 

func Remaining(s *Schedule) time.Duration

Remaining returns the remaining duration the current traffic fraction should be applied for.

func TargetFraction 

func TargetFraction(t *TargetFn, d time.Duration) float32

TargetFraction returns the target fraction at the given duration after a target function has started to be applied, assuming no delays.

Types

type ApplicationCleanupRequest 

type ApplicationCleanupRequest struct {
	AppName  string   `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	Versions []string `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

ApplicationCleanupRequest is a request to the distributor to clean up a set of versions for a given application.

func (*ApplicationCleanupRequest) Descriptor deprecated 

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

Deprecated: Use ApplicationCleanupRequest.ProtoReflect.Descriptor instead.

func (*ApplicationCleanupRequest) GetAppName 

func (x *ApplicationCleanupRequest) GetAppName() string

func (*ApplicationCleanupRequest) GetVersions 

func (x *ApplicationCleanupRequest) GetVersions() []string

func (*ApplicationCleanupRequest) ProtoMessage 

func (*ApplicationCleanupRequest) ProtoMessage()

func (*ApplicationCleanupRequest) ProtoReflect 

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

func (*ApplicationCleanupRequest) Reset 

func (x *ApplicationCleanupRequest) Reset()

func (*ApplicationCleanupRequest) String 

func (x *ApplicationCleanupRequest) String() string

type ApplicationDeleteRequest 

type ApplicationDeleteRequest struct {
	AppName  string   `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	Versions []string `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

ApplicationDeleteRequest is a request to the manager to delete a set of versions for a given application.

func (*ApplicationDeleteRequest) Descriptor deprecated 

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

Deprecated: Use ApplicationDeleteRequest.ProtoReflect.Descriptor instead.

func (*ApplicationDeleteRequest) GetAppName 

func (x *ApplicationDeleteRequest) GetAppName() string

func (*ApplicationDeleteRequest) GetVersions 

func (x *ApplicationDeleteRequest) GetVersions() []string

func (*ApplicationDeleteRequest) ProtoMessage 

func (*ApplicationDeleteRequest) ProtoMessage()

func (*ApplicationDeleteRequest) ProtoReflect 

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

func (*ApplicationDeleteRequest) Reset 

func (x *ApplicationDeleteRequest) Reset()

func (*ApplicationDeleteRequest) String 

func (x *ApplicationDeleteRequest) String() string

type ApplicationDeploymentRequest 

type ApplicationDeploymentRequest struct {
	AppName  string              `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	Versions []*config.GKEConfig `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

ApplicationDeploymentRequest is a request to the manager to deploy a set of versions for a given application.

func (*ApplicationDeploymentRequest) Descriptor deprecated 

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

Deprecated: Use ApplicationDeploymentRequest.ProtoReflect.Descriptor instead.

func (*ApplicationDeploymentRequest) GetAppName 

func (x *ApplicationDeploymentRequest) GetAppName() string

func (*ApplicationDeploymentRequest) GetVersions 

func (x *ApplicationDeploymentRequest) GetVersions() []*config.GKEConfig

func (*ApplicationDeploymentRequest) ProtoMessage 

func (*ApplicationDeploymentRequest) ProtoMessage()

func (*ApplicationDeploymentRequest) ProtoReflect 

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

func (*ApplicationDeploymentRequest) Reset 

func (x *ApplicationDeploymentRequest) Reset()

func (*ApplicationDeploymentRequest) String 

func (x *ApplicationDeploymentRequest) String() string

type ApplicationDistributionRequest 

type ApplicationDistributionRequest struct {
	AppName  string                        `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	Requests []*VersionDistributionRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

ApplicationDistributionRequest is a request to the distributor to start a set of versions for a given application in their deployment locations (e.g., a cloud region), and gradually shift traffic to them.

func (*ApplicationDistributionRequest) Descriptor deprecated 

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

Deprecated: Use ApplicationDistributionRequest.ProtoReflect.Descriptor instead.

func (*ApplicationDistributionRequest) GetAppName 

func (x *ApplicationDistributionRequest) GetAppName() string

func (*ApplicationDistributionRequest) GetRequests 

func (x *ApplicationDistributionRequest) GetRequests() []*VersionDistributionRequest

func (*ApplicationDistributionRequest) ProtoMessage 

func (*ApplicationDistributionRequest) ProtoMessage()

func (*ApplicationDistributionRequest) ProtoReflect 

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

func (*ApplicationDistributionRequest) Reset 

func (x *ApplicationDistributionRequest) Reset()

func (*ApplicationDistributionRequest) String 

func (x *ApplicationDistributionRequest) String() string

type ApplicationStateAtDistributor 

type ApplicationStateAtDistributor struct {
	VersionState    []*VersionStateAtDistributor `protobuf:"bytes,1,rep,name=version_state,json=versionState,proto3" json:"version_state,omitempty"`
	DeletedVersions []string                     `protobuf:"bytes,2,rep,name=deleted_versions,json=deletedVersions,proto3" json:"deleted_versions,omitempty"`
	// contains filtered or unexported fields
}

ApplicationStateAtDistributor contains the latest state for a given application at a particular distributor.

func (*ApplicationStateAtDistributor) Descriptor deprecated 

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

Deprecated: Use ApplicationStateAtDistributor.ProtoReflect.Descriptor instead.

func (*ApplicationStateAtDistributor) GetDeletedVersions 

func (x *ApplicationStateAtDistributor) GetDeletedVersions() []string

func (*ApplicationStateAtDistributor) GetVersionState 

func (x *ApplicationStateAtDistributor) GetVersionState() []*VersionStateAtDistributor

func (*ApplicationStateAtDistributor) ProtoMessage 

func (*ApplicationStateAtDistributor) ProtoMessage()

func (*ApplicationStateAtDistributor) ProtoReflect 

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

func (*ApplicationStateAtDistributor) Reset 

func (x *ApplicationStateAtDistributor) Reset()

func (*ApplicationStateAtDistributor) String 

func (x *ApplicationStateAtDistributor) String() string

type ApplicationStateAtDistributorRequest 

type ApplicationStateAtDistributorRequest struct {
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// contains filtered or unexported fields
}

ApplicationStateAtDistributorRequest is a request to the distributor to get the latest state for a given application.

func (*ApplicationStateAtDistributorRequest) Descriptor deprecated 

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

Deprecated: Use ApplicationStateAtDistributorRequest.ProtoReflect.Descriptor instead.

func (*ApplicationStateAtDistributorRequest) GetAppName 

func (x *ApplicationStateAtDistributorRequest) GetAppName() string

func (*ApplicationStateAtDistributorRequest) ProtoMessage 

func (*ApplicationStateAtDistributorRequest) ProtoMessage()

func (*ApplicationStateAtDistributorRequest) ProtoReflect 

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

func (*ApplicationStateAtDistributorRequest) Reset 

func (x *ApplicationStateAtDistributorRequest) Reset()

func (*ApplicationStateAtDistributorRequest) String 

func (x *ApplicationStateAtDistributorRequest) String() string

type ApplicationStopRequest 

type ApplicationStopRequest struct {
	AppName  string   `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	Versions []string `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

ApplicationStopRequest is a request to the manager to stop a set of versions for a given application.

func (*ApplicationStopRequest) Descriptor deprecated 

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

Deprecated: Use ApplicationStopRequest.ProtoReflect.Descriptor instead.

func (*ApplicationStopRequest) GetAppName 

func (x *ApplicationStopRequest) GetAppName() string

func (*ApplicationStopRequest) GetVersions 

func (x *ApplicationStopRequest) GetVersions() []string

func (*ApplicationStopRequest) ProtoMessage 

func (*ApplicationStopRequest) ProtoMessage()

func (*ApplicationStopRequest) ProtoReflect 

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

func (*ApplicationStopRequest) Reset 

func (x *ApplicationStopRequest) Reset()

func (*ApplicationStopRequest) String 

func (x *ApplicationStopRequest) String() string

type CascadeTarget 

type CascadeTarget struct {
	Location        string                        // e.g. "local", "us-central1"
	AppName         string                        // e.g. "collatz", "todo"
	VersionId       string                        // e.g. "6ba7b810-9dad-11d1"
	Listeners       map[string][]*protos.Listener // listeners, keyed by host
	TrafficFraction float32                       // the desired traffic fraction
}

CascadeTarget encapsulates the traffic specific information about a version of a Service Weaver app. Typically, you create one CascadeTarget for every version of your app and then call CascadeTraffic to assign traffic between them.

type ColocationGroupStartRequest 

type ColocationGroupStartRequest struct {
	Group  *protos.ColocationGroup `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Config *config.GKEConfig       `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

ColocationGroupStartEequest is a request to the manager to start a colocation group for a given application version.

func (*ColocationGroupStartRequest) Descriptor deprecated 

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

Deprecated: Use ColocationGroupStartRequest.ProtoReflect.Descriptor instead.

func (*ColocationGroupStartRequest) GetConfig 

func (x *ColocationGroupStartRequest) GetConfig() *config.GKEConfig

func (*ColocationGroupStartRequest) GetGroup 

func (x *ColocationGroupStartRequest) GetGroup() *protos.ColocationGroup

func (*ColocationGroupStartRequest) ProtoMessage 

func (*ColocationGroupStartRequest) ProtoMessage()

func (*ColocationGroupStartRequest) ProtoReflect 

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

func (*ColocationGroupStartRequest) Reset 

func (x *ColocationGroupStartRequest) Reset()

func (*ColocationGroupStartRequest) String 

func (x *ColocationGroupStartRequest) String() string

type ExportListenerRequest 

type ExportListenerRequest struct {
	Group    *protos.ColocationGroup `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Listener *protos.Listener        `protobuf:"bytes,2,opt,name=listener,proto3" json:"listener,omitempty"`
	Config   *config.GKEConfig       `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

ExportListenerRequest is a request to the manager to export a listener.

func (*ExportListenerRequest) Descriptor deprecated 

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

Deprecated: Use ExportListenerRequest.ProtoReflect.Descriptor instead.

func (*ExportListenerRequest) GetConfig 

func (x *ExportListenerRequest) GetConfig() *config.GKEConfig

func (*ExportListenerRequest) GetGroup added in v0.1.3 

func (x *ExportListenerRequest) GetGroup() *protos.ColocationGroup

func (*ExportListenerRequest) GetListener 

func (x *ExportListenerRequest) GetListener() *protos.Listener

func (*ExportListenerRequest) ProtoMessage 

func (*ExportListenerRequest) ProtoMessage()

func (*ExportListenerRequest) ProtoReflect 

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

func (*ExportListenerRequest) Reset 

func (x *ExportListenerRequest) Reset()

func (*ExportListenerRequest) String 

func (x *ExportListenerRequest) String() string

type FractionSpec 

type FractionSpec struct {

	// Minimum duration the traffic fraction should be applied.
	Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// Traffic fraction in the range [0, 1] to be sent to the application version.
	TrafficFraction float32 `protobuf:"fixed32,2,opt,name=traffic_fraction,json=trafficFraction,proto3" json:"traffic_fraction,omitempty"`
	// contains filtered or unexported fields
}

FractionSpec represents one stage in the TargetFn that should be applied to a given application version.

It stores the traffic fraction that should be assigned to the application version, as well as the duration of that traffic assignment. Once the traffic fraction has been applied for longer than the specified duration, the target function moves to the next rollout stage (see comments above TargetFn).

func (*FractionSpec) Descriptor deprecated 

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

Deprecated: Use FractionSpec.ProtoReflect.Descriptor instead.

func (*FractionSpec) GetDuration 

func (x *FractionSpec) GetDuration() *durationpb.Duration

func (*FractionSpec) GetTrafficFraction 

func (x *FractionSpec) GetTrafficFraction() float32

func (*FractionSpec) ProtoMessage 

func (*FractionSpec) ProtoMessage()

func (*FractionSpec) ProtoReflect 

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

func (*FractionSpec) Reset 

func (x *FractionSpec) Reset()

func (*FractionSpec) String 

func (x *FractionSpec) String() string

type GetListenerAddressRequest added in v0.1.3 

type GetListenerAddressRequest struct {
	Group    *protos.ColocationGroup `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Listener string                  `protobuf:"bytes,2,opt,name=listener,proto3" json:"listener,omitempty"`
	Config   *config.GKEConfig       `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

GetListenerAddressRequest is a request to the manager to get an address a listener in a given colocation group should listen on.

func (*GetListenerAddressRequest) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use GetListenerAddressRequest.ProtoReflect.Descriptor instead.

func (*GetListenerAddressRequest) GetConfig added in v0.1.3 

func (x *GetListenerAddressRequest) GetConfig() *config.GKEConfig

func (*GetListenerAddressRequest) GetGroup added in v0.1.3 

func (x *GetListenerAddressRequest) GetGroup() *protos.ColocationGroup

func (*GetListenerAddressRequest) GetListener added in v0.1.3 

func (x *GetListenerAddressRequest) GetListener() string

func (*GetListenerAddressRequest) ProtoMessage added in v0.1.3 

func (*GetListenerAddressRequest) ProtoMessage()

func (*GetListenerAddressRequest) ProtoReflect added in v0.1.3 

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

func (*GetListenerAddressRequest) Reset added in v0.1.3 

func (x *GetListenerAddressRequest) Reset()

func (*GetListenerAddressRequest) String added in v0.1.3 

func (x *GetListenerAddressRequest) String() string

type GroupState added in v0.1.3 

type GroupState struct {
	Groups []*GroupState_Group `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"`
	// Errors encountered collecting the group state.
	// Note that the group data may be partially populated even if there were
	// collection errors.
	Errors []string `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

GroupState stores the colocation group state for an application version or a collection of applications and their versions.

func (*GroupState) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use GroupState.ProtoReflect.Descriptor instead.

func (*GroupState) GetErrors added in v0.1.3 

func (x *GroupState) GetErrors() []string

func (*GroupState) GetGroups added in v0.1.3 

func (x *GroupState) GetGroups() []*GroupState_Group

func (*GroupState) ProtoMessage added in v0.1.3 

func (*GroupState) ProtoMessage()

func (*GroupState) ProtoReflect added in v0.1.3 

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

func (*GroupState) Reset added in v0.1.3 

func (x *GroupState) Reset()

func (*GroupState) String added in v0.1.3 

func (x *GroupState) String() string

type GroupStateRequest added in v0.1.3 

type GroupStateRequest struct {

	// Application name and version.
	//
	// If the application name is non-empty, the request is for retrieving
	// group state only for the given application; otherwise, the request is
	// for retrieving group state for all active applications.
	// If the application version is non-empty, the request is for retrieving
	// group state only for a particular version of an application; otherwise,
	// the request is for retrieving group state for all versions of an
	// application (or a collection of applications).
	// It is illegal to specify the version and not the application name.
	AppName   string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	VersionId string `protobuf:"bytes,2,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	// contains filtered or unexported fields
}

GroupStateRequest is a request to receive the state of groups for the given application version or a collection of applications and their versions.

func (*GroupStateRequest) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use GroupStateRequest.ProtoReflect.Descriptor instead.

func (*GroupStateRequest) GetAppName added in v0.1.3 

func (x *GroupStateRequest) GetAppName() string

func (*GroupStateRequest) GetVersionId added in v0.1.3 

func (x *GroupStateRequest) GetVersionId() string

func (*GroupStateRequest) ProtoMessage added in v0.1.3 

func (*GroupStateRequest) ProtoMessage()

func (*GroupStateRequest) ProtoReflect added in v0.1.3 

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

func (*GroupStateRequest) Reset added in v0.1.3 

func (x *GroupStateRequest) Reset()

func (*GroupStateRequest) String added in v0.1.3 

func (x *GroupStateRequest) String() string

type GroupState_Group added in v0.1.3 

type GroupState_Group struct {
	Name       string                      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Replicas   []*GroupState_Group_Replica `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`     // All known group replicas.
	Components []string                    `protobuf:"bytes,3,rep,name=components,proto3" json:"components,omitempty"` // Active components hosted by the group.
	Listeners  []*protos.Listener          `protobuf:"bytes,4,rep,name=listeners,proto3" json:"listeners,omitempty"`   // Listeners hosted by the group.
	// contains filtered or unexported fields
}

Group stores information about an application version group.

func (*GroupState_Group) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use GroupState_Group.ProtoReflect.Descriptor instead.

func (*GroupState_Group) GetComponents added in v0.1.3 

func (x *GroupState_Group) GetComponents() []string

func (*GroupState_Group) GetListeners added in v0.1.3 

func (x *GroupState_Group) GetListeners() []*protos.Listener

func (*GroupState_Group) GetName added in v0.1.3 

func (x *GroupState_Group) GetName() string

func (*GroupState_Group) GetReplicas added in v0.1.3 

func (x *GroupState_Group) GetReplicas() []*GroupState_Group_Replica

func (*GroupState_Group) ProtoMessage added in v0.1.3 

func (*GroupState_Group) ProtoMessage()

func (*GroupState_Group) ProtoReflect added in v0.1.3 

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

func (*GroupState_Group) Reset added in v0.1.3 

func (x *GroupState_Group) Reset()

func (*GroupState_Group) String added in v0.1.3 

func (x *GroupState_Group) String() string

type GroupState_Group_Replica added in v0.1.3 

type GroupState_Group_Replica struct {
	WeaveletAddr   string              `protobuf:"bytes,1,opt,name=weavelet_addr,json=weaveletAddr,proto3" json:"weavelet_addr,omitempty"`                            // Weavelet address.
	BabysitterAddr string              `protobuf:"bytes,2,opt,name=babysitter_addr,json=babysitterAddr,proto3" json:"babysitter_addr,omitempty"`                      // Babysitter address.
	HealthStatus   protos.HealthStatus `protobuf:"varint,3,opt,name=health_status,json=healthStatus,proto3,enum=runtime.HealthStatus" json:"health_status,omitempty"` // Health status.
	// contains filtered or unexported fields
}

Replica stores information about a colocation group replica.

func (*GroupState_Group_Replica) Descriptor deprecated added in v0.1.3 

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

Deprecated: Use GroupState_Group_Replica.ProtoReflect.Descriptor instead.

func (*GroupState_Group_Replica) GetBabysitterAddr added in v0.1.3 

func (x *GroupState_Group_Replica) GetBabysitterAddr() string

func (*GroupState_Group_Replica) GetHealthStatus added in v0.1.3 

func (x *GroupState_Group_Replica) GetHealthStatus() protos.HealthStatus

func (*GroupState_Group_Replica) GetWeaveletAddr added in v0.1.3 

func (x *GroupState_Group_Replica) GetWeaveletAddr() string

func (*GroupState_Group_Replica) ProtoMessage added in v0.1.3 

func (*GroupState_Group_Replica) ProtoMessage()

func (*GroupState_Group_Replica) ProtoReflect added in v0.1.3 

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

func (*GroupState_Group_Replica) Reset added in v0.1.3 

func (x *GroupState_Group_Replica) Reset()

func (*GroupState_Group_Replica) String added in v0.1.3 

func (x *GroupState_Group_Replica) String() string

type HostTrafficAssignment 

type HostTrafficAssignment struct {
	Allocs []*TrafficAllocation `protobuf:"bytes,1,rep,name=allocs,proto3" json:"allocs,omitempty"`
	// contains filtered or unexported fields
}

HostTrafficAssignment contains the traffic assignment for a given hostname.

func (*HostTrafficAssignment) Descriptor deprecated 

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

Deprecated: Use HostTrafficAssignment.ProtoReflect.Descriptor instead.

func (*HostTrafficAssignment) GetAllocs 

func (x *HostTrafficAssignment) GetAllocs() []*TrafficAllocation

func (*HostTrafficAssignment) ProtoMessage 

func (*HostTrafficAssignment) ProtoMessage()

func (*HostTrafficAssignment) ProtoReflect 

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

func (*HostTrafficAssignment) Reset 

func (x *HostTrafficAssignment) Reset()

func (*HostTrafficAssignment) String 

func (x *HostTrafficAssignment) String() string

type ReplicaToRegister 

type ReplicaToRegister struct {
	PodName           string                    `protobuf:"bytes,1,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`                               // Replica pod name (e.g., main-012345-6789)
	BabysitterAddress string                    `protobuf:"bytes,2,opt,name=babysitter_address,json=babysitterAddress,proto3" json:"babysitter_address,omitempty"` // e.g., host:1234
	Replica           *protos.ReplicaToRegister `protobuf:"bytes,3,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

ReplicaToRegister is a request to the manager to register the given Service Weaver replica, running in the given babysitter.

func (*ReplicaToRegister) Descriptor deprecated 

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

Deprecated: Use ReplicaToRegister.ProtoReflect.Descriptor instead.

func (*ReplicaToRegister) GetBabysitterAddress 

func (x *ReplicaToRegister) GetBabysitterAddress() string

func (*ReplicaToRegister) GetPodName 

func (x *ReplicaToRegister) GetPodName() string

func (*ReplicaToRegister) GetReplica 

func (x *ReplicaToRegister) GetReplica() *protos.ReplicaToRegister

func (*ReplicaToRegister) ProtoMessage 

func (*ReplicaToRegister) ProtoMessage()

func (*ReplicaToRegister) ProtoReflect 

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

func (*ReplicaToRegister) Reset 

func (x *ReplicaToRegister) Reset()

func (*ReplicaToRegister) String 

func (x *ReplicaToRegister) String() string

type Schedule 

type Schedule struct {

	// The target function being applied.
	//
	// TODO(mwhittaker): Right now, the code is inconsistent about whether a
	// target function ends with a fraction of 1.0. Try to clean that up.
	TargetFn *TargetFn `protobuf:"bytes,1,opt,name=target_fn,json=targetFn,proto3" json:"target_fn,omitempty"`
	// The index of the current traffic fraction in target_fn. After the final
	// traffic fraction has been applied for its specified duration, index is
	// incremented to be equal to the length of the number of traffic fractions.
	// This signals that the target function has been fully applied.
	Index int64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// Total duration the current traffic fraction has been applied.
	AppliedDuration *durationpb.Duration `protobuf:"bytes,3,opt,name=applied_duration,json=appliedDuration,proto3" json:"applied_duration,omitempty"`
	// contains filtered or unexported fields
}

Schedule represents a target function being applied.

A target function is a sequence of traffic fractions and the duration for which they should be applied. A schedule represents the actual application of the traffic fractions, as we progress from one traffic fraction to the next.

func NewSchedule 

func NewSchedule(target *TargetFn) *Schedule

NewSchedule returns a new Schedule.

func (*Schedule) Descriptor deprecated 

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

Deprecated: Use Schedule.ProtoReflect.Descriptor instead.

func (*Schedule) GetAppliedDuration 

func (x *Schedule) GetAppliedDuration() *durationpb.Duration

func (*Schedule) GetIndex 

func (x *Schedule) GetIndex() int64

func (*Schedule) GetTargetFn 

func (x *Schedule) GetTargetFn() *TargetFn

func (*Schedule) ProtoMessage 

func (*Schedule) ProtoMessage()

func (*Schedule) ProtoReflect 

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

func (*Schedule) Reset 

func (x *Schedule) Reset()

func (*Schedule) String 

func (x *Schedule) String() string

type TargetFn 

type TargetFn struct {
	Fractions []*FractionSpec `protobuf:"bytes,1,rep,name=fractions,proto3" json:"fractions,omitempty"`
	// contains filtered or unexported fields
}

TargetFn is a target function that controls the traffic rollout for a given application version inside a deployment location (e.g., a cloud region).

Each entry F_i in TargetFn stores a traffic fraction that should be assigned to the application version, as well as the duration of that traffic assignment.

Traffic assignment starts with entry F_0. Once the traffic fraction in F_i has been applied for longer than the duration specified in F_i, the traffic fraction in the entry F_(i+1) is applied. This process continues until all entries in the array have been exhausted, at which point the traffic fraction of 1.0 is applied and the application version is considered "installed".

Note that the traffic fraction is considered "applied" the moment it is successfully assigned to the application version. Failed fraction assignments don't count toward the fraction duration; instead, the earlier fraction remains applied. This means that some traffic fractions may be applied for significantly longer than the specified duration (e.g., cluster becomes unreachable); the only guarantee we provide is that a given fraction will never be applied for less than a specified duration.

func (*TargetFn) Descriptor deprecated 

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

Deprecated: Use TargetFn.ProtoReflect.Descriptor instead.

func (*TargetFn) GetFractions 

func (x *TargetFn) GetFractions() []*FractionSpec

func (*TargetFn) ProtoMessage 

func (*TargetFn) ProtoMessage()

func (*TargetFn) ProtoReflect 

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

func (*TargetFn) Reset 

func (x *TargetFn) Reset()

func (*TargetFn) String 

func (x *TargetFn) String() string

type TrafficAllocation 

type TrafficAllocation struct {
	Location        string           `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`                                        // location (e.g., a cloud region)
	AppName         string           `protobuf:"bytes,2,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`                           // name of the application
	VersionId       string           `protobuf:"bytes,3,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`                     // application version id
	TrafficFraction float32          `protobuf:"fixed32,4,opt,name=traffic_fraction,json=trafficFraction,proto3" json:"traffic_fraction,omitempty"` // traffic fraction allocated for version id
	Listener        *protos.Listener `protobuf:"bytes,5,opt,name=listener,proto3" json:"listener,omitempty"`                                        // network listener
	// contains filtered or unexported fields
}

TrafficAllocation contains a traffic allocation. It is the finest granularity in terms of traffic assignment.

func (*TrafficAllocation) Descriptor deprecated 

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

Deprecated: Use TrafficAllocation.ProtoReflect.Descriptor instead.

func (*TrafficAllocation) GetAppName 

func (x *TrafficAllocation) GetAppName() string

func (*TrafficAllocation) GetListener 

func (x *TrafficAllocation) GetListener() *protos.Listener

func (*TrafficAllocation) GetLocation 

func (x *TrafficAllocation) GetLocation() string

func (*TrafficAllocation) GetTrafficFraction 

func (x *TrafficAllocation) GetTrafficFraction() float32

func (*TrafficAllocation) GetVersionId 

func (x *TrafficAllocation) GetVersionId() string

func (*TrafficAllocation) ProtoMessage 

func (*TrafficAllocation) ProtoMessage()

func (*TrafficAllocation) ProtoReflect 

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

func (*TrafficAllocation) Reset 

func (x *TrafficAllocation) Reset()

func (*TrafficAllocation) String 

func (x *TrafficAllocation) String() string

type TrafficAssignment 

type TrafficAssignment struct {
	HostAssignment map[string]*HostTrafficAssignment `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

TrafficAssignment contains a traffic assignment keyed by hostname.

func CascadeTraffic 

func CascadeTraffic(targets []*CascadeTarget) (*TrafficAssignment, error)

CascadeTraffic assigns traffic to a set of targets. For every host, a traffic fraction of 1.0 is cascaded across the versions that export the host.

For example, imagine we version v1, v2, and v3 that export hosts [a, c], [a, b, c], and [b, c] respectively. v1, v2, and v3 have desired traffic fractions of 0.5, 0.4, and 0.4. We cascade traffic between the listeners as follows: 

v1 (0.5) | v2 (0.4) | v3 (0.4)
---------+----------+---------
 a (0.6) |  a (0.4) |
         |  b (0.6) |  b (0.4)
 c (0.2) |  c (0.4) |  c (0.4)

func MergeTrafficAssignments 

func MergeTrafficAssignments(components []*TrafficAssignment) *TrafficAssignment

MergeTrafficAssignments merges the traffic assignments for each hostname across multiple components.

A component can be an application or a location (e.g., a cloud region).

At a high-level, for a given hostname H it does the following:

  • all of H's traffic allocations in each component are appended together to form the set of allocations for H in the merged set.

  • if H appears in N components, the traffic allocations for H in each component are normalized by a factor of 1/N.

The above algorithm has the property that if the traffic allocations for H were adding up to 1.0 in the individual components, they will add up to 1.0 in the merged set as well.

func (*TrafficAssignment) Descriptor deprecated 

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

Deprecated: Use TrafficAssignment.ProtoReflect.Descriptor instead.

func (*TrafficAssignment) GetHostAssignment 

func (x *TrafficAssignment) GetHostAssignment() map[string]*HostTrafficAssignment

func (*TrafficAssignment) ProtoMessage 

func (*TrafficAssignment) ProtoMessage()

func (*TrafficAssignment) ProtoReflect 

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

func (*TrafficAssignment) Reset 

func (x *TrafficAssignment) Reset()

func (*TrafficAssignment) String 

func (x *TrafficAssignment) String() string

type VersionDistributionRequest 

type VersionDistributionRequest struct {

	// Deployment information for the new application version.
	Config *config.GKEConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// Rollout information for the new application version.
	TargetFn *TargetFn `protobuf:"bytes,2,opt,name=target_fn,json=targetFn,proto3" json:"target_fn,omitempty"`
	// Unique identifier that captures the order in which the application version
	// was submitted for rollout at the controller.
	SubmissionId int64 `protobuf:"varint,3,opt,name=submission_id,json=submissionId,proto3" json:"submission_id,omitempty"`
	// contains filtered or unexported fields
}

VersionDistributionRequest is a request to the distributor to start a new application version in its deployment location.

func (*VersionDistributionRequest) Descriptor deprecated 

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

Deprecated: Use VersionDistributionRequest.ProtoReflect.Descriptor instead.

func (*VersionDistributionRequest) GetConfig 

func (x *VersionDistributionRequest) GetConfig() *config.GKEConfig

func (*VersionDistributionRequest) GetSubmissionId 

func (x *VersionDistributionRequest) GetSubmissionId() int64

func (*VersionDistributionRequest) GetTargetFn 

func (x *VersionDistributionRequest) GetTargetFn() *TargetFn

func (*VersionDistributionRequest) ProtoMessage 

func (*VersionDistributionRequest) ProtoMessage()

func (*VersionDistributionRequest) ProtoReflect 

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

func (*VersionDistributionRequest) Reset 

func (x *VersionDistributionRequest) Reset()

func (*VersionDistributionRequest) String 

func (x *VersionDistributionRequest) String() string

type VersionStateAtDistributor 

type VersionStateAtDistributor struct {
	VersionId string `protobuf:"bytes,1,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	// Last traffic fraction that was applied.
	LastTrafficFractionApplied float32 `` /* 145-byte string literal not displayed */
	// Whether the rollout has successfully completed. Note that a rollout is not
	// necessarily completed when the last traffic fraction was applied (e.g.,
	// the local gateway might have transient failures and the distributor has to
	// reapply).
	RolloutCompleted bool `protobuf:"varint,3,opt,name=rollout_completed,json=rolloutCompleted,proto3" json:"rollout_completed,omitempty"`
	// Whether the main group is deployed.
	IsDeployed bool `protobuf:"varint,4,opt,name=is_deployed,json=isDeployed,proto3" json:"is_deployed,omitempty"`
	// All known groups for this application version.
	Groups *GroupState `protobuf:"bytes,5,opt,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

VersionStateAtDistributor stores the state of an application version at a particular distributor.

func (*VersionStateAtDistributor) Descriptor deprecated 

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

Deprecated: Use VersionStateAtDistributor.ProtoReflect.Descriptor instead.

func (*VersionStateAtDistributor) GetGroups added in v0.1.3 

func (x *VersionStateAtDistributor) GetGroups() *GroupState

func (*VersionStateAtDistributor) GetIsDeployed 

func (x *VersionStateAtDistributor) GetIsDeployed() bool

func (*VersionStateAtDistributor) GetLastTrafficFractionApplied 

func (x *VersionStateAtDistributor) GetLastTrafficFractionApplied() float32

func (*VersionStateAtDistributor) GetRolloutCompleted 

func (x *VersionStateAtDistributor) GetRolloutCompleted() bool

func (*VersionStateAtDistributor) GetVersionId 

func (x *VersionStateAtDistributor) GetVersionId() string

func (*VersionStateAtDistributor) ProtoMessage 

func (*VersionStateAtDistributor) ProtoMessage()

func (*VersionStateAtDistributor) ProtoReflect 

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

func (*VersionStateAtDistributor) Reset 

func (x *VersionStateAtDistributor) Reset()

func (*VersionStateAtDistributor) String 

func (x *VersionStateAtDistributor) String() string

Source Files

View all Source files

Directories

Path Synopsis
Package controller handles the deployment of new application versions.
 Package controller handles the deployment of new application versions.
Package distributor handles the distribution of new application versions in a particular deployment location (e.g., a cloud region).
 Package distributor handles the distribution of new application versions in a particular deployment location (e.g., a cloud region).
Package managertest provides a weavertest like testing framework for testing the gke and gke-local manager.
 Package managertest provides a weavertest like testing framework for testing the gke and gke-local manager.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.