api

package
v0.0.0-...-c283e9f Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2021 License: BSD-3-Clause Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ReleaseType_name = map[int32]string{
		0: "ANY",
		1: "CODE",
		2: "CONFIG",
	}
	ReleaseType_value = map[string]int32{
		"ANY":    0,
		"CODE":   1,
		"CONFIG": 2,
	}
)

Enum value maps for ReleaseType.

View Source 
var (
	ScaleRequestState_name = map[int32]string{
		0: "SCALE_PENDING",
		1: "SCALE_CANCELLED",
		2: "SCALE_COMPLETE",
	}
	ScaleRequestState_value = map[string]int32{
		"SCALE_PENDING":   0,
		"SCALE_CANCELLED": 1,
		"SCALE_COMPLETE":  2,
	}
)

Enum value maps for ScaleRequestState.

View Source 
var (
	DeploymentStatus_name = map[int32]string{
		0: "PENDING",
		1: "FAILED",
		2: "RUNNING",
		3: "COMPLETE",
	}
	DeploymentStatus_value = map[string]int32{
		"PENDING":  0,
		"FAILED":   1,
		"RUNNING":  2,
		"COMPLETE": 3,
	}
)

Enum value maps for DeploymentStatus.

View Source 
var (
	StatusResponse_Code_name = map[int32]string{
		0: "HEALTHY",
		1: "UNHEALTHY",
	}
	StatusResponse_Code_value = map[string]int32{
		"HEALTHY":   0,
		"UNHEALTHY": 1,
	}
)

Enum value maps for StatusResponse_Code.

View Source 
var (
	LabelFilter_Expression_Operator_name = map[int32]string{
		0: "OP_IN",
		1: "OP_NOT_IN",
		2: "OP_EXISTS",
		3: "OP_NOT_EXISTS",
	}
	LabelFilter_Expression_Operator_value = map[string]int32{
		"OP_IN":         0,
		"OP_NOT_IN":     1,
		"OP_EXISTS":     2,
		"OP_NOT_EXISTS": 3,
	}
)

Enum value maps for LabelFilter_Expression_Operator.

View Source 
var (
	DeploymentEvent_JobState_name = map[int32]string{
		0: "PENDING",
		1: "BLOCKED",
		2: "STARTING",
		3: "UP",
		5: "STOPPING",
		6: "DOWN",
		7: "CRASHED",
		8: "FAILED",
	}
	DeploymentEvent_JobState_value = map[string]int32{
		"PENDING":  0,
		"BLOCKED":  1,
		"STARTING": 2,
		"UP":       3,
		"STOPPING": 5,
		"DOWN":     6,
		"CRASHED":  7,
		"FAILED":   8,
	}
)

Enum value maps for DeploymentEvent_JobState.

View Source 
var File_controller_proto protoreflect.FileDescriptor

Functions

func MatchLabelFilters 

func MatchLabelFilters(labels map[string]string, labelFilters []*LabelFilter) bool

func NewControllerAllowedDevices 

func NewControllerAllowedDevices(from []*LibContainerDevice) []*host.Device

func NewControllerDeploymentProcesses 

func NewControllerDeploymentProcesses(from map[string]int32) map[string]int

func NewControllerDeploymentTags 

func NewControllerDeploymentTags(from map[string]*DeploymentProcessTags) map[string]map[string]string

func NewControllerHealthCheck 

func NewControllerHealthCheck(from *HostHealthCheck) *host.HealthCheck

func NewControllerLabelFilter 

func NewControllerLabelFilter(from *LabelFilter) ct.LabelFilter

func NewControllerLabelFilterExpression 

func NewControllerLabelFilterExpression(from *LabelFilter_Expression) *ct.LabelFilterExpression

func NewControllerLabelFilters 

func NewControllerLabelFilters(from []*LabelFilter) []ct.LabelFilter

func NewControllerMounts 

func NewControllerMounts(from []*HostMount) []host.Mount

func NewControllerPorts 

func NewControllerPorts(from []*Port) []ct.Port

func NewControllerProcesses 

func NewControllerProcesses(from map[string]*ProcessType) map[string]ct.ProcessType

func NewControllerResources 

func NewControllerResources(from map[string]*HostResourceSpec) resource.Resources

func NewControllerService 

func NewControllerService(from *HostService) *host.Service

func NewControllerVolumes 

func NewControllerVolumes(from []*VolumeReq) []ct.VolumeReq

func NewDeploymentProcesses 

func NewDeploymentProcesses(from map[string]int) map[string]int32

func NewDeploymentTags 

func NewDeploymentTags(from map[string]map[string]string) map[string]*DeploymentProcessTags

func NewDuration 

func NewDuration(d *time.Duration) *durpb.Duration

func NewError 

func NewError(err error, message string, args ...interface{}) error

func NewGoDuration 

func NewGoDuration(d *durpb.Duration) *time.Duration

func NewGoTimestamp 

func NewGoTimestamp(t *tspb.Timestamp) *time.Time

func NewProcesses 

func NewProcesses(from map[string]ct.ProcessType) map[string]*ProcessType

func NewResources 

func NewResources(from resource.Resources) map[string]*HostResourceSpec

func NewTimestamp 

func NewTimestamp(t *time.Time) *tspb.Timestamp

func ParseIDFromName 

func ParseIDFromName(name string, resource string) string

func ParseIDsFromNameFilters 

func ParseIDsFromNameFilters(nameFilters []string, resource string) []string

func RegisterControllerServer 

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

func WithAuthKey 

func WithAuthKey(key string) grpc.DialOption

Types

type AccessToken 

type AccessToken struct {
	ClientId   string               `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	UserId     string               `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	UserEmail  string               `protobuf:"bytes,3,opt,name=user_email,json=userEmail,proto3" json:"user_email,omitempty"`
	IssueTime  *timestamp.Timestamp `protobuf:"bytes,4,opt,name=issue_time,json=issueTime,proto3" json:"issue_time,omitempty"`
	ExpireTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	// contains filtered or unexported fields
}

func (*AccessToken) Descriptor deprecated 

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

Deprecated: Use AccessToken.ProtoReflect.Descriptor instead.

func (*AccessToken) GetClientId 

func (x *AccessToken) GetClientId() string

func (*AccessToken) GetExpireTime 

func (x *AccessToken) GetExpireTime() *timestamp.Timestamp

func (*AccessToken) GetIssueTime 

func (x *AccessToken) GetIssueTime() *timestamp.Timestamp

func (*AccessToken) GetUserEmail 

func (x *AccessToken) GetUserEmail() string

func (*AccessToken) GetUserId 

func (x *AccessToken) GetUserId() string

func (*AccessToken) ProtoMessage 

func (*AccessToken) ProtoMessage()

func (*AccessToken) ProtoReflect 

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

func (*AccessToken) Reset 

func (x *AccessToken) Reset()

func (*AccessToken) String 

func (x *AccessToken) String() string

type App 

type App struct {

	// name = "apps/APP_ID"
	Name          string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DisplayName   string            `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	Labels        map[string]string `` /* 153-byte string literal not displayed */
	DeployTimeout int32             `protobuf:"varint,4,opt,name=deploy_timeout,json=deployTimeout,proto3" json:"deploy_timeout,omitempty"`
	Strategy      string            `protobuf:"bytes,5,opt,name=strategy,proto3" json:"strategy,omitempty"`
	// release = Release.name
	Release    string               `protobuf:"bytes,6,opt,name=release,proto3" json:"release,omitempty"`
	CreateTime *timestamp.Timestamp `protobuf:"bytes,7,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	UpdateTime *timestamp.Timestamp `protobuf:"bytes,8,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	DeleteTime *timestamp.Timestamp `protobuf:"bytes,9,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
	// contains filtered or unexported fields
}

func NewApp 

func NewApp(a *ct.App) *App

func (*App) ControllerType 

func (a *App) ControllerType() *ct.App

func (*App) Descriptor deprecated 

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

Deprecated: Use App.ProtoReflect.Descriptor instead.

func (*App) GetCreateTime 

func (x *App) GetCreateTime() *timestamp.Timestamp

func (*App) GetDeleteTime 

func (x *App) GetDeleteTime() *timestamp.Timestamp

func (*App) GetDeployTimeout 

func (x *App) GetDeployTimeout() int32

func (*App) GetDisplayName 

func (x *App) GetDisplayName() string

func (*App) GetLabels 

func (x *App) GetLabels() map[string]string

func (*App) GetName 

func (x *App) GetName() string

func (*App) GetRelease 

func (x *App) GetRelease() string

func (*App) GetStrategy 

func (x *App) GetStrategy() string

func (*App) GetUpdateTime 

func (x *App) GetUpdateTime() *timestamp.Timestamp

func (*App) ProtoMessage 

func (*App) ProtoMessage()

func (*App) ProtoReflect 

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

func (*App) Reset 

func (x *App) Reset()

func (*App) String 

func (x *App) String() string

type ControllerClient 

type ControllerClient interface {
	Status(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*StatusResponse, error)
	StreamApps(ctx context.Context, in *StreamAppsRequest, opts ...grpc.CallOption) (Controller_StreamAppsClient, error)
	StreamReleases(ctx context.Context, in *StreamReleasesRequest, opts ...grpc.CallOption) (Controller_StreamReleasesClient, error)
	StreamScales(ctx context.Context, in *StreamScalesRequest, opts ...grpc.CallOption) (Controller_StreamScalesClient, error)
	StreamDeployments(ctx context.Context, in *StreamDeploymentsRequest, opts ...grpc.CallOption) (Controller_StreamDeploymentsClient, error)
	UpdateApp(ctx context.Context, in *UpdateAppRequest, opts ...grpc.CallOption) (*App, error)
	CreateScale(ctx context.Context, in *CreateScaleRequest, opts ...grpc.CallOption) (*ScaleRequest, error)
	CreateRelease(ctx context.Context, in *CreateReleaseRequest, opts ...grpc.CallOption) (*Release, error)
	CreateDeployment(ctx context.Context, in *CreateDeploymentRequest, opts ...grpc.CallOption) (Controller_CreateDeploymentClient, error)
}

ControllerClient is the client API for Controller service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerClient 

func NewControllerClient(cc grpc.ClientConnInterface) ControllerClient

type ControllerServer 

type ControllerServer interface {
	Status(context.Context, *empty.Empty) (*StatusResponse, error)
	StreamApps(*StreamAppsRequest, Controller_StreamAppsServer) error
	StreamReleases(*StreamReleasesRequest, Controller_StreamReleasesServer) error
	StreamScales(*StreamScalesRequest, Controller_StreamScalesServer) error
	StreamDeployments(*StreamDeploymentsRequest, Controller_StreamDeploymentsServer) error
	UpdateApp(context.Context, *UpdateAppRequest) (*App, error)
	CreateScale(context.Context, *CreateScaleRequest) (*ScaleRequest, error)
	CreateRelease(context.Context, *CreateReleaseRequest) (*Release, error)
	CreateDeployment(*CreateDeploymentRequest, Controller_CreateDeploymentServer) error
}

ControllerServer is the server API for Controller service.

type Controller_CreateDeploymentClient 

type Controller_CreateDeploymentClient interface {
	Recv() (*DeploymentEvent, error)
	grpc.ClientStream
}

type Controller_CreateDeploymentServer 

type Controller_CreateDeploymentServer interface {
	Send(*DeploymentEvent) error
	grpc.ServerStream
}

type Controller_StreamAppsClient 

type Controller_StreamAppsClient interface {
	Recv() (*StreamAppsResponse, error)
	grpc.ClientStream
}

type Controller_StreamAppsServer 

type Controller_StreamAppsServer interface {
	Send(*StreamAppsResponse) error
	grpc.ServerStream
}

type Controller_StreamDeploymentsClient 

type Controller_StreamDeploymentsClient interface {
	Recv() (*StreamDeploymentsResponse, error)
	grpc.ClientStream
}

type Controller_StreamDeploymentsServer 

type Controller_StreamDeploymentsServer interface {
	Send(*StreamDeploymentsResponse) error
	grpc.ServerStream
}

type Controller_StreamReleasesClient 

type Controller_StreamReleasesClient interface {
	Recv() (*StreamReleasesResponse, error)
	grpc.ClientStream
}

type Controller_StreamReleasesServer 

type Controller_StreamReleasesServer interface {
	Send(*StreamReleasesResponse) error
	grpc.ServerStream
}

type Controller_StreamScalesClient 

type Controller_StreamScalesClient interface {
	Recv() (*StreamScalesResponse, error)
	grpc.ClientStream
}

type Controller_StreamScalesServer 

type Controller_StreamScalesServer interface {
	Send(*StreamScalesResponse) error
	grpc.ServerStream
}

type CreateDeploymentRequest 

type CreateDeploymentRequest struct {

	// parent = "apps/APP_ID/releases/RELEASE_ID"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// optional scale request
	ScaleRequest *CreateScaleRequest `protobuf:"bytes,2,opt,name=scale_request,json=scaleRequest,proto3" json:"scale_request,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDeploymentRequest) Descriptor deprecated 

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

Deprecated: Use CreateDeploymentRequest.ProtoReflect.Descriptor instead.

func (*CreateDeploymentRequest) GetParent 

func (x *CreateDeploymentRequest) GetParent() string

func (*CreateDeploymentRequest) GetScaleRequest 

func (x *CreateDeploymentRequest) GetScaleRequest() *CreateScaleRequest

func (*CreateDeploymentRequest) ProtoMessage 

func (*CreateDeploymentRequest) ProtoMessage()

func (*CreateDeploymentRequest) ProtoReflect 

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

func (*CreateDeploymentRequest) Reset 

func (x *CreateDeploymentRequest) Reset()

func (*CreateDeploymentRequest) String 

func (x *CreateDeploymentRequest) String() string

type CreateReleaseRequest 

type CreateReleaseRequest struct {

	// parent = "apps/APP_ID"
	Parent    string   `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Release   *Release `protobuf:"bytes,2,opt,name=release,proto3" json:"release,omitempty"`
	RequestId string   `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReleaseRequest) Descriptor deprecated 

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

Deprecated: Use CreateReleaseRequest.ProtoReflect.Descriptor instead.

func (*CreateReleaseRequest) GetParent 

func (x *CreateReleaseRequest) GetParent() string

func (*CreateReleaseRequest) GetRelease 

func (x *CreateReleaseRequest) GetRelease() *Release

func (*CreateReleaseRequest) GetRequestId 

func (x *CreateReleaseRequest) GetRequestId() string

func (*CreateReleaseRequest) ProtoMessage 

func (*CreateReleaseRequest) ProtoMessage()

func (*CreateReleaseRequest) ProtoReflect 

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

func (*CreateReleaseRequest) Reset 

func (x *CreateReleaseRequest) Reset()

func (*CreateReleaseRequest) String 

func (x *CreateReleaseRequest) String() string

type CreateScaleRequest 

type CreateScaleRequest struct {

	// parent = "apps/APP_ID/releases/RELEASE_ID"
	Parent    string                            `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Processes map[string]int32                  `` /* 160-byte string literal not displayed */
	Tags      map[string]*DeploymentProcessTags `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateScaleRequest) ControllerType 

func (csr *CreateScaleRequest) ControllerType() *ct.ScaleRequest

func (*CreateScaleRequest) Descriptor deprecated 

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

Deprecated: Use CreateScaleRequest.ProtoReflect.Descriptor instead.

func (*CreateScaleRequest) GetParent 

func (x *CreateScaleRequest) GetParent() string

func (*CreateScaleRequest) GetProcesses 

func (x *CreateScaleRequest) GetProcesses() map[string]int32

func (*CreateScaleRequest) GetTags 

func (x *CreateScaleRequest) GetTags() map[string]*DeploymentProcessTags

func (*CreateScaleRequest) ProtoMessage 

func (*CreateScaleRequest) ProtoMessage()

func (*CreateScaleRequest) ProtoReflect 

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

func (*CreateScaleRequest) Reset 

func (x *CreateScaleRequest) Reset()

func (*CreateScaleRequest) String 

func (x *CreateScaleRequest) String() string

type DeploymentEvent 

type DeploymentEvent struct {

	// parent = "apps/APP_ID/deployments/DEPLOYMENT_ID"
	Parent     string                   `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	JobType    string                   `protobuf:"bytes,2,opt,name=job_type,json=jobType,proto3" json:"job_type,omitempty"`
	JobState   DeploymentEvent_JobState `` /* 129-byte string literal not displayed */
	Error      string                   `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	CreateTime *timestamp.Timestamp     `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentEvent) Descriptor deprecated 

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

Deprecated: Use DeploymentEvent.ProtoReflect.Descriptor instead.

func (*DeploymentEvent) GetCreateTime 

func (x *DeploymentEvent) GetCreateTime() *timestamp.Timestamp

func (*DeploymentEvent) GetError 

func (x *DeploymentEvent) GetError() string

func (*DeploymentEvent) GetJobState 

func (x *DeploymentEvent) GetJobState() DeploymentEvent_JobState

func (*DeploymentEvent) GetJobType 

func (x *DeploymentEvent) GetJobType() string

func (*DeploymentEvent) GetParent 

func (x *DeploymentEvent) GetParent() string

func (*DeploymentEvent) ProtoMessage 

func (*DeploymentEvent) ProtoMessage()

func (*DeploymentEvent) ProtoReflect 

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

func (*DeploymentEvent) Reset 

func (x *DeploymentEvent) Reset()

func (*DeploymentEvent) String 

func (x *DeploymentEvent) String() string

type DeploymentEvent_JobState 

type DeploymentEvent_JobState int32
const (
	DeploymentEvent_PENDING  DeploymentEvent_JobState = 0
	DeploymentEvent_BLOCKED  DeploymentEvent_JobState = 1
	DeploymentEvent_STARTING DeploymentEvent_JobState = 2
	DeploymentEvent_UP       DeploymentEvent_JobState = 3
	DeploymentEvent_STOPPING DeploymentEvent_JobState = 5
	DeploymentEvent_DOWN     DeploymentEvent_JobState = 6
	// CRASHED and FAILURE are no longer valid job states,
	// but we still need to handle them in case they are set by old
	// schedulers still using the legacy code.
	DeploymentEvent_CRASHED DeploymentEvent_JobState = 7
	DeploymentEvent_FAILED  DeploymentEvent_JobState = 8
)

func NewJobState 

func NewJobState(from ct.JobState) DeploymentEvent_JobState

func (DeploymentEvent_JobState) Descriptor 

func (DeploymentEvent_JobState) Descriptor() protoreflect.EnumDescriptor

func (DeploymentEvent_JobState) Enum 

func (x DeploymentEvent_JobState) Enum() *DeploymentEvent_JobState

func (DeploymentEvent_JobState) EnumDescriptor deprecated 

func (DeploymentEvent_JobState) EnumDescriptor() ([]byte, []int)

Deprecated: Use DeploymentEvent_JobState.Descriptor instead.

func (DeploymentEvent_JobState) Number 

func (x DeploymentEvent_JobState) Number() protoreflect.EnumNumber

func (DeploymentEvent_JobState) String 

func (x DeploymentEvent_JobState) String() string

func (DeploymentEvent_JobState) Type 

func (DeploymentEvent_JobState) Type() protoreflect.EnumType

type DeploymentProcessTags 

type DeploymentProcessTags struct {
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeploymentProcessTags) Descriptor deprecated 

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

Deprecated: Use DeploymentProcessTags.ProtoReflect.Descriptor instead.

func (*DeploymentProcessTags) GetTags 

func (x *DeploymentProcessTags) GetTags() map[string]string

func (*DeploymentProcessTags) ProtoMessage 

func (*DeploymentProcessTags) ProtoMessage()

func (*DeploymentProcessTags) ProtoReflect 

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

func (*DeploymentProcessTags) Reset 

func (x *DeploymentProcessTags) Reset()

func (*DeploymentProcessTags) String 

func (x *DeploymentProcessTags) String() string

type DeploymentStatus 

type DeploymentStatus int32
const (
	DeploymentStatus_PENDING  DeploymentStatus = 0
	DeploymentStatus_FAILED   DeploymentStatus = 1
	DeploymentStatus_RUNNING  DeploymentStatus = 2
	DeploymentStatus_COMPLETE DeploymentStatus = 3
)

func NewDeploymentStatus 

func NewDeploymentStatus(from string) DeploymentStatus

func (DeploymentStatus) ControllerType 

func (s DeploymentStatus) ControllerType() string

func (DeploymentStatus) Descriptor 

func (DeploymentStatus) Descriptor() protoreflect.EnumDescriptor

func (DeploymentStatus) Enum 

func (x DeploymentStatus) Enum() *DeploymentStatus

func (DeploymentStatus) EnumDescriptor deprecated 

func (DeploymentStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use DeploymentStatus.Descriptor instead.

func (DeploymentStatus) Number 

func (x DeploymentStatus) Number() protoreflect.EnumNumber

func (DeploymentStatus) String 

func (x DeploymentStatus) String() string

func (DeploymentStatus) Type 

func (DeploymentStatus) Type() protoreflect.EnumType

type ExpandedDeployment 

type ExpandedDeployment struct {

	// name = "apps/APP_ID/deployments/DEPLOYMENT_ID"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// old_release = Release.name
	OldRelease *Release `protobuf:"bytes,3,opt,name=old_release,json=oldRelease,proto3" json:"old_release,omitempty"`
	// new_release = Release.name
	NewRelease    *Release                          `protobuf:"bytes,4,opt,name=new_release,json=newRelease,proto3" json:"new_release,omitempty"`
	Type          ReleaseType                       `protobuf:"varint,5,opt,name=type,proto3,enum=flynn.api.v1.ReleaseType" json:"type,omitempty"`
	Strategy      string                            `protobuf:"bytes,6,opt,name=strategy,proto3" json:"strategy,omitempty"`
	Status        DeploymentStatus                  `protobuf:"varint,7,opt,name=status,proto3,enum=flynn.api.v1.DeploymentStatus" json:"status,omitempty"`
	Processes     map[string]int32                  `` /* 160-byte string literal not displayed */
	Tags          map[string]*DeploymentProcessTags `` /* 149-byte string literal not displayed */
	DeployTimeout int32                             `protobuf:"varint,10,opt,name=deploy_timeout,json=deployTimeout,proto3" json:"deploy_timeout,omitempty"`
	CreateTime    *timestamp.Timestamp              `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	ExpireTime    *timestamp.Timestamp              `protobuf:"bytes,12,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	EndTime       *timestamp.Timestamp              `protobuf:"bytes,13,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func NewExpandedDeployment 

func NewExpandedDeployment(from *ct.ExpandedDeployment) *ExpandedDeployment

func (*ExpandedDeployment) Descriptor deprecated 

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

Deprecated: Use ExpandedDeployment.ProtoReflect.Descriptor instead.

func (*ExpandedDeployment) GetCreateTime 

func (x *ExpandedDeployment) GetCreateTime() *timestamp.Timestamp

func (*ExpandedDeployment) GetDeployTimeout 

func (x *ExpandedDeployment) GetDeployTimeout() int32

func (*ExpandedDeployment) GetEndTime 

func (x *ExpandedDeployment) GetEndTime() *timestamp.Timestamp

func (*ExpandedDeployment) GetExpireTime 

func (x *ExpandedDeployment) GetExpireTime() *timestamp.Timestamp

func (*ExpandedDeployment) GetName 

func (x *ExpandedDeployment) GetName() string

func (*ExpandedDeployment) GetNewRelease 

func (x *ExpandedDeployment) GetNewRelease() *Release

func (*ExpandedDeployment) GetOldRelease 

func (x *ExpandedDeployment) GetOldRelease() *Release

func (*ExpandedDeployment) GetProcesses 

func (x *ExpandedDeployment) GetProcesses() map[string]int32

func (*ExpandedDeployment) GetStatus 

func (x *ExpandedDeployment) GetStatus() DeploymentStatus

func (*ExpandedDeployment) GetStrategy 

func (x *ExpandedDeployment) GetStrategy() string

func (*ExpandedDeployment) GetTags 

func (x *ExpandedDeployment) GetTags() map[string]*DeploymentProcessTags

func (*ExpandedDeployment) GetType 

func (x *ExpandedDeployment) GetType() ReleaseType

func (*ExpandedDeployment) ProtoMessage 

func (*ExpandedDeployment) ProtoMessage()

func (*ExpandedDeployment) ProtoReflect 

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

func (*ExpandedDeployment) Reset 

func (x *ExpandedDeployment) Reset()

func (*ExpandedDeployment) String 

func (x *ExpandedDeployment) String() string

type HostHealthCheck 

type HostHealthCheck struct {

	// Type is one of tcp, http, https
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Interval is the time to wait between checks after the service has been
	// marked as up. It defaults to two seconds.
	Interval *duration.Duration `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// Threshold is the number of consecutive checks of the same status before
	// a service will be marked as up or down after coming up for the first
	// time. It defaults to 2.
	Threshold int32 `protobuf:"varint,4,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// If KillDown is true, the job will be killed if the service goes down (or
	// does not come up)
	KillDown bool `protobuf:"varint,5,opt,name=kill_down,json=killDown,proto3" json:"kill_down,omitempty"`
	// StartTimeout is the maximum duration that a service can take to come up
	// for the first time if KillDown is true. It defaults to ten seconds.
	StartTimeout *duration.Duration `protobuf:"bytes,6,opt,name=start_timeout,json=startTimeout,proto3" json:"start_timeout,omitempty"`
	// Extra optional config fields for http/https checks
	Path   string `protobuf:"bytes,7,opt,name=path,proto3" json:"path,omitempty"`
	Host   string `protobuf:"bytes,8,opt,name=host,proto3" json:"host,omitempty"`
	Match  string `protobuf:"bytes,9,opt,name=match,proto3" json:"match,omitempty"`
	Status int32  `protobuf:"varint,10,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

See github.com/flynn/flynn/host/types Mount

func NewHealthCheck 

func NewHealthCheck(from *host.HealthCheck) *HostHealthCheck

func (*HostHealthCheck) Descriptor deprecated 

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

Deprecated: Use HostHealthCheck.ProtoReflect.Descriptor instead.

func (*HostHealthCheck) GetHost 

func (x *HostHealthCheck) GetHost() string

func (*HostHealthCheck) GetInterval 

func (x *HostHealthCheck) GetInterval() *duration.Duration

func (*HostHealthCheck) GetKillDown 

func (x *HostHealthCheck) GetKillDown() bool

func (*HostHealthCheck) GetMatch 

func (x *HostHealthCheck) GetMatch() string

func (*HostHealthCheck) GetPath 

func (x *HostHealthCheck) GetPath() string

func (*HostHealthCheck) GetStartTimeout 

func (x *HostHealthCheck) GetStartTimeout() *duration.Duration

func (*HostHealthCheck) GetStatus 

func (x *HostHealthCheck) GetStatus() int32

func (*HostHealthCheck) GetThreshold 

func (x *HostHealthCheck) GetThreshold() int32

func (*HostHealthCheck) GetType 

func (x *HostHealthCheck) GetType() string

func (*HostHealthCheck) ProtoMessage 

func (*HostHealthCheck) ProtoMessage()

func (*HostHealthCheck) ProtoReflect 

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

func (*HostHealthCheck) Reset 

func (x *HostHealthCheck) Reset()

func (*HostHealthCheck) String 

func (x *HostHealthCheck) String() string

type HostMount 

type HostMount struct {
	Location  string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	Target    string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Writeable bool   `protobuf:"varint,3,opt,name=writeable,proto3" json:"writeable,omitempty"`
	Device    string `protobuf:"bytes,4,opt,name=device,proto3" json:"device,omitempty"`
	Data      string `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	Flags     int32  `protobuf:"varint,6,opt,name=flags,proto3" json:"flags,omitempty"`
	// contains filtered or unexported fields
}

See github.com/flynn/flynn/host/types Mount

func NewMounts 

func NewMounts(from []host.Mount) []*HostMount

func (*HostMount) Descriptor deprecated 

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

Deprecated: Use HostMount.ProtoReflect.Descriptor instead.

func (*HostMount) GetData 

func (x *HostMount) GetData() string

func (*HostMount) GetDevice 

func (x *HostMount) GetDevice() string

func (*HostMount) GetFlags 

func (x *HostMount) GetFlags() int32

func (*HostMount) GetLocation 

func (x *HostMount) GetLocation() string

func (*HostMount) GetTarget 

func (x *HostMount) GetTarget() string

func (*HostMount) GetWriteable 

func (x *HostMount) GetWriteable() bool

func (*HostMount) ProtoMessage 

func (*HostMount) ProtoMessage()

func (*HostMount) ProtoReflect 

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

func (*HostMount) Reset 

func (x *HostMount) Reset()

func (*HostMount) String 

func (x *HostMount) String() string

type HostResourceSpec 

type HostResourceSpec struct {

	// Request, if set, is the amount of resource a job expects to consume,
	// so the job should only be placed on a host with at least this amount
	// of resource available, and once scheduled this amount of resource
	// should then be unavailable on the given host.
	Request int64 `protobuf:"varint,1,opt,name=request,proto3" json:"request,omitempty"`
	// Limit, if set, is an upper limit on the amount of resource a job can
	// consume, the outcome of hitting this limit being implementation
	// defined (e.g. a system error, throttling, catchable / uncatchable
	// signals etc.)
	Limit int64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

See github.com/flynn/flynn/host/resource Spec

func (*HostResourceSpec) Descriptor deprecated 

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

Deprecated: Use HostResourceSpec.ProtoReflect.Descriptor instead.

func (*HostResourceSpec) GetLimit 

func (x *HostResourceSpec) GetLimit() int64

func (*HostResourceSpec) GetRequest 

func (x *HostResourceSpec) GetRequest() int64

func (*HostResourceSpec) ProtoMessage 

func (*HostResourceSpec) ProtoMessage()

func (*HostResourceSpec) ProtoReflect 

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

func (*HostResourceSpec) Reset 

func (x *HostResourceSpec) Reset()

func (*HostResourceSpec) String 

func (x *HostResourceSpec) String() string

type HostService 

type HostService struct {
	DisplayName string `protobuf:"bytes,1,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Create the service in service discovery
	Create bool             `protobuf:"varint,2,opt,name=create,proto3" json:"create,omitempty"`
	Check  *HostHealthCheck `protobuf:"bytes,3,opt,name=check,proto3" json:"check,omitempty"`
	// contains filtered or unexported fields
}

See github.com/flynn/flynn/host/types Mount

func NewService 

func NewService(from *host.Service) *HostService

func (*HostService) Descriptor deprecated 

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

Deprecated: Use HostService.ProtoReflect.Descriptor instead.

func (*HostService) GetCheck 

func (x *HostService) GetCheck() *HostHealthCheck

func (*HostService) GetCreate 

func (x *HostService) GetCreate() bool

func (*HostService) GetDisplayName 

func (x *HostService) GetDisplayName() string

func (*HostService) ProtoMessage 

func (*HostService) ProtoMessage()

func (*HostService) ProtoReflect 

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

func (*HostService) Reset 

func (x *HostService) Reset()

func (*HostService) String 

func (x *HostService) String() string

type LabelFilter 

type LabelFilter struct {

	// expressions are ANDed together.
	Expressions []*LabelFilter_Expression `protobuf:"bytes,1,rep,name=expressions,proto3" json:"expressions,omitempty"`
	// contains filtered or unexported fields
}

func (*LabelFilter) Descriptor deprecated 

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

Deprecated: Use LabelFilter.ProtoReflect.Descriptor instead.

func (*LabelFilter) GetExpressions 

func (x *LabelFilter) GetExpressions() []*LabelFilter_Expression

func (*LabelFilter) Match 

func (f *LabelFilter) Match(labels map[string]string) bool

func (*LabelFilter) ProtoMessage 

func (*LabelFilter) ProtoMessage()

func (*LabelFilter) ProtoReflect 

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

func (*LabelFilter) Reset 

func (x *LabelFilter) Reset()

func (*LabelFilter) String 

func (x *LabelFilter) String() string

type LabelFilter_Expression 

type LabelFilter_Expression struct {
	Key    string                          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Op     LabelFilter_Expression_Operator `protobuf:"varint,2,opt,name=op,proto3,enum=flynn.api.v1.LabelFilter_Expression_Operator" json:"op,omitempty"`
	Values []string                        `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LabelFilter_Expression) Descriptor deprecated 

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

Deprecated: Use LabelFilter_Expression.ProtoReflect.Descriptor instead.

func (*LabelFilter_Expression) GetKey 

func (x *LabelFilter_Expression) GetKey() string

func (*LabelFilter_Expression) GetOp 

func (x *LabelFilter_Expression) GetOp() LabelFilter_Expression_Operator

func (*LabelFilter_Expression) GetValues 

func (x *LabelFilter_Expression) GetValues() []string

func (*LabelFilter_Expression) Match 

func (e *LabelFilter_Expression) Match(labels map[string]string) bool

func (*LabelFilter_Expression) ProtoMessage 

func (*LabelFilter_Expression) ProtoMessage()

func (*LabelFilter_Expression) ProtoReflect 

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

func (*LabelFilter_Expression) Reset 

func (x *LabelFilter_Expression) Reset()

func (*LabelFilter_Expression) String 

func (x *LabelFilter_Expression) String() string

type LabelFilter_Expression_Operator 

type LabelFilter_Expression_Operator int32
const (
	// OP_IN matches if there is a label entry where the value is in the given
	// values for the given key
	LabelFilter_Expression_OP_IN LabelFilter_Expression_Operator = 0
	// OP_NOT_IN matches if there are no label entries where the value is in
	// the given values for the given key
	LabelFilter_Expression_OP_NOT_IN LabelFilter_Expression_Operator = 1
	// OP_EXISTS matches if there is a label entry with the given key (it is
	// an error to provide a value)
	LabelFilter_Expression_OP_EXISTS LabelFilter_Expression_Operator = 2
	// OP_NOT_EXISTS matches if there are no label entries for the given key
	// (it is an error to provide a value)
	LabelFilter_Expression_OP_NOT_EXISTS LabelFilter_Expression_Operator = 3
)

func (LabelFilter_Expression_Operator) Descriptor 

func (LabelFilter_Expression_Operator) Descriptor() protoreflect.EnumDescriptor

func (LabelFilter_Expression_Operator) Enum 

func (x LabelFilter_Expression_Operator) Enum() *LabelFilter_Expression_Operator

func (LabelFilter_Expression_Operator) EnumDescriptor deprecated 

func (LabelFilter_Expression_Operator) EnumDescriptor() ([]byte, []int)

Deprecated: Use LabelFilter_Expression_Operator.Descriptor instead.

func (LabelFilter_Expression_Operator) Number 

func (x LabelFilter_Expression_Operator) Number() protoreflect.EnumNumber

func (LabelFilter_Expression_Operator) String 

func (x LabelFilter_Expression_Operator) String() string

func (LabelFilter_Expression_Operator) Type 

func (LabelFilter_Expression_Operator) Type() protoreflect.EnumType

type LibContainerDevice 

type LibContainerDevice struct {

	// Device type, block, char, etc.
	Type int32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	// Path to the device.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Major is the device's major number.
	Major int64 `protobuf:"varint,3,opt,name=major,proto3" json:"major,omitempty"`
	// Minor is the device's minor number.
	Minor int64 `protobuf:"varint,4,opt,name=minor,proto3" json:"minor,omitempty"`
	// Cgroup permissions format, rwm.
	Permissions string `protobuf:"bytes,5,opt,name=permissions,proto3" json:"permissions,omitempty"`
	// FileMode permission bits for the device.
	FileMode uint32 `protobuf:"varint,6,opt,name=file_mode,json=fileMode,proto3" json:"file_mode,omitempty"`
	// Uid of the device.
	Uid uint32 `protobuf:"varint,7,opt,name=uid,proto3" json:"uid,omitempty"`
	// Gid of the device.
	Gid uint32 `protobuf:"varint,8,opt,name=gid,proto3" json:"gid,omitempty"`
	// Write the file to the allowed list
	Allow bool `protobuf:"varint,9,opt,name=allow,proto3" json:"allow,omitempty"`
	// contains filtered or unexported fields
}

See github.com/opencontainers/runc/libcontainer/configs Device

func NewAllowedDevices 

func NewAllowedDevices(from []*host.Device) []*LibContainerDevice

func (*LibContainerDevice) Descriptor deprecated 

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

Deprecated: Use LibContainerDevice.ProtoReflect.Descriptor instead.

func (*LibContainerDevice) GetAllow 

func (x *LibContainerDevice) GetAllow() bool

func (*LibContainerDevice) GetFileMode 

func (x *LibContainerDevice) GetFileMode() uint32

func (*LibContainerDevice) GetGid 

func (x *LibContainerDevice) GetGid() uint32

func (*LibContainerDevice) GetMajor 

func (x *LibContainerDevice) GetMajor() int64

func (*LibContainerDevice) GetMinor 

func (x *LibContainerDevice) GetMinor() int64

func (*LibContainerDevice) GetPath 

func (x *LibContainerDevice) GetPath() string

func (*LibContainerDevice) GetPermissions 

func (x *LibContainerDevice) GetPermissions() string

func (*LibContainerDevice) GetType 

func (x *LibContainerDevice) GetType() int32

func (*LibContainerDevice) GetUid 

func (x *LibContainerDevice) GetUid() uint32

func (*LibContainerDevice) ProtoMessage 

func (*LibContainerDevice) ProtoMessage()

func (*LibContainerDevice) ProtoReflect 

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

func (*LibContainerDevice) Reset 

func (x *LibContainerDevice) Reset()

func (*LibContainerDevice) String 

func (x *LibContainerDevice) String() string

type Port 

type Port struct {
	Port    int32        `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	Proto   string       `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
	Service *HostService `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func NewPorts 

func NewPorts(from []ct.Port) []*Port

func (*Port) Descriptor deprecated 

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

Deprecated: Use Port.ProtoReflect.Descriptor instead.

func (*Port) GetPort 

func (x *Port) GetPort() int32

func (*Port) GetProto 

func (x *Port) GetProto() string

func (*Port) GetService 

func (x *Port) GetService() *HostService

func (*Port) ProtoMessage 

func (*Port) ProtoMessage()

func (*Port) ProtoReflect 

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

func (*Port) Reset 

func (x *Port) Reset()

func (*Port) String 

func (x *Port) String() string

type ProcessType 

type ProcessType struct {
	Args              []string                     `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
	Env               map[string]string            `` /* 147-byte string literal not displayed */
	Ports             []*Port                      `protobuf:"bytes,3,rep,name=ports,proto3" json:"ports,omitempty"`
	Volumes           []*VolumeReq                 `protobuf:"bytes,4,rep,name=volumes,proto3" json:"volumes,omitempty"`
	Omni              bool                         `protobuf:"varint,5,opt,name=omni,proto3" json:"omni,omitempty"`
	HostNetwork       bool                         `protobuf:"varint,6,opt,name=host_network,json=hostNetwork,proto3" json:"host_network,omitempty"`
	HostPidNamespace  bool                         `protobuf:"varint,7,opt,name=host_pid_namespace,json=hostPidNamespace,proto3" json:"host_pid_namespace,omitempty"`
	Service           string                       `protobuf:"bytes,8,opt,name=service,proto3" json:"service,omitempty"`
	Resurrect         bool                         `protobuf:"varint,9,opt,name=resurrect,proto3" json:"resurrect,omitempty"`
	Resources         map[string]*HostResourceSpec `` /* 160-byte string literal not displayed */
	Mounts            []*HostMount                 `protobuf:"bytes,11,rep,name=mounts,proto3" json:"mounts,omitempty"`
	LinuxCapabilities []string                     `protobuf:"bytes,12,rep,name=linux_capabilities,json=linuxCapabilities,proto3" json:"linux_capabilities,omitempty"`
	AllowedDevices    []*LibContainerDevice        `protobuf:"bytes,13,rep,name=allowed_devices,json=allowedDevices,proto3" json:"allowed_devices,omitempty"`
	WriteableCgroups  bool                         `protobuf:"varint,14,opt,name=writeable_cgroups,json=writeableCgroups,proto3" json:"writeable_cgroups,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessType) Descriptor deprecated 

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

Deprecated: Use ProcessType.ProtoReflect.Descriptor instead.

func (*ProcessType) GetAllowedDevices 

func (x *ProcessType) GetAllowedDevices() []*LibContainerDevice

func (*ProcessType) GetArgs 

func (x *ProcessType) GetArgs() []string

func (*ProcessType) GetEnv 

func (x *ProcessType) GetEnv() map[string]string

func (*ProcessType) GetHostNetwork 

func (x *ProcessType) GetHostNetwork() bool

func (*ProcessType) GetHostPidNamespace 

func (x *ProcessType) GetHostPidNamespace() bool

func (*ProcessType) GetLinuxCapabilities 

func (x *ProcessType) GetLinuxCapabilities() []string

func (*ProcessType) GetMounts 

func (x *ProcessType) GetMounts() []*HostMount

func (*ProcessType) GetOmni 

func (x *ProcessType) GetOmni() bool

func (*ProcessType) GetPorts 

func (x *ProcessType) GetPorts() []*Port

func (*ProcessType) GetResources 

func (x *ProcessType) GetResources() map[string]*HostResourceSpec

func (*ProcessType) GetResurrect 

func (x *ProcessType) GetResurrect() bool

func (*ProcessType) GetService 

func (x *ProcessType) GetService() string

func (*ProcessType) GetVolumes 

func (x *ProcessType) GetVolumes() []*VolumeReq

func (*ProcessType) GetWriteableCgroups 

func (x *ProcessType) GetWriteableCgroups() bool

func (*ProcessType) ProtoMessage 

func (*ProcessType) ProtoMessage()

func (*ProcessType) ProtoReflect 

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

func (*ProcessType) Reset 

func (x *ProcessType) Reset()

func (*ProcessType) String 

func (x *ProcessType) String() string

type Release 

type Release struct {

	// name = "apps/APP_ID/releases/RELEASE_ID"
	Name       string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Artifacts  []string                `protobuf:"bytes,3,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	Env        map[string]string       `` /* 147-byte string literal not displayed */
	Labels     map[string]string       `` /* 153-byte string literal not displayed */
	Processes  map[string]*ProcessType `` /* 159-byte string literal not displayed */
	Type       ReleaseType             `protobuf:"varint,7,opt,name=type,proto3,enum=flynn.api.v1.ReleaseType" json:"type,omitempty"`
	CreateTime *timestamp.Timestamp    `protobuf:"bytes,8,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	DeleteTime *timestamp.Timestamp    `protobuf:"bytes,9,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
	// contains filtered or unexported fields
}

func NewRelease 

func NewRelease(r *ct.Release) *Release

func (*Release) ControllerType 

func (r *Release) ControllerType() *ct.Release

func (*Release) Descriptor deprecated 

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

Deprecated: Use Release.ProtoReflect.Descriptor instead.

func (*Release) GetArtifacts 

func (x *Release) GetArtifacts() []string

func (*Release) GetCreateTime 

func (x *Release) GetCreateTime() *timestamp.Timestamp

func (*Release) GetDeleteTime 

func (x *Release) GetDeleteTime() *timestamp.Timestamp

func (*Release) GetEnv 

func (x *Release) GetEnv() map[string]string

func (*Release) GetLabels 

func (x *Release) GetLabels() map[string]string

func (*Release) GetName 

func (x *Release) GetName() string

func (*Release) GetProcesses 

func (x *Release) GetProcesses() map[string]*ProcessType

func (*Release) GetType 

func (x *Release) GetType() ReleaseType

func (*Release) ProtoMessage 

func (*Release) ProtoMessage()

func (*Release) ProtoReflect 

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

func (*Release) Reset 

func (x *Release) Reset()

func (*Release) String 

func (x *Release) String() string

type ReleaseType 

type ReleaseType int32
const (
	ReleaseType_ANY    ReleaseType = 0
	ReleaseType_CODE   ReleaseType = 1
	ReleaseType_CONFIG ReleaseType = 2
)

func (ReleaseType) Descriptor 

func (ReleaseType) Descriptor() protoreflect.EnumDescriptor

func (ReleaseType) Enum 

func (x ReleaseType) Enum() *ReleaseType

func (ReleaseType) EnumDescriptor deprecated 

func (ReleaseType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReleaseType.Descriptor instead.

func (ReleaseType) Number 

func (x ReleaseType) Number() protoreflect.EnumNumber

func (ReleaseType) String 

func (x ReleaseType) String() string

func (ReleaseType) Type 

func (ReleaseType) Type() protoreflect.EnumType

type ReleaseTypeMatcher 

type ReleaseTypeMatcher struct {
	// contains filtered or unexported fields
}

func NewReleaseTypeMatcher 

func NewReleaseTypeMatcher(types []ReleaseType) *ReleaseTypeMatcher

func (*ReleaseTypeMatcher) Match 

func (m *ReleaseTypeMatcher) Match(t ReleaseType) bool

type ScaleRequest 

type ScaleRequest struct {

	// parent = "apps/APP_ID/releases/RELEASE_ID"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// name = "apps/APP_ID/releases/RELEASE_ID/scales/SCALE_REQUEST_ID"
	Name         string                            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	State        ScaleRequestState                 `protobuf:"varint,3,opt,name=state,proto3,enum=flynn.api.v1.ScaleRequestState" json:"state,omitempty"`
	OldProcesses map[string]int32                  `` /* 186-byte string literal not displayed */
	NewProcesses map[string]int32                  `` /* 186-byte string literal not displayed */
	OldTags      map[string]*DeploymentProcessTags `` /* 170-byte string literal not displayed */
	NewTags      map[string]*DeploymentProcessTags `` /* 170-byte string literal not displayed */
	CreateTime   *timestamp.Timestamp              `protobuf:"bytes,8,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	UpdateTime   *timestamp.Timestamp              `protobuf:"bytes,9,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

func NewScaleRequest 

func NewScaleRequest(ctScaleReq *ct.ScaleRequest) *ScaleRequest

func (*ScaleRequest) ControllerType 

func (req *ScaleRequest) ControllerType() *ct.ScaleRequest

func (*ScaleRequest) Descriptor deprecated 

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

Deprecated: Use ScaleRequest.ProtoReflect.Descriptor instead.

func (*ScaleRequest) GetCreateTime 

func (x *ScaleRequest) GetCreateTime() *timestamp.Timestamp

func (*ScaleRequest) GetName 

func (x *ScaleRequest) GetName() string

func (*ScaleRequest) GetNewProcesses 

func (x *ScaleRequest) GetNewProcesses() map[string]int32

func (*ScaleRequest) GetNewTags 

func (x *ScaleRequest) GetNewTags() map[string]*DeploymentProcessTags

func (*ScaleRequest) GetOldProcesses 

func (x *ScaleRequest) GetOldProcesses() map[string]int32

func (*ScaleRequest) GetOldTags 

func (x *ScaleRequest) GetOldTags() map[string]*DeploymentProcessTags

func (*ScaleRequest) GetParent 

func (x *ScaleRequest) GetParent() string

func (*ScaleRequest) GetState 

func (x *ScaleRequest) GetState() ScaleRequestState

func (*ScaleRequest) GetUpdateTime 

func (x *ScaleRequest) GetUpdateTime() *timestamp.Timestamp

func (*ScaleRequest) ProtoMessage 

func (*ScaleRequest) ProtoMessage()

func (*ScaleRequest) ProtoReflect 

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

func (*ScaleRequest) Reset 

func (x *ScaleRequest) Reset()

func (*ScaleRequest) String 

func (x *ScaleRequest) String() string

type ScaleRequestState 

type ScaleRequestState int32
const (
	ScaleRequestState_SCALE_PENDING   ScaleRequestState = 0
	ScaleRequestState_SCALE_CANCELLED ScaleRequestState = 1
	ScaleRequestState_SCALE_COMPLETE  ScaleRequestState = 2
)

func (ScaleRequestState) ControllerType 

func (s ScaleRequestState) ControllerType() ct.ScaleRequestState

func (ScaleRequestState) Descriptor 

func (ScaleRequestState) Descriptor() protoreflect.EnumDescriptor

func (ScaleRequestState) Enum 

func (x ScaleRequestState) Enum() *ScaleRequestState

func (ScaleRequestState) EnumDescriptor deprecated 

func (ScaleRequestState) EnumDescriptor() ([]byte, []int)

Deprecated: Use ScaleRequestState.Descriptor instead.

func (ScaleRequestState) Number 

func (x ScaleRequestState) Number() protoreflect.EnumNumber

func (ScaleRequestState) String 

func (x ScaleRequestState) String() string

func (ScaleRequestState) Type 

func (ScaleRequestState) Type() protoreflect.EnumType

type SignedData 

type SignedData struct {
	Data      []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*SignedData) Descriptor deprecated 

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

Deprecated: Use SignedData.ProtoReflect.Descriptor instead.

func (*SignedData) GetData 

func (x *SignedData) GetData() []byte

func (*SignedData) GetSignature 

func (x *SignedData) GetSignature() []byte

func (*SignedData) ProtoMessage 

func (*SignedData) ProtoMessage()

func (*SignedData) ProtoReflect 

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

func (*SignedData) Reset 

func (x *SignedData) Reset()

func (*SignedData) String 

func (x *SignedData) String() string

type StatusResponse 

type StatusResponse struct {
	Status  StatusResponse_Code `protobuf:"varint,1,opt,name=status,proto3,enum=flynn.api.v1.StatusResponse_Code" json:"status,omitempty"`
	Detail  []byte              `protobuf:"bytes,2,opt,name=detail,proto3" json:"detail,omitempty"`
	Version string              `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func NewStatusResponse 

func NewStatusResponse(healthy bool, detail []byte) *StatusResponse

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetDetail 

func (x *StatusResponse) GetDetail() []byte

func (*StatusResponse) GetStatus 

func (x *StatusResponse) GetStatus() StatusResponse_Code

func (*StatusResponse) GetVersion 

func (x *StatusResponse) GetVersion() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StatusResponse_Code 

type StatusResponse_Code int32
const (
	StatusResponse_HEALTHY   StatusResponse_Code = 0
	StatusResponse_UNHEALTHY StatusResponse_Code = 1
)

func (StatusResponse_Code) Descriptor 

func (StatusResponse_Code) Descriptor() protoreflect.EnumDescriptor

func (StatusResponse_Code) Enum 

func (x StatusResponse_Code) Enum() *StatusResponse_Code

func (StatusResponse_Code) EnumDescriptor deprecated 

func (StatusResponse_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use StatusResponse_Code.Descriptor instead.

func (StatusResponse_Code) Number 

func (x StatusResponse_Code) Number() protoreflect.EnumNumber

func (StatusResponse_Code) String 

func (x StatusResponse_Code) String() string

func (StatusResponse_Code) Type 

func (StatusResponse_Code) Type() protoreflect.EnumType

type StreamAppsRequest 

type StreamAppsRequest struct {

	// The maximum number of resources to return in the initial page.
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Used for pagination. Must be a next_page_token returned from a previous response.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Specifies an optional list of resource names that should be looked up. The
	// list length must be smaller than page_size. This can be used to request a
	// known set of one or more resources and optionally receive updates about
	// them, and can also be used to retrieve a single resource.
	NameFilters []string `protobuf:"bytes,3,rep,name=name_filters,json=nameFilters,proto3" json:"name_filters,omitempty"`
	// filters are ORed
	LabelFilters []*LabelFilter `protobuf:"bytes,4,rep,name=label_filters,json=labelFilters,proto3" json:"label_filters,omitempty"`
	// When true, leaves the stream open and sends any updates to each resource
	// returned in the initial page until the stream is closed.
	StreamUpdates bool `protobuf:"varint,5,opt,name=stream_updates,json=streamUpdates,proto3" json:"stream_updates,omitempty"`
	// When true, leaves the stream open and sends newly created resources
	// matching the filters until the stream is closed. page_token must not be
	// set.
	StreamCreates bool `protobuf:"varint,6,opt,name=stream_creates,json=streamCreates,proto3" json:"stream_creates,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamAppsRequest) Descriptor deprecated 

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

Deprecated: Use StreamAppsRequest.ProtoReflect.Descriptor instead.

func (*StreamAppsRequest) GetLabelFilters 

func (x *StreamAppsRequest) GetLabelFilters() []*LabelFilter

func (*StreamAppsRequest) GetNameFilters 

func (x *StreamAppsRequest) GetNameFilters() []string

func (*StreamAppsRequest) GetPageSize 

func (x *StreamAppsRequest) GetPageSize() int32

func (*StreamAppsRequest) GetPageToken 

func (x *StreamAppsRequest) GetPageToken() string

func (*StreamAppsRequest) GetStreamCreates 

func (x *StreamAppsRequest) GetStreamCreates() bool

func (*StreamAppsRequest) GetStreamUpdates 

func (x *StreamAppsRequest) GetStreamUpdates() bool

func (*StreamAppsRequest) ProtoMessage 

func (*StreamAppsRequest) ProtoMessage()

func (*StreamAppsRequest) ProtoReflect 

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

func (*StreamAppsRequest) Reset 

func (x *StreamAppsRequest) Reset()

func (*StreamAppsRequest) String 

func (x *StreamAppsRequest) String() string

type StreamAppsResponse 

type StreamAppsResponse struct {
	Apps []*App `protobuf:"bytes,1,rep,name=apps,proto3" json:"apps,omitempty"`
	// Set to true on the last response for the initial page.
	PageComplete  bool   `protobuf:"varint,2,opt,name=page_complete,json=pageComplete,proto3" json:"page_complete,omitempty"`
	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamAppsResponse) Descriptor deprecated 

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

Deprecated: Use StreamAppsResponse.ProtoReflect.Descriptor instead.

func (*StreamAppsResponse) GetApps 

func (x *StreamAppsResponse) GetApps() []*App

func (*StreamAppsResponse) GetNextPageToken 

func (x *StreamAppsResponse) GetNextPageToken() string

func (*StreamAppsResponse) GetPageComplete 

func (x *StreamAppsResponse) GetPageComplete() bool

func (*StreamAppsResponse) ProtoMessage 

func (*StreamAppsResponse) ProtoMessage()

func (*StreamAppsResponse) ProtoReflect 

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

func (*StreamAppsResponse) Reset 

func (x *StreamAppsResponse) Reset()

func (*StreamAppsResponse) String 

func (x *StreamAppsResponse) String() string

type StreamDeploymentsRequest 

type StreamDeploymentsRequest struct {

	// The maximum number of resources to return in the initial page.
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Used for pagination. Must be a next_page_token returned from a previous response.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Specifies an optional list of resource names that should be looked up. The
	// list length must be smaller than page_size. This can be used to request a
	// known set of one or more resources and optionally receive updates about
	// them, and can also be used to retrieve a single resource. Parent resource
	// names may also be used to filter resources.
	NameFilters []string `protobuf:"bytes,3,rep,name=name_filters,json=nameFilters,proto3" json:"name_filters,omitempty"`
	// Specified an optional list of release types. If provided, only resources
	// with these release types will be returned.
	TypeFilters []ReleaseType `` /* 132-byte string literal not displayed */
	// Specifies an optional list of statuses. If provided, only deployments
	// matching one of the given statuses will be returned.
	StatusFilters []DeploymentStatus `` /* 143-byte string literal not displayed */
	// When true, leaves the stream open and sends any updates to each resource
	// returned in the initial page until the stream is closed.
	StreamUpdates bool `protobuf:"varint,7,opt,name=stream_updates,json=streamUpdates,proto3" json:"stream_updates,omitempty"`
	// When true, leaves the stream open and sends newly created resources
	// matching the filters until the stream is closed. page_token must not be
	// set.
	StreamCreates bool `protobuf:"varint,8,opt,name=stream_creates,json=streamCreates,proto3" json:"stream_creates,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamDeploymentsRequest) Descriptor deprecated 

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

Deprecated: Use StreamDeploymentsRequest.ProtoReflect.Descriptor instead.

func (*StreamDeploymentsRequest) GetNameFilters 

func (x *StreamDeploymentsRequest) GetNameFilters() []string

func (*StreamDeploymentsRequest) GetPageSize 

func (x *StreamDeploymentsRequest) GetPageSize() int32

func (*StreamDeploymentsRequest) GetPageToken 

func (x *StreamDeploymentsRequest) GetPageToken() string

func (*StreamDeploymentsRequest) GetStatusFilters 

func (x *StreamDeploymentsRequest) GetStatusFilters() []DeploymentStatus

func (*StreamDeploymentsRequest) GetStreamCreates 

func (x *StreamDeploymentsRequest) GetStreamCreates() bool

func (*StreamDeploymentsRequest) GetStreamUpdates 

func (x *StreamDeploymentsRequest) GetStreamUpdates() bool

func (*StreamDeploymentsRequest) GetTypeFilters 

func (x *StreamDeploymentsRequest) GetTypeFilters() []ReleaseType

func (*StreamDeploymentsRequest) ProtoMessage 

func (*StreamDeploymentsRequest) ProtoMessage()

func (*StreamDeploymentsRequest) ProtoReflect 

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

func (*StreamDeploymentsRequest) Reset 

func (x *StreamDeploymentsRequest) Reset()

func (*StreamDeploymentsRequest) String 

func (x *StreamDeploymentsRequest) String() string

type StreamDeploymentsResponse 

type StreamDeploymentsResponse struct {
	Deployments []*ExpandedDeployment `protobuf:"bytes,1,rep,name=deployments,proto3" json:"deployments,omitempty"`
	// Set to true on the last response for the initial page.
	PageComplete  bool   `protobuf:"varint,2,opt,name=page_complete,json=pageComplete,proto3" json:"page_complete,omitempty"`
	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamDeploymentsResponse) Descriptor deprecated 

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

Deprecated: Use StreamDeploymentsResponse.ProtoReflect.Descriptor instead.

func (*StreamDeploymentsResponse) GetDeployments 

func (x *StreamDeploymentsResponse) GetDeployments() []*ExpandedDeployment

func (*StreamDeploymentsResponse) GetNextPageToken 

func (x *StreamDeploymentsResponse) GetNextPageToken() string

func (*StreamDeploymentsResponse) GetPageComplete 

func (x *StreamDeploymentsResponse) GetPageComplete() bool

func (*StreamDeploymentsResponse) ProtoMessage 

func (*StreamDeploymentsResponse) ProtoMessage()

func (*StreamDeploymentsResponse) ProtoReflect 

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

func (*StreamDeploymentsResponse) Reset 

func (x *StreamDeploymentsResponse) Reset()

func (*StreamDeploymentsResponse) String 

func (x *StreamDeploymentsResponse) String() string

type StreamReleasesRequest 

type StreamReleasesRequest struct {

	// The maximum number of resources to return in the initial page.
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Used for pagination. Must be a next_page_token returned from a previous response.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Specifies an optional list of resource names that should be looked up. The
	// list length must be smaller than page_size. This can be used to request a
	// known set of one or more resources and optionally receive updates about
	// them, and can also be used to retrieve a single resource. Parent resource
	// names may also be used to filter resources.
	NameFilters []string `protobuf:"bytes,3,rep,name=name_filters,json=nameFilters,proto3" json:"name_filters,omitempty"`
	// filters are ORed
	LabelFilters []*LabelFilter `protobuf:"bytes,4,rep,name=label_filters,json=labelFilters,proto3" json:"label_filters,omitempty"`
	// When true, leaves the stream open and sends any updates (i.e. resource
	// deletions) to each resource returned in the initial page until the stream
	// is closed.
	StreamUpdates bool `protobuf:"varint,5,opt,name=stream_updates,json=streamUpdates,proto3" json:"stream_updates,omitempty"`
	// When true, leaves the stream open and sends newly created resources
	// matching the filters until the stream is closed. page_token must not be
	// set.
	StreamCreates bool `protobuf:"varint,6,opt,name=stream_creates,json=streamCreates,proto3" json:"stream_creates,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamReleasesRequest) Descriptor deprecated 

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

Deprecated: Use StreamReleasesRequest.ProtoReflect.Descriptor instead.

func (*StreamReleasesRequest) GetLabelFilters 

func (x *StreamReleasesRequest) GetLabelFilters() []*LabelFilter

func (*StreamReleasesRequest) GetNameFilters 

func (x *StreamReleasesRequest) GetNameFilters() []string

func (*StreamReleasesRequest) GetPageSize 

func (x *StreamReleasesRequest) GetPageSize() int32

func (*StreamReleasesRequest) GetPageToken 

func (x *StreamReleasesRequest) GetPageToken() string

func (*StreamReleasesRequest) GetStreamCreates 

func (x *StreamReleasesRequest) GetStreamCreates() bool

func (*StreamReleasesRequest) GetStreamUpdates 

func (x *StreamReleasesRequest) GetStreamUpdates() bool

func (*StreamReleasesRequest) ProtoMessage 

func (*StreamReleasesRequest) ProtoMessage()

func (*StreamReleasesRequest) ProtoReflect 

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

func (*StreamReleasesRequest) Reset 

func (x *StreamReleasesRequest) Reset()

func (*StreamReleasesRequest) String 

func (x *StreamReleasesRequest) String() string

type StreamReleasesResponse 

type StreamReleasesResponse struct {
	Releases []*Release `protobuf:"bytes,1,rep,name=releases,proto3" json:"releases,omitempty"`
	// Set to true on the last response for the initial page.
	PageComplete  bool   `protobuf:"varint,2,opt,name=page_complete,json=pageComplete,proto3" json:"page_complete,omitempty"`
	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamReleasesResponse) Descriptor deprecated 

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

Deprecated: Use StreamReleasesResponse.ProtoReflect.Descriptor instead.

func (*StreamReleasesResponse) GetNextPageToken 

func (x *StreamReleasesResponse) GetNextPageToken() string

func (*StreamReleasesResponse) GetPageComplete 

func (x *StreamReleasesResponse) GetPageComplete() bool

func (*StreamReleasesResponse) GetReleases 

func (x *StreamReleasesResponse) GetReleases() []*Release

func (*StreamReleasesResponse) ProtoMessage 

func (*StreamReleasesResponse) ProtoMessage()

func (*StreamReleasesResponse) ProtoReflect 

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

func (*StreamReleasesResponse) Reset 

func (x *StreamReleasesResponse) Reset()

func (*StreamReleasesResponse) String 

func (x *StreamReleasesResponse) String() string

type StreamScalesRequest 

type StreamScalesRequest struct {

	// The maximum number of resources to return in the initial page.
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Used for pagination. Must be a next_page_token returned from a previous response.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Specifies an optional list of resource names that should be looked up. The
	// list length must be smaller than page_size. This can be used to request a
	// known set of one or more resources and optionally receive updates about
	// them, and can also be used to retrieve a single resource. Parent resource
	// names may also be used to filter resources.
	NameFilters []string `protobuf:"bytes,3,rep,name=name_filters,json=nameFilters,proto3" json:"name_filters,omitempty"`
	// When set, only includes resources having one of the specified states
	StateFilters []ScaleRequestState `` /* 141-byte string literal not displayed */
	// When true, leaves the stream open and sends any updates to each resource
	// returned in the initial page until the stream is closed.
	StreamUpdates bool `protobuf:"varint,5,opt,name=stream_updates,json=streamUpdates,proto3" json:"stream_updates,omitempty"`
	// When true, leaves the stream open and sends newly created resources
	// matching the filters until the stream is closed. page_token must not be
	// set.
	StreamCreates bool `protobuf:"varint,6,opt,name=stream_creates,json=streamCreates,proto3" json:"stream_creates,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamScalesRequest) Descriptor deprecated 

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

Deprecated: Use StreamScalesRequest.ProtoReflect.Descriptor instead.

func (*StreamScalesRequest) GetNameFilters 

func (x *StreamScalesRequest) GetNameFilters() []string

func (*StreamScalesRequest) GetPageSize 

func (x *StreamScalesRequest) GetPageSize() int32

func (*StreamScalesRequest) GetPageToken 

func (x *StreamScalesRequest) GetPageToken() string

func (*StreamScalesRequest) GetStateFilters 

func (x *StreamScalesRequest) GetStateFilters() []ScaleRequestState

func (*StreamScalesRequest) GetStreamCreates 

func (x *StreamScalesRequest) GetStreamCreates() bool

func (*StreamScalesRequest) GetStreamUpdates 

func (x *StreamScalesRequest) GetStreamUpdates() bool

func (*StreamScalesRequest) ProtoMessage 

func (*StreamScalesRequest) ProtoMessage()

func (*StreamScalesRequest) ProtoReflect 

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

func (*StreamScalesRequest) Reset 

func (x *StreamScalesRequest) Reset()

func (*StreamScalesRequest) String 

func (x *StreamScalesRequest) String() string

type StreamScalesResponse 

type StreamScalesResponse struct {
	ScaleRequests []*ScaleRequest `protobuf:"bytes,1,rep,name=scale_requests,json=scaleRequests,proto3" json:"scale_requests,omitempty"`
	// Set to true on the last response for the initial page.
	PageComplete  bool   `protobuf:"varint,2,opt,name=page_complete,json=pageComplete,proto3" json:"page_complete,omitempty"`
	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamScalesResponse) Descriptor deprecated 

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

Deprecated: Use StreamScalesResponse.ProtoReflect.Descriptor instead.

func (*StreamScalesResponse) GetNextPageToken 

func (x *StreamScalesResponse) GetNextPageToken() string

func (*StreamScalesResponse) GetPageComplete 

func (x *StreamScalesResponse) GetPageComplete() bool

func (*StreamScalesResponse) GetScaleRequests 

func (x *StreamScalesResponse) GetScaleRequests() []*ScaleRequest

func (*StreamScalesResponse) ProtoMessage 

func (*StreamScalesResponse) ProtoMessage()

func (*StreamScalesResponse) ProtoReflect 

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

func (*StreamScalesResponse) Reset 

func (x *StreamScalesResponse) Reset()

func (*StreamScalesResponse) String 

func (x *StreamScalesResponse) String() string

type UnimplementedControllerServer 

type UnimplementedControllerServer struct {
}

UnimplementedControllerServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerServer) CreateDeployment 

func (*UnimplementedControllerServer) CreateDeployment(*CreateDeploymentRequest, Controller_CreateDeploymentServer) error

func (*UnimplementedControllerServer) CreateRelease 

func (*UnimplementedControllerServer) CreateRelease(context.Context, *CreateReleaseRequest) (*Release, error)

func (*UnimplementedControllerServer) CreateScale 

func (*UnimplementedControllerServer) CreateScale(context.Context, *CreateScaleRequest) (*ScaleRequest, error)

func (*UnimplementedControllerServer) Status 

func (*UnimplementedControllerServer) Status(context.Context, *empty.Empty) (*StatusResponse, error)

func (*UnimplementedControllerServer) StreamApps 

func (*UnimplementedControllerServer) StreamApps(*StreamAppsRequest, Controller_StreamAppsServer) error

func (*UnimplementedControllerServer) StreamDeployments 

func (*UnimplementedControllerServer) StreamDeployments(*StreamDeploymentsRequest, Controller_StreamDeploymentsServer) error

func (*UnimplementedControllerServer) StreamReleases 

func (*UnimplementedControllerServer) StreamReleases(*StreamReleasesRequest, Controller_StreamReleasesServer) error

func (*UnimplementedControllerServer) StreamScales 

func (*UnimplementedControllerServer) StreamScales(*StreamScalesRequest, Controller_StreamScalesServer) error

func (*UnimplementedControllerServer) UpdateApp 

func (*UnimplementedControllerServer) UpdateApp(context.Context, *UpdateAppRequest) (*App, error)

type UpdateAppRequest 

type UpdateAppRequest struct {
	App        *App                  `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	UpdateMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateAppRequest) Descriptor deprecated 

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

Deprecated: Use UpdateAppRequest.ProtoReflect.Descriptor instead.

func (*UpdateAppRequest) GetApp 

func (x *UpdateAppRequest) GetApp() *App

func (*UpdateAppRequest) GetUpdateMask 

func (x *UpdateAppRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateAppRequest) ProtoMessage 

func (*UpdateAppRequest) ProtoMessage()

func (*UpdateAppRequest) ProtoReflect 

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

func (*UpdateAppRequest) Reset 

func (x *UpdateAppRequest) Reset()

func (*UpdateAppRequest) String 

func (x *UpdateAppRequest) String() string

type VolumeReq 

type VolumeReq struct {
	Path         string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	DeleteOnStop bool   `protobuf:"varint,2,opt,name=delete_on_stop,json=deleteOnStop,proto3" json:"delete_on_stop,omitempty"`
	// contains filtered or unexported fields
}

func NewVolumes 

func NewVolumes(from []ct.VolumeReq) []*VolumeReq

func (*VolumeReq) Descriptor deprecated 

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

Deprecated: Use VolumeReq.ProtoReflect.Descriptor instead.

func (*VolumeReq) GetDeleteOnStop 

func (x *VolumeReq) GetDeleteOnStop() bool

func (*VolumeReq) GetPath 

func (x *VolumeReq) GetPath() string

func (*VolumeReq) ProtoMessage 

func (*VolumeReq) ProtoMessage()

func (*VolumeReq) ProtoReflect 

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

func (*VolumeReq) Reset 

func (x *VolumeReq) Reset()

func (*VolumeReq) String 

func (x *VolumeReq) String() string

Source Files

View all Source files

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.