api

package
v0.0.0-...-b359386 Latest Latest
Warning

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

Go to latest
Published: Oct 15, 2020 License: Apache-2.0 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

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 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 (*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 `` /* 127-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) Enum

func (DeploymentEvent_JobState) EnumDescriptor deprecated

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

Deprecated: Use DeploymentEvent_JobState.Descriptor instead.

func (DeploymentEvent_JobState) Number

func (DeploymentEvent_JobState) String

func (x DeploymentEvent_JobState) String() string

func (DeploymentEvent_JobState) Type

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) Enum

func (DeploymentStatus) EnumDescriptor deprecated

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

Deprecated: Use DeploymentStatus.Descriptor instead.

func (DeploymentStatus) Number

func (DeploymentStatus) String

func (x DeploymentStatus) String() string

func (DeploymentStatus) Type

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=owo.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=owo.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 (*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/realjf/owo/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/realjf/owo/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/realjf/owo/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/realjf/owo/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=owo.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 (*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) Enum

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 (LabelFilter_Expression_Operator) String

func (LabelFilter_Expression_Operator) Type

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=owo.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) 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

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=owo.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) Enum

func (ScaleRequestState) EnumDescriptor deprecated

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

Deprecated: Use ScaleRequestState.Descriptor instead.

func (ScaleRequestState) Number

func (ScaleRequestState) String

func (x ScaleRequestState) String() string

func (ScaleRequestState) Type

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=owo.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) Enum

func (StatusResponse_Code) EnumDescriptor deprecated

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

Deprecated: Use StatusResponse_Code.Descriptor instead.

func (StatusResponse_Code) Number

func (StatusResponse_Code) String

func (x StatusResponse_Code) String() string

func (StatusResponse_Code) Type

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 `` /* 130-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 `` /* 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,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 (*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 `` /* 139-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) CreateRelease

func (*UnimplementedControllerServer) CreateScale

func (*UnimplementedControllerServer) Status

func (*UnimplementedControllerServer) StreamApps

func (*UnimplementedControllerServer) StreamDeployments

func (*UnimplementedControllerServer) StreamReleases

func (*UnimplementedControllerServer) StreamScales

func (*UnimplementedControllerServer) UpdateApp

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL