deployflow

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_deployflow_deployflow_proto protoreflect.FileDescriptor

Functions

func RegisterDeployFlowServer 

func RegisterDeployFlowServer(s *grpc.Server, srv DeployFlowServer)

Types

type ApplicationSpec 

type ApplicationSpec struct {
	AppID            int32                  `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"`
	GroupID          int32                  `protobuf:"varint,2,opt,name=groupID,proto3" json:"groupID,omitempty"`
	AppName          string                 `protobuf:"bytes,3,opt,name=appName,proto3" json:"appName,omitempty"`
	InstanceName     string                 `protobuf:"bytes,4,opt,name=instanceName,proto3" json:"instanceName,omitempty"`
	Replicas         *wrapperspb.Int32Value `protobuf:"bytes,5,opt,name=replicas,proto3" json:"replicas,omitempty"`
	ApplicationType  string                 `protobuf:"bytes,6,opt,name=applicationType,proto3" json:"applicationType,omitempty"`
	ApplicationLabel map[string]string      `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ApplicationSpec) Descriptor deprecated 

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

Deprecated: Use ApplicationSpec.ProtoReflect.Descriptor instead.

func (*ApplicationSpec) GetAppID 

func (x *ApplicationSpec) GetAppID() int32

func (*ApplicationSpec) GetAppName 

func (x *ApplicationSpec) GetAppName() string

func (*ApplicationSpec) GetApplicationLabel 

func (x *ApplicationSpec) GetApplicationLabel() map[string]string

func (*ApplicationSpec) GetApplicationType 

func (x *ApplicationSpec) GetApplicationType() string

func (*ApplicationSpec) GetGroupID 

func (x *ApplicationSpec) GetGroupID() int32

func (*ApplicationSpec) GetInstanceName 

func (x *ApplicationSpec) GetInstanceName() string

func (*ApplicationSpec) GetReplicas 

func (x *ApplicationSpec) GetReplicas() *wrapperspb.Int32Value

func (*ApplicationSpec) ProtoMessage 

func (*ApplicationSpec) ProtoMessage()

func (*ApplicationSpec) ProtoReflect 

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

func (*ApplicationSpec) Reset 

func (x *ApplicationSpec) Reset()

func (*ApplicationSpec) String 

func (x *ApplicationSpec) String() string

type Batch 

type Batch struct {
	Batch          int32                  `protobuf:"varint,1,opt,name=batch,proto3" json:"batch,omitempty"`
	BatchSize      int32                  `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	Canary         bool                   `protobuf:"varint,3,opt,name=canary,proto3" json:"canary,omitempty"`
	Phase          string                 `protobuf:"bytes,4,opt,name=phase,proto3" json:"phase,omitempty"`
	FailedReplicas int32                  `protobuf:"varint,5,opt,name=failedReplicas,proto3" json:"failedReplicas,omitempty"`
	Pods           []*PodInfo             `protobuf:"bytes,6,rep,name=pods,proto3" json:"pods,omitempty"`
	StartedAt      *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=startedAt,proto3" json:"startedAt,omitempty"`
	FinishedAt     *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=finishedAt,proto3" json:"finishedAt,omitempty"`
	// contains filtered or unexported fields
}

func (*Batch) Descriptor deprecated 

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

Deprecated: Use Batch.ProtoReflect.Descriptor instead.

func (*Batch) GetBatch 

func (x *Batch) GetBatch() int32

func (*Batch) GetBatchSize 

func (x *Batch) GetBatchSize() int32

func (*Batch) GetCanary 

func (x *Batch) GetCanary() bool

func (*Batch) GetFailedReplicas 

func (x *Batch) GetFailedReplicas() int32

func (*Batch) GetFinishedAt 

func (x *Batch) GetFinishedAt() *timestamppb.Timestamp

func (*Batch) GetPhase 

func (x *Batch) GetPhase() string

func (*Batch) GetPods 

func (x *Batch) GetPods() []*PodInfo

func (*Batch) GetStartedAt 

func (x *Batch) GetStartedAt() *timestamppb.Timestamp

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) ProtoReflect 

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

func (*Batch) Reset 

func (x *Batch) Reset()

func (*Batch) String 

func (x *Batch) String() string

type ContainerPort 

type ContainerPort struct {
	HostPort      int32  `protobuf:"varint,1,opt,name=hostPort,proto3" json:"hostPort,omitempty"`
	ContainerPort int32  `protobuf:"varint,2,opt,name=containerPort,proto3" json:"containerPort,omitempty"`
	Protocol      string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Name          string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerPort) Descriptor deprecated 

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

