controller

type AppState struct {

	// Application versions, keyed by version id.
	Versions map[string]*AppVersionState `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AppStatus struct {

	// The app's name.
	App string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	// The status of every version of this app.
	Versions []*AppVersionStatus `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	// The rollout schedule of this app.
	ProjectedTraffic *ProjectedTraffic `protobuf:"bytes,3,opt,name=projected_traffic,json=projectedTraffic,proto3" json:"projected_traffic,omitempty"`
	// contains filtered or unexported fields
}

type AppVersionDistributorState struct {
	WaveIdx int64                       `protobuf:"varint,1,opt,name=wave_idx,json=waveIdx,proto3" json:"wave_idx,omitempty"`
	Status  AppVersionDistributorStatus `protobuf:"varint,2,opt,name=status,proto3,enum=controller.AppVersionDistributorStatus" json:"status,omitempty"`
	// All running Kubernetes ReplicaSets for this application version at the
	// distributor.
	ReplicaSets []*nanny.ReplicaSet `protobuf:"bytes,3,rep,name=replica_sets,json=replicaSets,proto3" json:"replica_sets,omitempty"`
	// contains filtered or unexported fields
}

type AppVersionDistributorStatus int32

type AppVersionState struct {
	Config          *config.GKEConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	RolloutStrategy *RolloutStrategy  `protobuf:"bytes,2,opt,name=rollout_strategy,json=rolloutStrategy,proto3" json:"rollout_strategy,omitempty"`
	// Distributors state for a given application version.
	Distributors map[string]*AppVersionDistributorState `` /* 165-byte string literal not displayed */
	// Unique identifier that captures the order in which the application version
	// was submitted for rollout at the controller.
	SubmissionId int64 `protobuf:"varint,5,opt,name=submission_id,json=submissionId,proto3" json:"submission_id,omitempty"`
	// The time when the application version was submitted to the controller.
	SubmissionTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=submission_time,json=submissionTime,proto3" json:"submission_time,omitempty"`
	// The wave idx that has been rolling out.
	WaveIdx int64 `protobuf:"varint,6,opt,name=wave_idx,json=waveIdx,proto3" json:"wave_idx,omitempty"`
	// The time when the current wave was started, or nil if rollout is done
	// (i.e., wave_idx equals the number of waves).
	TimeWaveStarted *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=time_wave_started,json=timeWaveStarted,proto3" json:"time_wave_started,omitempty"`
	// The time when the wave was successfully rolled out.
	TimeWaveRolledOut *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=time_wave_rolled_out,json=timeWaveRolledOut,proto3" json:"time_wave_rolled_out,omitempty"`
	// contains filtered or unexported fields
}

type AppVersionStatus struct {
	App            string                  `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`                                        // the app name (e.g., collatz)
	Id             string                  `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                          // the deployment id (e.g., a83903259a93)
	SubmissionId   int64                   `protobuf:"varint,3,opt,name=submission_id,json=submissionId,proto3" json:"submission_id,omitempty"` // the unique sequence number (e.g., 0, 1, 2)
	SubmissionTime *timestamppb.Timestamp  `protobuf:"bytes,4,opt,name=submission_time,json=submissionTime,proto3" json:"submission_time,omitempty"`
	GkeConfig      *config.GKEConfig       `protobuf:"bytes,5,opt,name=gke_config,json=gkeConfig,proto3" json:"gke_config,omitempty"` // GKE config for this deployment.
	Status         AppVersionStatus_Status `protobuf:"varint,7,opt,name=status,proto3,enum=controller.AppVersionStatus_Status" json:"status,omitempty"`
	ReplicaSets    []*ReplicaSetStatus     `protobuf:"bytes,8,rep,name=replica_sets,json=replicaSets,proto3" json:"replica_sets,omitempty"`
	Listeners      []*ListenerStatus       `protobuf:"bytes,9,rep,name=listeners,proto3" json:"listeners,omitempty"`
	// contains filtered or unexported fields
}

type AppVersionStatus_Status int32

type ControllerState struct {
	Applications map[string]bool              `` /* 166-byte string literal not displayed */
	Distributors map[string]*DistributorState `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DistributorState struct {

	// Distributor location.
	Location *RolloutRequest_Location `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// Latest traffic assignment for public listeners received from the
	// corresponding distributor.
	TrafficAssignment *nanny.TrafficAssignment `protobuf:"bytes,2,opt,name=traffic_assignment,json=trafficAssignment,proto3" json:"traffic_assignment,omitempty"`
	// contains filtered or unexported fields
}

type KillRequest struct {
	App string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"` // the app to kill
	// contains filtered or unexported fields
}

type ListenerStatus struct {
	Name     string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`         // listener name
	Public   bool     `protobuf:"varint,2,opt,name=public,proto3" json:"public,omitempty"`    // is the listener public?
	Hostname []string `protobuf:"bytes,3,rep,name=hostname,proto3" json:"hostname,omitempty"` // hostnames the listener is reachable at.
	// contains filtered or unexported fields
}

type ProjectedTraffic struct {
	App         string        `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	Projections []*Projection `protobuf:"bytes,2,rep,name=projections,proto3" json:"projections,omitempty"`
	// contains filtered or unexported fields
}

type Projection struct {
	Time    *timestamppb.Timestamp   `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Traffic *nanny.TrafficAssignment `protobuf:"bytes,2,opt,name=traffic,proto3" json:"traffic,omitempty"`
	// contains filtered or unexported fields
}

type ReplicaSetStatus struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                               // ReplicaSet name
	Location        string   `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`                                       // location (e.g., us-east1)
	HealthyReplicas int64    `protobuf:"varint,3,opt,name=healthy_replicas,json=healthyReplicas,proto3" json:"healthy_replicas,omitempty"` // number of healthy replicas
	TotalReplicas   int64    `protobuf:"varint,4,opt,name=total_replicas,json=totalReplicas,proto3" json:"total_replicas,omitempty"`       // number of total replicas
	Components      []string `protobuf:"bytes,5,rep,name=components,proto3" json:"components,omitempty"`                                   // active components
	// contains filtered or unexported fields
}

type RolloutRequest struct {

	// Deployment information for the application.
	Config *config.GKEConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// A list of locations to rollout the application to.
	Locations []*RolloutRequest_Location `protobuf:"bytes,3,rep,name=locations,proto3" json:"locations,omitempty"`
	// contains filtered or unexported fields
}

type RolloutRequest_Location struct {

	// A descriptive name for the location (e.g., a cloud region).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Address of the distributor that manages traffic for the application.
	DistributorAddr string `protobuf:"bytes,2,opt,name=distributor_addr,json=distributorAddr,proto3" json:"distributor_addr,omitempty"`
	// contains filtered or unexported fields
}

type RolloutStrategy struct {
	Waves []*RolloutWave `protobuf:"bytes,1,rep,name=waves,proto3" json:"waves,omitempty"`
	// contains filtered or unexported fields
}

type RolloutWave struct {

	// List of traffic target functions, keyed by location.
	TargetFunctions map[string]*nanny.TargetFn `` /* 194-byte string literal not displayed */
	// Time to wait after all the target functions have been applied before
	// declaring the wave as complete.
	WaitTime *durationpb.Duration `protobuf:"bytes,2,opt,name=wait_time,json=waitTime,proto3" json:"wait_time,omitempty"`
	// contains filtered or unexported fields
}

type Status struct {

	// The status of every app.
	Apps []*AppStatus `protobuf:"bytes,1,rep,name=apps,proto3" json:"apps,omitempty"`
	// The current public traffic assignment.
	Traffic *nanny.TrafficAssignment `protobuf:"bytes,2,opt,name=traffic,proto3" json:"traffic,omitempty"`
	// The current private traffic assignments at every location.
	PrivateTraffic []*nanny.TrafficAssignment `protobuf:"bytes,3,rep,name=private_traffic,json=privateTraffic,proto3" json:"private_traffic,omitempty"`
	// contains filtered or unexported fields
}

type StatusRequest struct {

	// Application whose status should be retrieved. If empty, the status for
	// all known applications is retrieved.
	App string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	// Application version whose status should be retrieved. If empty, the status
	// for all known application versions is retrieved.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type SubmissionId struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}