Deprecated: Use ContainerPort.ProtoReflect.Descriptor instead.

func (*ContainerPort) GetContainerPort 

func (x *ContainerPort) GetContainerPort() int32

func (*ContainerPort) GetHostPort 

func (x *ContainerPort) GetHostPort() int32

func (*ContainerPort) GetName 

func (x *ContainerPort) GetName() string

func (*ContainerPort) GetProtocol 

func (x *ContainerPort) GetProtocol() string

func (*ContainerPort) ProtoMessage 

func (*ContainerPort) ProtoMessage()

func (*ContainerPort) ProtoReflect 

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

func (*ContainerPort) Reset 

func (x *ContainerPort) Reset()

func (*ContainerPort) String 

func (x *ContainerPort) String() string

type ContinueRequest 

type ContinueRequest struct {
	Deploy *DeployMeta  `protobuf:"bytes,1,opt,name=deploy,proto3" json:"deploy,omitempty"`
	Target *TargetState `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*ContinueRequest) Descriptor deprecated 

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

Deprecated: Use ContinueRequest.ProtoReflect.Descriptor instead.

func (*ContinueRequest) GetDeploy 

func (x *ContinueRequest) GetDeploy() *DeployMeta

func (*ContinueRequest) GetTarget 

func (x *ContinueRequest) GetTarget() *TargetState

func (*ContinueRequest) ProtoMessage 

func (*ContinueRequest) ProtoMessage()

func (*ContinueRequest) ProtoReflect 

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

func (*ContinueRequest) Reset 

func (x *ContinueRequest) Reset()

func (*ContinueRequest) String 

func (x *ContinueRequest) String() string

type CreateRequest 

type CreateRequest struct {
	AppID           int32            `protobuf:"varint,1,opt,name=appID,proto3" json:"appID,omitempty"`
	GroupID         int32            `protobuf:"varint,2,opt,name=groupID,proto3" json:"groupID,omitempty"`
	AppName         string           `protobuf:"bytes,3,opt,name=appName,proto3" json:"appName,omitempty"`
	InstanceName    string           `protobuf:"bytes,4,opt,name=instanceName,proto3" json:"instanceName,omitempty"`
	Namespace       string           `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ApplicationSpec *ApplicationSpec `protobuf:"bytes,6,opt,name=applicationSpec,proto3" json:"applicationSpec,omitempty"`
	Strategy        *UpdateStrategy  `protobuf:"bytes,7,opt,name=strategy,proto3" json:"strategy,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetAppID 

func (x *CreateRequest) GetAppID() int32

func (*CreateRequest) GetAppName 

func (x *CreateRequest) GetAppName() string

func (*CreateRequest) GetApplicationSpec 

func (x *CreateRequest) GetApplicationSpec() *ApplicationSpec

func (*CreateRequest) GetGroupID 

func (x *CreateRequest) GetGroupID() int32

func (*CreateRequest) GetInstanceName 

func (x *CreateRequest) GetInstanceName() string

func (*CreateRequest) GetNamespace 

func (x *CreateRequest) GetNamespace() string

func (*CreateRequest) GetStrategy 

func (x *CreateRequest) GetStrategy() *UpdateStrategy

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type Deploy 

type Deploy struct {
	Namespace             string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name                  string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	AppID                 int32                  `protobuf:"varint,3,opt,name=appID,proto3" json:"appID,omitempty"`
	GroupID               int32                  `protobuf:"varint,4,opt,name=groupID,proto3" json:"groupID,omitempty"`
	AppName               string                 `protobuf:"bytes,5,opt,name=appName,proto3" json:"appName,omitempty"`
	InstanceName          string                 `protobuf:"bytes,6,opt,name=instanceName,proto3" json:"instanceName,omitempty"`
	Replicas              int32                  `protobuf:"varint,7,opt,name=replicas,proto3" json:"replicas,omitempty"`
	Action                string                 `protobuf:"bytes,8,opt,name=action,proto3" json:"action,omitempty"`
	AvailableReplicas     int32                  `protobuf:"varint,9,opt,name=availableReplicas,proto3" json:"availableReplicas,omitempty"`
	UpdatedReplicas       int32                  `protobuf:"varint,10,opt,name=updatedReplicas,proto3" json:"updatedReplicas,omitempty"`
	UpdatedReadyReplicas  int32                  `protobuf:"varint,11,opt,name=updatedReadyReplicas,proto3" json:"updatedReadyReplicas,omitempty"`
	UpdateRevision        string                 `protobuf:"bytes,12,opt,name=updateRevision,proto3" json:"updateRevision,omitempty"`
	Conditions            []*Batch               `protobuf:"bytes,13,rep,name=conditions,proto3" json:"conditions,omitempty"`
	Paused                bool                   `protobuf:"varint,14,opt,name=paused,proto3" json:"paused,omitempty"`
	Phase                 string                 `protobuf:"bytes,15,opt,name=phase,proto3" json:"phase,omitempty"`
	Finished              bool                   `protobuf:"varint,16,opt,name=finished,proto3" json:"finished,omitempty"`
	Batches               int32                  `protobuf:"varint,17,opt,name=batches,proto3" json:"batches,omitempty"`
	BatchSize             int32                  `protobuf:"varint,18,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	FinishedBatches       int32                  `protobuf:"varint,19,opt,name=finishedBatches,proto3" json:"finishedBatches,omitempty"`
	FinishedReplicas      int32                  `protobuf:"varint,20,opt,name=finishedReplicas,proto3" json:"finishedReplicas,omitempty"`
	FailedReplicas        int32                  `protobuf:"varint,21,opt,name=failedReplicas,proto3" json:"failedReplicas,omitempty"`
	StartedAt             *timestamppb.Timestamp `protobuf:"bytes,22,opt,name=startedAt,proto3" json:"startedAt,omitempty"`
	FinishedAt            *timestamppb.Timestamp `protobuf:"bytes,23,opt,name=finishedAt,proto3" json:"finishedAt,omitempty"`
	UpdatedAt             *timestamppb.Timestamp `protobuf:"bytes,29,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	Mode                  string                 `protobuf:"bytes,24,opt,name=mode,proto3" json:"mode,omitempty"`
	BatchIntervalSeconds  int32                  `protobuf:"varint,25,opt,name=batchIntervalSeconds,proto3" json:"batchIntervalSeconds,omitempty"`
	TimeoutSeconds        int32                  `protobuf:"varint,26,opt,name=timeoutSeconds,proto3" json:"timeoutSeconds,omitempty"`
	GracefulPeriodSeconds int32                  `protobuf:"varint,27,opt,name=gracefulPeriodSeconds,proto3" json:"gracefulPeriodSeconds,omitempty"`
	Canary                int32                  `protobuf:"varint,28,opt,name=canary,proto3" json:"canary,omitempty"`
	// contains filtered or unexported fields
}

func (*Deploy) Descriptor deprecated 

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

Deprecated: Use Deploy.ProtoReflect.Descriptor instead.

func (*Deploy) GetAction 

func (x *Deploy) GetAction() string

func (*Deploy) GetAppID 

func (x *Deploy) GetAppID() int32

func (*Deploy) GetAppName 

func (x *Deploy) GetAppName() string

func (*Deploy) GetAvailableReplicas 

func (x *Deploy) GetAvailableReplicas() int32

func (*Deploy) GetBatchIntervalSeconds 

func (x *Deploy) GetBatchIntervalSeconds() int32

func (*Deploy) GetBatchSize 

func (x *Deploy) GetBatchSize() int32

func (*Deploy) GetBatches 

func (x *Deploy) GetBatches() int32

func (*Deploy) GetCanary 

func (x *Deploy) GetCanary() int32

func (*Deploy) GetConditions 

func (x *Deploy) GetConditions() []*Batch

func (*Deploy) GetFailedReplicas 

func (x *Deploy) GetFailedReplicas() int32

func (*Deploy) GetFinished 

func (x *Deploy) GetFinished() bool

func (*Deploy) GetFinishedAt 

func (x *Deploy) GetFinishedAt() *timestamppb.Timestamp

func (*Deploy) GetFinishedBatches 

func (x *Deploy) GetFinishedBatches() int32

func (*Deploy) GetFinishedReplicas 

func (x *Deploy) GetFinishedReplicas() int32

func (*Deploy) GetGracefulPeriodSeconds 

func (x *Deploy) GetGracefulPeriodSeconds() int32

func (*Deploy) GetGroupID 

func (x *Deploy) GetGroupID() int32

func (*Deploy) GetInstanceName 

func (x *Deploy) GetInstanceName() string

func (*Deploy) GetMode 

func (x *Deploy) GetMode() string

func (*Deploy) GetName 

func (x *Deploy) GetName() string

func (*Deploy) GetNamespace 

func (x *Deploy) GetNamespace() string

func (*Deploy) GetPaused 

func (x *Deploy) GetPaused() bool

func (*Deploy) GetPhase 

func (x *Deploy) GetPhase() string

func (*Deploy) GetReplicas 

func (x *Deploy) GetReplicas() int32

func (*Deploy) GetStartedAt 

func (x *Deploy) GetStartedAt() *timestamppb.Timestamp

func (*Deploy) GetTimeoutSeconds 

func (x *Deploy) GetTimeoutSeconds() int32

func (*Deploy) GetUpdateRevision 

func (x *Deploy) GetUpdateRevision() string

func (*Deploy) GetUpdatedAt 

func (x *Deploy) GetUpdatedAt() *timestamppb.Timestamp

func (*Deploy) GetUpdatedReadyReplicas 

func (x *Deploy) GetUpdatedReadyReplicas() int32

func (*Deploy) GetUpdatedReplicas 

func (x *Deploy) GetUpdatedReplicas() int32

func (*Deploy) ProtoMessage 

func (*Deploy) ProtoMessage()

func (*Deploy) ProtoReflect 

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

func (*Deploy) Reset 

func (x *Deploy) Reset()

func (*Deploy) String 

func (x *Deploy) String() string

type DeployFilter 

type DeployFilter struct {
	Namespace    string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	InstanceName string                 `protobuf:"bytes,2,opt,name=instanceName,proto3" json:"instanceName,omitempty"`
	Action       string                 `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"`
	Start        int32                  `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	PageSize     int32                  `protobuf:"varint,5,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	After        *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=after,proto3" json:"after,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployFilter) Descriptor deprecated 

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

Deprecated: Use DeployFilter.ProtoReflect.Descriptor instead.

func (*DeployFilter) GetAction 

func (x *DeployFilter) GetAction() string

func (*DeployFilter) GetAfter 

func (x *DeployFilter) GetAfter() *timestamppb.Timestamp

func (*DeployFilter) GetInstanceName 

func (x *DeployFilter) GetInstanceName() string

func (*DeployFilter) GetNamespace 

func (x *DeployFilter) GetNamespace() string

func (*DeployFilter) GetPageSize 

func (x *DeployFilter) GetPageSize() int32

func (*DeployFilter) GetStart 

func (x *DeployFilter) GetStart() int32

func (*DeployFilter) ProtoMessage 

func (*DeployFilter) ProtoMessage()

func (*DeployFilter) ProtoReflect 

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

func (*DeployFilter) Reset 

func (x *DeployFilter) Reset()

func (*DeployFilter) String 

func (x *DeployFilter) String() string

type DeployFlowClient 

type DeployFlowClient interface {
	Get(ctx context.Context, in *DeployMetaRequest, opts ...grpc.CallOption) (*DeployReply, error)
	Gets(ctx context.Context, in *DeploysRequest, opts ...grpc.CallOption) (*DeploysReply, error)
	Cancel(ctx context.Context, in *DeployMetaRequest, opts ...grpc.CallOption) (DeployFlow_CancelClient, error)
	Pause(ctx context.Context, in *DeployMetaRequest, opts ...grpc.CallOption) (DeployFlow_PauseClient, error)
	Resume(ctx context.Context, in *DeployMetaRequest, opts ...grpc.CallOption) (DeployFlow_ResumeClient, error)
	Continue(ctx context.Context, in *ContinueRequest, opts ...grpc.CallOption) (*DeployReply, error)
	Next(ctx context.Context, in *NextRequest, opts ...grpc.CallOption) (*DeployReply, error)
	Delete(ctx context.Context, in *DeployMetaRequest, opts ...grpc.CallOption) (*EmptyReply, error)
	// Watch watches Deploy status changes continuously till the target state is met.
	// If target state is not specified, use current desired target state in DeployFlow spec.
	// Watch will be stopped when the deploy is gone or finished or an error happens.
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (DeployFlow_WatchClient, error)
	// ListAndWatch lists Deploys first, and then watch Deploy changes infinitely.
	ListAndWatch(ctx context.Context, in *DeploysRequest, opts ...grpc.CallOption) (DeployFlow_ListAndWatchClient, error)
}

DeployFlowClient is the client API for DeployFlow service.

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

func NewDeployFlowClient 

func NewDeployFlowClient(cc grpc.ClientConnInterface) DeployFlowClient

type DeployFlowServer 

type DeployFlowServer interface {
	Get(context.Context, *DeployMetaRequest) (*DeployReply, error)
	Gets(context.Context, *DeploysRequest) (*DeploysReply, error)
	Cancel(*DeployMetaRequest, DeployFlow_CancelServer) error
	Pause(*DeployMetaRequest, DeployFlow_PauseServer) error
	Resume(*DeployMetaRequest, DeployFlow_ResumeServer) error
	Continue(context.Context, *ContinueRequest) (*DeployReply, error)
	Next(context.Context, *NextRequest) (*DeployReply, error)
	Delete(context.Context, *DeployMetaRequest) (*EmptyReply, error)
	// Watch watches Deploy status changes continuously till the target state is met.
	// If target state is not specified, use current desired target state in DeployFlow spec.
	// Watch will be stopped when the deploy is gone or finished or an error happens.
	Watch(*WatchRequest, DeployFlow_WatchServer) error
	// ListAndWatch lists Deploys first, and then watch Deploy changes infinitely.
	ListAndWatch(*DeploysRequest, DeployFlow_ListAndWatchServer) error
}

DeployFlowServer is the server API for DeployFlow service.

type DeployFlow_CancelClient 

type DeployFlow_CancelClient interface {
	Recv() (*DeployReply, error)
	grpc.ClientStream
}

type DeployFlow_CancelServer 

type DeployFlow_CancelServer interface {
	Send(*DeployReply) error
	grpc.ServerStream
}

type DeployFlow_ListAndWatchClient 

type DeployFlow_ListAndWatchClient interface {
	Recv() (*DeploysReply, error)
	grpc.ClientStream
}

type DeployFlow_ListAndWatchServer 

type DeployFlow_ListAndWatchServer interface {
	Send(*DeploysReply) error
	grpc.ServerStream
}

type DeployFlow_PauseClient 

type DeployFlow_PauseClient interface {
	Recv() (*DeployReply, error)
	grpc.ClientStream
}

type DeployFlow_PauseServer 

type DeployFlow_PauseServer interface {
	Send(*DeployReply) error
	grpc.ServerStream
}

type DeployFlow_ResumeClient 

type DeployFlow_ResumeClient interface {
	Recv() (*DeployReply, error)
	grpc.ClientStream
}

type DeployFlow_ResumeServer 

type DeployFlow_ResumeServer interface {
	Send(*DeployReply) error
	grpc.ServerStream
}

type DeployFlow_WatchClient 

type DeployFlow_WatchClient interface {
	Recv() (*DeployReply, error)
	grpc.ClientStream
}

type DeployFlow_WatchServer 

type DeployFlow_WatchServer interface {
	Send(*DeployReply) error
	grpc.ServerStream
}

type DeployMeta 

type DeployMeta struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployMeta) Descriptor deprecated 

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

Deprecated: Use DeployMeta.ProtoReflect.Descriptor instead.

func (*DeployMeta) GetName 

func (x *DeployMeta) GetName() string

func (*DeployMeta) GetNamespace 

func (x *DeployMeta) GetNamespace() string

func (*DeployMeta) ProtoMessage 

func (*DeployMeta) ProtoMessage()

func (*DeployMeta) ProtoReflect 

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

func (*DeployMeta) Reset 

func (x *DeployMeta) Reset()

func (*DeployMeta) String 

func (x *DeployMeta) String() string

type DeployMetaRequest 

type DeployMetaRequest struct {
	Deploy *DeployMeta `protobuf:"bytes,1,opt,name=deploy,proto3" json:"deploy,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployMetaRequest) Descriptor deprecated 

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

Deprecated: Use DeployMetaRequest.ProtoReflect.Descriptor instead.

func (*DeployMetaRequest) GetDeploy 

func (x *DeployMetaRequest) GetDeploy() *DeployMeta

func (*DeployMetaRequest) ProtoMessage 

func (*DeployMetaRequest) ProtoMessage()

func (*DeployMetaRequest) ProtoReflect 

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

func (*DeployMetaRequest) Reset 

func (x *DeployMetaRequest) Reset()

func (*DeployMetaRequest) String 

func (x *DeployMetaRequest) String() string

type DeployReply 

type DeployReply struct {
	Deploy *Deploy `protobuf:"bytes,1,opt,name=deploy,proto3" json:"deploy,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployReply) Descriptor deprecated 

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

Deprecated: Use DeployReply.ProtoReflect.Descriptor instead.

func (*DeployReply) GetDeploy 

func (x *DeployReply) GetDeploy() *Deploy

func (*DeployReply) ProtoMessage 

func (*DeployReply) ProtoMessage()

func (*DeployReply) ProtoReflect 

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

func (*DeployReply) Reset 

func (x *DeployReply) Reset()

func (*DeployReply) String 

func (x *DeployReply) String() string

type DeploysReply 

type DeploysReply struct {
	Deploys []*Deploy `protobuf:"bytes,1,rep,name=deploys,proto3" json:"deploys,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploysReply) Descriptor deprecated 

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

Deprecated: Use DeploysReply.ProtoReflect.Descriptor instead.

func (*DeploysReply) GetDeploys 

func (x *DeploysReply) GetDeploys() []*Deploy

func (*DeploysReply) ProtoMessage 

func (*DeploysReply) ProtoMessage()

func (*DeploysReply) ProtoReflect 

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

func (*DeploysReply) Reset 

func (x *DeploysReply) Reset()

func (*DeploysReply) String 

func (x *DeploysReply) String() string

type DeploysRequest 

type DeploysRequest struct {
	Filter *DeployFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploysRequest) Descriptor deprecated 

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

Deprecated: Use DeploysRequest.ProtoReflect.Descriptor instead.

func (*DeploysRequest) GetFilter 

func (x *DeploysRequest) GetFilter() *DeployFilter

func (*DeploysRequest) ProtoMessage 

func (*DeploysRequest) ProtoMessage()

func (*DeploysRequest) ProtoReflect 

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

func (*DeploysRequest) Reset 

func (x *DeploysRequest) Reset()

func (*DeploysRequest) String 

func (x *DeploysRequest) String() string

type EmptyReply 

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

func (*EmptyReply) Descriptor deprecated 

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

Deprecated: Use EmptyReply.ProtoReflect.Descriptor instead.

func (*EmptyReply) ProtoMessage 

func (*EmptyReply) ProtoMessage()

func (*EmptyReply) ProtoReflect 

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

func (*EmptyReply) Reset 

func (x *EmptyReply) Reset()

func (*EmptyReply) String 

func (x *EmptyReply) String() string

type EnvVar 

type EnvVar struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvVar) Descriptor deprecated 

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

Deprecated: Use EnvVar.ProtoReflect.Descriptor instead.

func (*EnvVar) GetName 

func (x *EnvVar) GetName() string

func (*EnvVar) GetValue 

func (x *EnvVar) GetValue() string

func (*EnvVar) ProtoMessage 

func (*EnvVar) ProtoMessage()

func (*EnvVar) ProtoReflect 

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

func (*EnvVar) Reset 

func (x *EnvVar) Reset()

func (*EnvVar) String 

func (x *EnvVar) String() string

type NextRequest 

type NextRequest struct {
	Deploy *DeployMeta `protobuf:"bytes,1,opt,name=deploy,proto3" json:"deploy,omitempty"`
	// contains filtered or unexported fields
}

func (*NextRequest) Descriptor deprecated 

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

Deprecated: Use NextRequest.ProtoReflect.Descriptor instead.

func (*NextRequest) GetDeploy 

func (x *NextRequest) GetDeploy() *DeployMeta

func (*NextRequest) ProtoMessage 

func (*NextRequest) ProtoMessage()

func (*NextRequest) ProtoReflect 

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

func (*NextRequest) Reset 

func (x *NextRequest) Reset()

func (*NextRequest) String 

func (x *NextRequest) String() string

type NonUpdateStrategy 

type NonUpdateStrategy struct {
	BatchSize            string   `protobuf:"bytes,1,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	PodsToDelete         []string `protobuf:"bytes,2,rep,name=podsToDelete,proto3" json:"podsToDelete,omitempty"`
	Batches              int32    `protobuf:"varint,3,opt,name=batches,proto3" json:"batches,omitempty"`
	BatchIntervalSeconds int32    `protobuf:"varint,4,opt,name=batchIntervalSeconds,proto3" json:"batchIntervalSeconds,omitempty"`
	Mode                 string   `protobuf:"bytes,5,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*NonUpdateStrategy) Descriptor deprecated 

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

Deprecated: Use NonUpdateStrategy.ProtoReflect.Descriptor instead.

func (*NonUpdateStrategy) GetBatchIntervalSeconds 

func (x *NonUpdateStrategy) GetBatchIntervalSeconds() int32

func (*NonUpdateStrategy) GetBatchSize 

func (x *NonUpdateStrategy) GetBatchSize() string

func (*NonUpdateStrategy) GetBatches 

func (x *NonUpdateStrategy) GetBatches() int32

func (*NonUpdateStrategy) GetMode 

func (x *NonUpdateStrategy) GetMode() string

func (*NonUpdateStrategy) GetPodsToDelete 

func (x *NonUpdateStrategy) GetPodsToDelete() []string

func (*NonUpdateStrategy) ProtoMessage 

func (*NonUpdateStrategy) ProtoMessage()

func (*NonUpdateStrategy) ProtoReflect 

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

func (*NonUpdateStrategy) Reset 

func (x *NonUpdateStrategy) Reset()

func (*NonUpdateStrategy) String 

func (x *NonUpdateStrategy) String() string

type PodInfo 

type PodInfo struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ip           string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Port         int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Phase        string `protobuf:"bytes,4,opt,name=phase,proto3" json:"phase,omitempty"`
	PullInStatus string `protobuf:"bytes,5,opt,name=pullInStatus,proto3" json:"pullInStatus,omitempty"`
	// contains filtered or unexported fields
}

func (*PodInfo) Descriptor deprecated 

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

Deprecated: Use PodInfo.ProtoReflect.Descriptor instead.

func (*PodInfo) GetIp 

func (x *PodInfo) GetIp() string

func (*PodInfo) GetName 

func (x *PodInfo) GetName() string

func (*PodInfo) GetPhase 

func (x *PodInfo) GetPhase() string

func (*PodInfo) GetPort 

func (x *PodInfo) GetPort() int32

func (*PodInfo) GetPullInStatus 

func (x *PodInfo) GetPullInStatus() string

func (*PodInfo) ProtoMessage 

func (*PodInfo) ProtoMessage()

func (*PodInfo) ProtoReflect 

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

func (*PodInfo) Reset 

func (x *PodInfo) Reset()

func (*PodInfo) String 

func (x *PodInfo) String() string

type SidecarSpec 

type SidecarSpec struct {
	Name             string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image            string           `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Envs             []*EnvVar        `protobuf:"bytes,3,rep,name=envs,proto3" json:"envs,omitempty"`
	Cpu              string           `protobuf:"bytes,4,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory           string           `protobuf:"bytes,5,opt,name=memory,proto3" json:"memory,omitempty"`
	GuaranteedCPU    string           `protobuf:"bytes,6,opt,name=guaranteedCPU,proto3" json:"guaranteedCPU,omitempty"`
	GuaranteedMemory string           `protobuf:"bytes,7,opt,name=guaranteedMemory,proto3" json:"guaranteedMemory,omitempty"`
	ContainerPorts   []*ContainerPort `protobuf:"bytes,8,rep,name=containerPorts,proto3" json:"containerPorts,omitempty"`
	// contains filtered or unexported fields
}

func (*SidecarSpec) Descriptor deprecated 

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

Deprecated: Use SidecarSpec.ProtoReflect.Descriptor instead.

func (*SidecarSpec) GetContainerPorts 

func (x *SidecarSpec) GetContainerPorts() []*ContainerPort

func (*SidecarSpec) GetCpu 

func (x *SidecarSpec) GetCpu() string

func (*SidecarSpec) GetEnvs 

func (x *SidecarSpec) GetEnvs() []*EnvVar

func (*SidecarSpec) GetGuaranteedCPU 

func (x *SidecarSpec) GetGuaranteedCPU() string

func (*SidecarSpec) GetGuaranteedMemory 

func (x *SidecarSpec) GetGuaranteedMemory() string

func (*SidecarSpec) GetImage 

func (x *SidecarSpec) GetImage() string

func (*SidecarSpec) GetMemory 

func (x *SidecarSpec) GetMemory() string

func (*SidecarSpec) GetName 

func (x *SidecarSpec) GetName() string

func (*SidecarSpec) ProtoMessage 

func (*SidecarSpec) ProtoMessage()

func (*SidecarSpec) ProtoReflect 

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

func (*SidecarSpec) Reset 

func (x *SidecarSpec) Reset()

func (*SidecarSpec) String 

func (x *SidecarSpec) String() string

type TargetState 

type TargetState struct {
	Stage   string `protobuf:"bytes,1,opt,name=stage,proto3" json:"stage,omitempty"`
	Batches int32  `protobuf:"varint,2,opt,name=batches,proto3" json:"batches,omitempty"`
	// contains filtered or unexported fields
}

func (*TargetState) Descriptor deprecated 

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

Deprecated: Use TargetState.ProtoReflect.Descriptor instead.

func (*TargetState) GetBatches 

func (x *TargetState) GetBatches() int32

func (*TargetState) GetStage 

func (x *TargetState) GetStage() string

func (*TargetState) ProtoMessage 

func (*TargetState) ProtoMessage()

func (*TargetState) ProtoReflect 

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

func (*TargetState) Reset 

func (x *TargetState) Reset()

func (*TargetState) String 

func (x *TargetState) String() string

type UnimplementedDeployFlowServer 

type UnimplementedDeployFlowServer struct {
}

UnimplementedDeployFlowServer can be embedded to have forward compatible implementations.

func (*UnimplementedDeployFlowServer) Cancel 

func (*UnimplementedDeployFlowServer) Cancel(*DeployMetaRequest, DeployFlow_CancelServer) error

func (*UnimplementedDeployFlowServer) Continue 

func (*UnimplementedDeployFlowServer) Continue(context.Context, *ContinueRequest) (*DeployReply, error)

func (*UnimplementedDeployFlowServer) Delete 

func (*UnimplementedDeployFlowServer) Delete(context.Context, *DeployMetaRequest) (*EmptyReply, error)

func (*UnimplementedDeployFlowServer) Get 

func (*UnimplementedDeployFlowServer) Get(context.Context, *DeployMetaRequest) (*DeployReply, error)

func (*UnimplementedDeployFlowServer) Gets 

func (*UnimplementedDeployFlowServer) Gets(context.Context, *DeploysRequest) (*DeploysReply, error)

func (*UnimplementedDeployFlowServer) ListAndWatch 

func (*UnimplementedDeployFlowServer) ListAndWatch(*DeploysRequest, DeployFlow_ListAndWatchServer) error

func (*UnimplementedDeployFlowServer) Next 

func (*UnimplementedDeployFlowServer) Next(context.Context, *NextRequest) (*DeployReply, error)

func (*UnimplementedDeployFlowServer) Pause 

func (*UnimplementedDeployFlowServer) Pause(*DeployMetaRequest, DeployFlow_PauseServer) error

func (*UnimplementedDeployFlowServer) Resume 

func (*UnimplementedDeployFlowServer) Resume(*DeployMetaRequest, DeployFlow_ResumeServer) error

func (*UnimplementedDeployFlowServer) Watch 

func (*UnimplementedDeployFlowServer) Watch(*WatchRequest, DeployFlow_WatchServer) error

type UpdateStrategy 

type UpdateStrategy struct {
	Canary               int32  `protobuf:"varint,1,opt,name=canary,proto3" json:"canary,omitempty"`
	BatchSize            string `protobuf:"bytes,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	NoPullIn             bool   `protobuf:"varint,3,opt,name=noPullIn,proto3" json:"noPullIn,omitempty"`
	Stage                string `protobuf:"bytes,4,opt,name=stage,proto3" json:"stage,omitempty"`
	Batches              int32  `protobuf:"varint,5,opt,name=batches,proto3" json:"batches,omitempty"`
	BatchIntervalSeconds int32  `protobuf:"varint,6,opt,name=batchIntervalSeconds,proto3" json:"batchIntervalSeconds,omitempty"`
	Mode                 string `protobuf:"bytes,7,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStrategy) Descriptor deprecated 

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

Deprecated: Use UpdateStrategy.ProtoReflect.Descriptor instead.

func (*UpdateStrategy) GetBatchIntervalSeconds 

func (x *UpdateStrategy) GetBatchIntervalSeconds() int32

func (*UpdateStrategy) GetBatchSize 

func (x *UpdateStrategy) GetBatchSize() string

func (*UpdateStrategy) GetBatches 

func (x *UpdateStrategy) GetBatches() int32

func (*UpdateStrategy) GetCanary 

func (x *UpdateStrategy) GetCanary() int32

func (*UpdateStrategy) GetMode 

func (x *UpdateStrategy) GetMode() string

func (*UpdateStrategy) GetNoPullIn 

func (x *UpdateStrategy) GetNoPullIn() bool

func (*UpdateStrategy) GetStage 

func (x *UpdateStrategy) GetStage() string

func (*UpdateStrategy) ProtoMessage 

func (*UpdateStrategy) ProtoMessage()

func (*UpdateStrategy) ProtoReflect 

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

func (*UpdateStrategy) Reset 

func (x *UpdateStrategy) Reset()

func (*UpdateStrategy) String 

func (x *UpdateStrategy) String() string

type WatchRequest 

type WatchRequest struct {
	Deploy *DeployMeta  `protobuf:"bytes,1,opt,name=deploy,proto3" json:"deploy,omitempty"`
	Target *TargetState `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchRequest) Descriptor deprecated 

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

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) GetDeploy 

func (x *WatchRequest) GetDeploy() *DeployMeta

func (*WatchRequest) GetTarget 

func (x *WatchRequest) GetTarget() *TargetState

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect 

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

func (*WatchRequest) Reset 

func (x *WatchRequest) Reset()

func (*WatchRequest) String 

func (x *WatchRequest) 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.