pipeline

package
v0.0.0-...-af36fda Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2024 License: Apache-2.0 Imports: 9 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ContainerType_name = map[int32]string{
		0: "CONTAINER_TYPE_UNSPECIFIED",
		1: "CONTAINER_TYPE_MAIN",
		2: "CONTAINER_TYPE_SIDECAR",
		3: "CONTAINER_TYPE_INIT",
	}
	ContainerType_value = map[string]int32{
		"CONTAINER_TYPE_UNSPECIFIED": 0,
		"CONTAINER_TYPE_MAIN":        1,
		"CONTAINER_TYPE_SIDECAR":     2,
		"CONTAINER_TYPE_INIT":        3,
	}
)

Enum value maps for ContainerType.

View Source 
var (
	JobExecutionState_name = map[int32]string{
		0: "JOB_STATE_UNSPECIFIED",
		1: "JOB_STATE_ONGOING",
		2: "JOB_STATE_COMPLETED",
		3: "JOB_STATE_FAILED",
		4: "JOB_STATE_TERMINATED",
	}
	JobExecutionState_value = map[string]int32{
		"JOB_STATE_UNSPECIFIED": 0,
		"JOB_STATE_ONGOING":     1,
		"JOB_STATE_COMPLETED":   2,
		"JOB_STATE_FAILED":      3,
		"JOB_STATE_TERMINATED":  4,
	}
)

Enum value maps for JobExecutionState.

View Source 
var (
	ObjectState_name = map[int32]string{
		0: "OBJECT_STATE_UNSPECIFIED",
		1: "OBJECT_STATE_HEALTHY",
		2: "OBJECT_STATE_PENDING",
		3: "OBJECT_STATE_ERROR",
	}
	ObjectState_value = map[string]int32{
		"OBJECT_STATE_UNSPECIFIED": 0,
		"OBJECT_STATE_HEALTHY":     1,
		"OBJECT_STATE_PENDING":     2,
		"OBJECT_STATE_ERROR":       3,
	}
)

Enum value maps for ObjectState.

View Source 
var (
	ObjectOutcome_name = map[int32]string{
		0: "OBJECT_OUTCOME_UNSPECIFIED",
		1: "OBJECT_OUTCOME_CREATE",
		2: "OBJECT_OUTCOME_UPDATE",
		3: "OBJECT_OUTCOME_DELETE",
		4: "OBJECT_OUTCOME_UNCHANGED",
		5: "OBJECT_OUTCOME_ALREADY_EXISTS",
	}
	ObjectOutcome_value = map[string]int32{
		"OBJECT_OUTCOME_UNSPECIFIED":    0,
		"OBJECT_OUTCOME_CREATE":         1,
		"OBJECT_OUTCOME_UPDATE":         2,
		"OBJECT_OUTCOME_DELETE":         3,
		"OBJECT_OUTCOME_UNCHANGED":      4,
		"OBJECT_OUTCOME_ALREADY_EXISTS": 5,
	}
)

Enum value maps for ObjectOutcome.

View Source 
var File_operator_api_v1_pipeline_object_status_proto protoreflect.FileDescriptor
View Source 
var File_operator_api_v1_pipeline_service_proto protoreflect.FileDescriptor
View Source 
var Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1.pipeline.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DryRun",
			Handler:    _Service_DryRun_Handler,
		},
		{
			MethodName: "DryRunPluginConfig",
			Handler:    _Service_DryRunPluginConfig_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchObjectStatus",
			Handler:       _Service_WatchObjectStatus_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "operator/api/v1/pipeline/service.proto",
}

Service_ServiceDesc is the grpc.ServiceDesc for Service service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterServiceServer 

func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

Types

type CapsuleStatus 

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

func (*CapsuleStatus) Descriptor deprecated 

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

Deprecated: Use CapsuleStatus.ProtoReflect.Descriptor instead.

func (*CapsuleStatus) ProtoMessage 

func (*CapsuleStatus) ProtoMessage()

func (*CapsuleStatus) ProtoReflect 

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

func (*CapsuleStatus) Reset 

func (x *CapsuleStatus) Reset()

func (*CapsuleStatus) String 

func (x *CapsuleStatus) String() string

type ConfigFileStatus 

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

func (*ConfigFileStatus) Descriptor deprecated 

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

Deprecated: Use ConfigFileStatus.ProtoReflect.Descriptor instead.

func (*ConfigFileStatus) ProtoMessage 

func (*ConfigFileStatus) ProtoMessage()

func (*ConfigFileStatus) ProtoReflect 

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

func (*ConfigFileStatus) Reset 

func (x *ConfigFileStatus) Reset()

func (*ConfigFileStatus) String 

func (x *ConfigFileStatus) String() string

type ContainerStatus 

type ContainerStatus struct {
	RestartCount    uint32                                `protobuf:"varint,1,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
	LastTermination *ContainerStatus_ContainerTermination `protobuf:"bytes,2,opt,name=last_termination,json=lastTermination,proto3" json:"last_termination,omitempty"`
	StartedAt       *timestamppb.Timestamp                `protobuf:"bytes,3,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	Image           string                                `protobuf:"bytes,4,opt,name=image,proto3" json:"image,omitempty"`
	Type            ContainerType                         `protobuf:"varint,5,opt,name=type,proto3,enum=api.v1.pipeline.ContainerType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerStatus) Descriptor deprecated 

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

Deprecated: Use ContainerStatus.ProtoReflect.Descriptor instead.

func (*ContainerStatus) GetImage 

func (x *ContainerStatus) GetImage() string

func (*ContainerStatus) GetLastTermination 

func (x *ContainerStatus) GetLastTermination() *ContainerStatus_ContainerTermination

func (*ContainerStatus) GetRestartCount 

func (x *ContainerStatus) GetRestartCount() uint32

func (*ContainerStatus) GetStartedAt 

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

func (*ContainerStatus) GetType 

func (x *ContainerStatus) GetType() ContainerType

func (*ContainerStatus) ProtoMessage 

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) ProtoReflect 

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

func (*ContainerStatus) Reset 

func (x *ContainerStatus) Reset()

func (*ContainerStatus) String 

func (x *ContainerStatus) String() string

type ContainerStatus_ContainerTermination 

type ContainerStatus_ContainerTermination struct {

	// Exit status from the last termination of the container
	ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// Signal from the last termination of the container
	Signal int32 `protobuf:"varint,2,opt,name=signal,proto3" json:"signal,omitempty"`
	// (brief) reason from the last termination of the container
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// Message regarding the last termination of the container
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// Time at which previous execution of the container started
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// Time at which the container last terminated
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// Container's ID in the format 'type://container_id'
	ContainerId string `protobuf:"bytes,7,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

Information about the last container termination.

func (*ContainerStatus_ContainerTermination) Descriptor deprecated 

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

Deprecated: Use ContainerStatus_ContainerTermination.ProtoReflect.Descriptor instead.

func (*ContainerStatus_ContainerTermination) GetContainerId 

func (x *ContainerStatus_ContainerTermination) GetContainerId() string

func (*ContainerStatus_ContainerTermination) GetExitCode 

func (x *ContainerStatus_ContainerTermination) GetExitCode() int32

func (*ContainerStatus_ContainerTermination) GetFinishedAt 

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

func (*ContainerStatus_ContainerTermination) GetMessage 

func (x *ContainerStatus_ContainerTermination) GetMessage() string

func (*ContainerStatus_ContainerTermination) GetReason 

func (x *ContainerStatus_ContainerTermination) GetReason() string

func (*ContainerStatus_ContainerTermination) GetSignal 

func (x *ContainerStatus_ContainerTermination) GetSignal() int32

func (*ContainerStatus_ContainerTermination) GetStartedAt 

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

func (*ContainerStatus_ContainerTermination) ProtoMessage 

func (*ContainerStatus_ContainerTermination) ProtoMessage()

func (*ContainerStatus_ContainerTermination) ProtoReflect 

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

func (*ContainerStatus_ContainerTermination) Reset 

func (x *ContainerStatus_ContainerTermination) Reset()

func (*ContainerStatus_ContainerTermination) String 

func (x *ContainerStatus_ContainerTermination) String() string

type ContainerType 

type ContainerType int32
const (
	ContainerType_CONTAINER_TYPE_UNSPECIFIED ContainerType = 0
	ContainerType_CONTAINER_TYPE_MAIN        ContainerType = 1
	ContainerType_CONTAINER_TYPE_SIDECAR     ContainerType = 2
	ContainerType_CONTAINER_TYPE_INIT        ContainerType = 3
)

func (ContainerType) Descriptor 

func (ContainerType) Descriptor() protoreflect.EnumDescriptor

func (ContainerType) Enum 

func (x ContainerType) Enum() *ContainerType

func (ContainerType) EnumDescriptor deprecated 

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

Deprecated: Use ContainerType.Descriptor instead.

func (ContainerType) Number 

func (x ContainerType) Number() protoreflect.EnumNumber

func (ContainerType) String 

func (x ContainerType) String() string

func (ContainerType) Type 

func (ContainerType) Type() protoreflect.EnumType

type CronjobStatus 

type CronjobStatus struct {
	Schedule string `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// contains filtered or unexported fields
}

func (*CronjobStatus) Descriptor deprecated 

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

Deprecated: Use CronjobStatus.ProtoReflect.Descriptor instead.

func (*CronjobStatus) GetSchedule 

func (x *CronjobStatus) GetSchedule() string

func (*CronjobStatus) ProtoMessage 

func (*CronjobStatus) ProtoMessage()

func (*CronjobStatus) ProtoReflect 

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

func (*CronjobStatus) Reset 

func (x *CronjobStatus) Reset()

func (*CronjobStatus) String 

func (x *CronjobStatus) String() string

type DryRunPluginConfigRequest 

type DryRunPluginConfigRequest struct {
	Namespace      string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Capsule        string `protobuf:"bytes,2,opt,name=capsule,proto3" json:"capsule,omitempty"`
	OperatorConfig string `protobuf:"bytes,3,opt,name=operator_config,json=operatorConfig,proto3" json:"operator_config,omitempty"`
	CapsuleSpec    string `protobuf:"bytes,4,opt,name=capsule_spec,json=capsuleSpec,proto3" json:"capsule_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*DryRunPluginConfigRequest) Descriptor deprecated 

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

Deprecated: Use DryRunPluginConfigRequest.ProtoReflect.Descriptor instead.

func (*DryRunPluginConfigRequest) GetCapsule 

func (x *DryRunPluginConfigRequest) GetCapsule() string

func (*DryRunPluginConfigRequest) GetCapsuleSpec 

func (x *DryRunPluginConfigRequest) GetCapsuleSpec() string

func (*DryRunPluginConfigRequest) GetNamespace 

func (x *DryRunPluginConfigRequest) GetNamespace() string

func (*DryRunPluginConfigRequest) GetOperatorConfig 

func (x *DryRunPluginConfigRequest) GetOperatorConfig() string

func (*DryRunPluginConfigRequest) ProtoMessage 

func (*DryRunPluginConfigRequest) ProtoMessage()

func (*DryRunPluginConfigRequest) ProtoReflect 

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

func (*DryRunPluginConfigRequest) Reset 

func (x *DryRunPluginConfigRequest) Reset()

func (*DryRunPluginConfigRequest) String 

func (x *DryRunPluginConfigRequest) String() string

type DryRunPluginConfigResponse 

type DryRunPluginConfigResponse struct {
	Steps []*StepConfig `protobuf:"bytes,1,rep,name=steps,proto3" json:"steps,omitempty"`
	// contains filtered or unexported fields
}

func (*DryRunPluginConfigResponse) Descriptor deprecated 

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

Deprecated: Use DryRunPluginConfigResponse.ProtoReflect.Descriptor instead.

func (*DryRunPluginConfigResponse) GetSteps 

func (x *DryRunPluginConfigResponse) GetSteps() []*StepConfig

func (*DryRunPluginConfigResponse) ProtoMessage 

func (*DryRunPluginConfigResponse) ProtoMessage()

func (*DryRunPluginConfigResponse) ProtoReflect 

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

func (*DryRunPluginConfigResponse) Reset 

func (x *DryRunPluginConfigResponse) Reset()

func (*DryRunPluginConfigResponse) String 

func (x *DryRunPluginConfigResponse) String() string

type DryRunRequest 

type DryRunRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Capsule   string `protobuf:"bytes,2,opt,name=capsule,proto3" json:"capsule,omitempty"`
	// A YAML encoded OperatorConfig, to be used when processing the pipeline.
	OperatorConfig string `protobuf:"bytes,3,opt,name=operator_config,json=operatorConfig,proto3" json:"operator_config,omitempty"`
	// An optional YAML encoded capsule spec, to be used instead of the current
	// one.
	CapsuleSpec string `protobuf:"bytes,4,opt,name=capsule_spec,json=capsuleSpec,proto3" json:"capsule_spec,omitempty"`
	// If force is enabled, existing resources will be handled as if they were
	// supposed to be replaced.
	Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	// Additional objects to be considered materialized when performing the dryrun
	AdditionalObjects []*Object `protobuf:"bytes,6,rep,name=additional_objects,json=additionalObjects,proto3" json:"additional_objects,omitempty"`
	// contains filtered or unexported fields
}

func (*DryRunRequest) Descriptor deprecated 

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

Deprecated: Use DryRunRequest.ProtoReflect.Descriptor instead.

func (*DryRunRequest) GetAdditionalObjects 

func (x *DryRunRequest) GetAdditionalObjects() []*Object

func (*DryRunRequest) GetCapsule 

func (x *DryRunRequest) GetCapsule() string

func (*DryRunRequest) GetCapsuleSpec 

func (x *DryRunRequest) GetCapsuleSpec() string

func (*DryRunRequest) GetForce 

func (x *DryRunRequest) GetForce() bool

func (*DryRunRequest) GetNamespace 

func (x *DryRunRequest) GetNamespace() string

func (*DryRunRequest) GetOperatorConfig 

func (x *DryRunRequest) GetOperatorConfig() string

func (*DryRunRequest) ProtoMessage 

func (*DryRunRequest) ProtoMessage()

func (*DryRunRequest) ProtoReflect 

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

func (*DryRunRequest) Reset 

func (x *DryRunRequest) Reset()

func (*DryRunRequest) String 

func (x *DryRunRequest) String() string

type DryRunResponse 

type DryRunResponse struct {
	InputObjects  []*Object       `protobuf:"bytes,1,rep,name=input_objects,json=inputObjects,proto3" json:"input_objects,omitempty"`
	OutputObjects []*ObjectChange `protobuf:"bytes,2,rep,name=output_objects,json=outputObjects,proto3" json:"output_objects,omitempty"`
	// contains filtered or unexported fields
}

func (*DryRunResponse) Descriptor deprecated 

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

Deprecated: Use DryRunResponse.ProtoReflect.Descriptor instead.

func (*DryRunResponse) GetInputObjects 

func (x *DryRunResponse) GetInputObjects() []*Object

func (*DryRunResponse) GetOutputObjects 

func (x *DryRunResponse) GetOutputObjects() []*ObjectChange

func (*DryRunResponse) ProtoMessage 

func (*DryRunResponse) ProtoMessage()

func (*DryRunResponse) ProtoReflect 

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

func (*DryRunResponse) Reset 

func (x *DryRunResponse) Reset()

func (*DryRunResponse) String 

func (x *DryRunResponse) String() string

type GVK 

type GVK struct {
	Group   string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Kind    string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*GVK) Descriptor deprecated 

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

Deprecated: Use GVK.ProtoReflect.Descriptor instead.

func (*GVK) GetGroup 

func (x *GVK) GetGroup() string

func (*GVK) GetKind 

func (x *GVK) GetKind() string

func (*GVK) GetVersion 

func (x *GVK) GetVersion() string

func (*GVK) ProtoMessage 

func (*GVK) ProtoMessage()

func (*GVK) ProtoReflect 

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

func (*GVK) Reset 

func (x *GVK) Reset()

func (*GVK) String 

func (x *GVK) String() string

type InstanceStatus 

type InstanceStatus struct {
	RolloutId uint64 `protobuf:"varint,1,opt,name=rollout_id,json=rolloutId,proto3" json:"rollout_id,omitempty"`
	Node      string `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceStatus) Descriptor deprecated 

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

Deprecated: Use InstanceStatus.ProtoReflect.Descriptor instead.

func (*InstanceStatus) GetNode 

func (x *InstanceStatus) GetNode() string

func (*InstanceStatus) GetRolloutId 

func (x *InstanceStatus) GetRolloutId() uint64

func (*InstanceStatus) ProtoMessage 

func (*InstanceStatus) ProtoMessage()

func (*InstanceStatus) ProtoReflect 

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

func (*InstanceStatus) Reset 

func (x *InstanceStatus) Reset()

func (*InstanceStatus) String 

func (x *InstanceStatus) String() string

type InterfaceStatus 

type InterfaceStatus struct {
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceStatus) Descriptor deprecated 

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

Deprecated: Use InterfaceStatus.ProtoReflect.Descriptor instead.

func (*InterfaceStatus) GetPort 

func (x *InterfaceStatus) GetPort() uint32

func (*InterfaceStatus) ProtoMessage 

func (*InterfaceStatus) ProtoMessage()

func (*InterfaceStatus) ProtoReflect 

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

func (*InterfaceStatus) Reset 

func (x *InterfaceStatus) Reset()

func (*InterfaceStatus) String 

func (x *InterfaceStatus) String() string

type JobExecutionState 

type JobExecutionState int32

Different states a job execution can be in 

const (
	// Default value.
	JobExecutionState_JOB_STATE_UNSPECIFIED JobExecutionState = 0
	// The job is running.
	JobExecutionState_JOB_STATE_ONGOING JobExecutionState = 1
	// The job completed successfully.
	JobExecutionState_JOB_STATE_COMPLETED JobExecutionState = 2
	// The job failed.
	JobExecutionState_JOB_STATE_FAILED JobExecutionState = 3
	// The job was terminated.
	JobExecutionState_JOB_STATE_TERMINATED JobExecutionState = 4
)

func (JobExecutionState) Descriptor 

func (JobExecutionState) Descriptor() protoreflect.EnumDescriptor

func (JobExecutionState) Enum 

func (x JobExecutionState) Enum() *JobExecutionState

func (JobExecutionState) EnumDescriptor deprecated 

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

Deprecated: Use JobExecutionState.Descriptor instead.

func (JobExecutionState) Number 

func (x JobExecutionState) Number() protoreflect.EnumNumber

func (JobExecutionState) String 

func (x JobExecutionState) String() string

func (JobExecutionState) Type 

func (JobExecutionState) Type() protoreflect.EnumType

type JobExecutionStatus 

type JobExecutionStatus struct {
	JobName    string                 `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	RolloutId  uint64                 `protobuf:"varint,2,opt,name=rollout_id,json=rolloutId,proto3" json:"rollout_id,omitempty"`
	Retries    int32                  `protobuf:"varint,3,opt,name=retries,proto3" json:"retries,omitempty"`
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	State      JobExecutionState      `protobuf:"varint,6,opt,name=state,proto3,enum=api.v1.pipeline.JobExecutionState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*JobExecutionStatus) Descriptor deprecated 

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

Deprecated: Use JobExecutionStatus.ProtoReflect.Descriptor instead.

func (*JobExecutionStatus) GetCreatedAt 

func (x *JobExecutionStatus) GetCreatedAt() *timestamppb.Timestamp

func (*JobExecutionStatus) GetFinishedAt 

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

func (*JobExecutionStatus) GetJobName 

func (x *JobExecutionStatus) GetJobName() string

func (*JobExecutionStatus) GetRetries 

func (x *JobExecutionStatus) GetRetries() int32

func (*JobExecutionStatus) GetRolloutId 

func (x *JobExecutionStatus) GetRolloutId() uint64

func (*JobExecutionStatus) GetState 

func (x *JobExecutionStatus) GetState() JobExecutionState

func (*JobExecutionStatus) ProtoMessage 

func (*JobExecutionStatus) ProtoMessage()

func (*JobExecutionStatus) ProtoReflect 

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

func (*JobExecutionStatus) Reset 

func (x *JobExecutionStatus) Reset()

func (*JobExecutionStatus) String 

func (x *JobExecutionStatus) String() string

type Object 

type Object struct {
	Gvk     *GVK   `protobuf:"bytes,1,opt,name=gvk,proto3" json:"gvk,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*Object) Descriptor deprecated 

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

Deprecated: Use Object.ProtoReflect.Descriptor instead.

func (*Object) GetContent 

func (x *Object) GetContent() string

func (*Object) GetGvk 

func (x *Object) GetGvk() *GVK

func (*Object) GetName 

func (x *Object) GetName() string

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) ProtoReflect 

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

func (*Object) Reset 

func (x *Object) Reset()

func (*Object) String 

func (x *Object) String() string

type ObjectChange 

type ObjectChange struct {
	Object  *Object       `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Outcome ObjectOutcome `protobuf:"varint,2,opt,name=outcome,proto3,enum=api.v1.pipeline.ObjectOutcome" json:"outcome,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectChange) Descriptor deprecated 

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

Deprecated: Use ObjectChange.ProtoReflect.Descriptor instead.

func (*ObjectChange) GetObject 

func (x *ObjectChange) GetObject() *Object

func (*ObjectChange) GetOutcome 

func (x *ObjectChange) GetOutcome() ObjectOutcome

func (*ObjectChange) ProtoMessage 

func (*ObjectChange) ProtoMessage()

func (*ObjectChange) ProtoReflect 

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

func (*ObjectChange) Reset 

func (x *ObjectChange) Reset()

func (*ObjectChange) String 

func (x *ObjectChange) String() string

type ObjectCondition 

type ObjectCondition struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	State     ObjectState            `protobuf:"varint,3,opt,name=state,proto3,enum=api.v1.pipeline.ObjectState" json:"state,omitempty"`
	Message   string                 `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectCondition) Descriptor deprecated 

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

Deprecated: Use ObjectCondition.ProtoReflect.Descriptor instead.

func (*ObjectCondition) GetMessage 

func (x *ObjectCondition) GetMessage() string

func (*ObjectCondition) GetName 

func (x *ObjectCondition) GetName() string

func (*ObjectCondition) GetState 

func (x *ObjectCondition) GetState() ObjectState

func (*ObjectCondition) GetUpdatedAt 

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

func (*ObjectCondition) ProtoMessage 

func (*ObjectCondition) ProtoMessage()

func (*ObjectCondition) ProtoReflect 

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

func (*ObjectCondition) Reset 

func (x *ObjectCondition) Reset()

func (*ObjectCondition) String 

func (x *ObjectCondition) String() string

type ObjectOutcome 

type ObjectOutcome int32
const (
	ObjectOutcome_OBJECT_OUTCOME_UNSPECIFIED    ObjectOutcome = 0
	ObjectOutcome_OBJECT_OUTCOME_CREATE         ObjectOutcome = 1
	ObjectOutcome_OBJECT_OUTCOME_UPDATE         ObjectOutcome = 2
	ObjectOutcome_OBJECT_OUTCOME_DELETE         ObjectOutcome = 3
	ObjectOutcome_OBJECT_OUTCOME_UNCHANGED      ObjectOutcome = 4
	ObjectOutcome_OBJECT_OUTCOME_ALREADY_EXISTS ObjectOutcome = 5
)

func (ObjectOutcome) Descriptor 

func (ObjectOutcome) Descriptor() protoreflect.EnumDescriptor

func (ObjectOutcome) Enum 

func (x ObjectOutcome) Enum() *ObjectOutcome

func (ObjectOutcome) EnumDescriptor deprecated 

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

Deprecated: Use ObjectOutcome.Descriptor instead.

func (ObjectOutcome) Number 

func (x ObjectOutcome) Number() protoreflect.EnumNumber

func (ObjectOutcome) String 

func (x ObjectOutcome) String() string

func (ObjectOutcome) Type 

func (ObjectOutcome) Type() protoreflect.EnumType

type ObjectRef 

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

func (*ObjectRef) Descriptor deprecated 

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

Deprecated: Use ObjectRef.ProtoReflect.Descriptor instead.

func (*ObjectRef) GetGvk 

func (x *ObjectRef) GetGvk() *GVK

func (*ObjectRef) GetName 

func (x *ObjectRef) GetName() string

func (*ObjectRef) GetNamespace 

func (x *ObjectRef) GetNamespace() string

func (*ObjectRef) ProtoMessage 

func (*ObjectRef) ProtoMessage()

func (*ObjectRef) ProtoReflect 

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

func (*ObjectRef) Reset 

func (x *ObjectRef) Reset()

func (*ObjectRef) String 

func (x *ObjectRef) String() string

type ObjectState 

type ObjectState int32
const (
	ObjectState_OBJECT_STATE_UNSPECIFIED ObjectState = 0
	ObjectState_OBJECT_STATE_HEALTHY     ObjectState = 1
	ObjectState_OBJECT_STATE_PENDING     ObjectState = 2
	ObjectState_OBJECT_STATE_ERROR       ObjectState = 3
)

func (ObjectState) Descriptor 

func (ObjectState) Descriptor() protoreflect.EnumDescriptor

func (ObjectState) Enum 

func (x ObjectState) Enum() *ObjectState

func (ObjectState) EnumDescriptor deprecated 

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

Deprecated: Use ObjectState.Descriptor instead.

func (ObjectState) Number 

func (x ObjectState) Number() protoreflect.EnumNumber

func (ObjectState) String 

func (x ObjectState) String() string

func (ObjectState) Type 

func (ObjectState) Type() protoreflect.EnumType

type ObjectStatus 

type ObjectStatus struct {
	ObjectRef *ObjectRef        `protobuf:"bytes,1,opt,name=object_ref,json=objectRef,proto3" json:"object_ref,omitempty"`
	Info      *ObjectStatusInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// The createdTimestamp from the kubernetes object.
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt  *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	DeletionAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=deletion_at,json=deletionAt,proto3" json:"deletion_at,omitempty"`
	Parent     *ObjectRef             `protobuf:"bytes,4,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStatus) Descriptor deprecated 

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

Deprecated: Use ObjectStatus.ProtoReflect.Descriptor instead.

func (*ObjectStatus) GetCreatedAt 

func (x *ObjectStatus) GetCreatedAt() *timestamppb.Timestamp

func (*ObjectStatus) GetDeletionAt 

func (x *ObjectStatus) GetDeletionAt() *timestamppb.Timestamp

func (*ObjectStatus) GetInfo 

func (x *ObjectStatus) GetInfo() *ObjectStatusInfo

func (*ObjectStatus) GetObjectRef 

func (x *ObjectStatus) GetObjectRef() *ObjectRef

func (*ObjectStatus) GetParent 

func (x *ObjectStatus) GetParent() *ObjectRef

func (*ObjectStatus) GetUpdatedAt 

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

func (*ObjectStatus) ProtoMessage 

func (*ObjectStatus) ProtoMessage()

func (*ObjectStatus) ProtoReflect 

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

func (*ObjectStatus) Reset 

func (x *ObjectStatus) Reset()

func (*ObjectStatus) String 

func (x *ObjectStatus) String() string

type ObjectStatusChange 

type ObjectStatusChange struct {
	Capsule string `protobuf:"bytes,1,opt,name=capsule,proto3" json:"capsule,omitempty"`
	// Types that are assignable to Change:
	//
	//	*ObjectStatusChange_Updated
	//	*ObjectStatusChange_Deleted
	//	*ObjectStatusChange_Checkpoint_
	Change isObjectStatusChange_Change `protobuf_oneof:"change"`
	// contains filtered or unexported fields
}

func (*ObjectStatusChange) Descriptor deprecated 

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

Deprecated: Use ObjectStatusChange.ProtoReflect.Descriptor instead.

func (*ObjectStatusChange) GetCapsule 

func (x *ObjectStatusChange) GetCapsule() string

func (*ObjectStatusChange) GetChange 

func (m *ObjectStatusChange) GetChange() isObjectStatusChange_Change

func (*ObjectStatusChange) GetCheckpoint 

func (x *ObjectStatusChange) GetCheckpoint() *ObjectStatusChange_Checkpoint

func (*ObjectStatusChange) GetDeleted 

func (x *ObjectStatusChange) GetDeleted() *ObjectRef

func (*ObjectStatusChange) GetUpdated 

func (x *ObjectStatusChange) GetUpdated() *ObjectStatus

func (*ObjectStatusChange) ProtoMessage 

func (*ObjectStatusChange) ProtoMessage()

func (*ObjectStatusChange) ProtoReflect 

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

func (*ObjectStatusChange) Reset 

func (x *ObjectStatusChange) Reset()

func (*ObjectStatusChange) String 

func (x *ObjectStatusChange) String() string

type ObjectStatusChange_Checkpoint 

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

func (*ObjectStatusChange_Checkpoint) Descriptor deprecated 

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

Deprecated: Use ObjectStatusChange_Checkpoint.ProtoReflect.Descriptor instead.

func (*ObjectStatusChange_Checkpoint) ProtoMessage 

func (*ObjectStatusChange_Checkpoint) ProtoMessage()

func (*ObjectStatusChange_Checkpoint) ProtoReflect 

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

func (*ObjectStatusChange_Checkpoint) Reset 

func (x *ObjectStatusChange_Checkpoint) Reset()

func (*ObjectStatusChange_Checkpoint) String 

func (x *ObjectStatusChange_Checkpoint) String() string

type ObjectStatusChange_Checkpoint_ 

type ObjectStatusChange_Checkpoint_ struct {
	// Checkpoint events indicates that all existing object statuses for
	// this namespace has been sent in the current "watch" session.
	Checkpoint *ObjectStatusChange_Checkpoint `protobuf:"bytes,4,opt,name=checkpoint,proto3,oneof"`
}

type ObjectStatusChange_Deleted 

type ObjectStatusChange_Deleted struct {
	Deleted *ObjectRef `protobuf:"bytes,3,opt,name=deleted,proto3,oneof"`
}

type ObjectStatusChange_Updated 

type ObjectStatusChange_Updated struct {
	Updated *ObjectStatus `protobuf:"bytes,2,opt,name=updated,proto3,oneof"`
}

type ObjectStatusInfo 

type ObjectStatusInfo struct {
	Conditions     []*ObjectCondition      `protobuf:"bytes,1,rep,name=conditions,proto3" json:"conditions,omitempty"`
	Properties     map[string]string       `` /* 161-byte string literal not displayed */
	SubObjects     []*SubObjectStatus      `protobuf:"bytes,3,rep,name=sub_objects,json=subObjects,proto3" json:"sub_objects,omitempty"`
	PlatformStatus []*PlatformObjectStatus `protobuf:"bytes,4,rep,name=platform_status,json=platformStatus,proto3" json:"platform_status,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStatusInfo) Descriptor deprecated 

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

Deprecated: Use ObjectStatusInfo.ProtoReflect.Descriptor instead.

func (*ObjectStatusInfo) GetConditions 

func (x *ObjectStatusInfo) GetConditions() []*ObjectCondition

func (*ObjectStatusInfo) GetPlatformStatus 

func (x *ObjectStatusInfo) GetPlatformStatus() []*PlatformObjectStatus

func (*ObjectStatusInfo) GetProperties 

func (x *ObjectStatusInfo) GetProperties() map[string]string

func (*ObjectStatusInfo) GetSubObjects 

func (x *ObjectStatusInfo) GetSubObjects() []*SubObjectStatus

func (*ObjectStatusInfo) ProtoMessage 

func (*ObjectStatusInfo) ProtoMessage()

func (*ObjectStatusInfo) ProtoReflect 

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

func (*ObjectStatusInfo) Reset 

func (x *ObjectStatusInfo) Reset()

func (*ObjectStatusInfo) String 

func (x *ObjectStatusInfo) String() string

type PlatformObjectStatus 

type PlatformObjectStatus struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Kind:
	//
	//	*PlatformObjectStatus_Route
	//	*PlatformObjectStatus_Instance
	//	*PlatformObjectStatus_Container
	//	*PlatformObjectStatus_ConfigFile
	//	*PlatformObjectStatus_Cronjob
	//	*PlatformObjectStatus_Capsule
	//	*PlatformObjectStatus_Interface
	//	*PlatformObjectStatus_JobExecution
	//	*PlatformObjectStatus_Vpa
	Kind isPlatformObjectStatus_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*PlatformObjectStatus) Descriptor deprecated 

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

Deprecated: Use PlatformObjectStatus.ProtoReflect.Descriptor instead.

func (*PlatformObjectStatus) GetCapsule 

func (x *PlatformObjectStatus) GetCapsule() *CapsuleStatus

func (*PlatformObjectStatus) GetConfigFile 

func (x *PlatformObjectStatus) GetConfigFile() *ConfigFileStatus

func (*PlatformObjectStatus) GetContainer 

func (x *PlatformObjectStatus) GetContainer() *ContainerStatus

func (*PlatformObjectStatus) GetCronjob 

func (x *PlatformObjectStatus) GetCronjob() *CronjobStatus

func (*PlatformObjectStatus) GetInstance 

func (x *PlatformObjectStatus) GetInstance() *InstanceStatus

func (*PlatformObjectStatus) GetInterface 

func (x *PlatformObjectStatus) GetInterface() *InterfaceStatus

func (*PlatformObjectStatus) GetJobExecution 

func (x *PlatformObjectStatus) GetJobExecution() *JobExecutionStatus

func (*PlatformObjectStatus) GetKind 

func (m *PlatformObjectStatus) GetKind() isPlatformObjectStatus_Kind

func (*PlatformObjectStatus) GetName 

func (x *PlatformObjectStatus) GetName() string

func (*PlatformObjectStatus) GetRoute 

func (x *PlatformObjectStatus) GetRoute() *RouteStatus

func (*PlatformObjectStatus) GetVpa 

func (x *PlatformObjectStatus) GetVpa() *VerticalPodAutoscalerStatus

func (*PlatformObjectStatus) ProtoMessage 

func (*PlatformObjectStatus) ProtoMessage()

func (*PlatformObjectStatus) ProtoReflect 

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

func (*PlatformObjectStatus) Reset 

func (x *PlatformObjectStatus) Reset()

func (*PlatformObjectStatus) String 

func (x *PlatformObjectStatus) String() string

type PlatformObjectStatus_Capsule 

type PlatformObjectStatus_Capsule struct {
	Capsule *CapsuleStatus `protobuf:"bytes,7,opt,name=capsule,proto3,oneof"`
}

type PlatformObjectStatus_ConfigFile 

type PlatformObjectStatus_ConfigFile struct {
	ConfigFile *ConfigFileStatus `protobuf:"bytes,5,opt,name=config_file,json=configFile,proto3,oneof"`
}

type PlatformObjectStatus_Container 

type PlatformObjectStatus_Container struct {
	Container *ContainerStatus `protobuf:"bytes,4,opt,name=container,proto3,oneof"`
}

type PlatformObjectStatus_Cronjob 

type PlatformObjectStatus_Cronjob struct {
	Cronjob *CronjobStatus `protobuf:"bytes,6,opt,name=cronjob,proto3,oneof"`
}

type PlatformObjectStatus_Instance 

type PlatformObjectStatus_Instance struct {
	Instance *InstanceStatus `protobuf:"bytes,3,opt,name=instance,proto3,oneof"`
}

type PlatformObjectStatus_Interface 

type PlatformObjectStatus_Interface struct {
	Interface *InterfaceStatus `protobuf:"bytes,8,opt,name=interface,proto3,oneof"`
}

type PlatformObjectStatus_JobExecution 

type PlatformObjectStatus_JobExecution struct {
	JobExecution *JobExecutionStatus `protobuf:"bytes,9,opt,name=job_execution,json=jobExecution,proto3,oneof"`
}

type PlatformObjectStatus_Route 

type PlatformObjectStatus_Route struct {
	Route *RouteStatus `protobuf:"bytes,2,opt,name=route,proto3,oneof"`
}

type PlatformObjectStatus_Vpa 

type PlatformObjectStatus_Vpa struct {
	Vpa *VerticalPodAutoscalerStatus `protobuf:"bytes,10,opt,name=vpa,proto3,oneof"`
}

type PluginConfig 

type PluginConfig struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Config string `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	Err    string `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginConfig) Descriptor deprecated 

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

Deprecated: Use PluginConfig.ProtoReflect.Descriptor instead.

func (*PluginConfig) GetConfig 

func (x *PluginConfig) GetConfig() string

func (*PluginConfig) GetErr 

func (x *PluginConfig) GetErr() string

func (*PluginConfig) GetName 

func (x *PluginConfig) GetName() string

func (*PluginConfig) ProtoMessage 

func (*PluginConfig) ProtoMessage()

func (*PluginConfig) ProtoReflect 

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

func (*PluginConfig) Reset 

func (x *PluginConfig) Reset()

func (*PluginConfig) String 

func (x *PluginConfig) String() string

type Recommendation 

type Recommendation struct {
	LowerBound uint64 `protobuf:"varint,1,opt,name=lower_bound,json=lowerBound,proto3" json:"lower_bound,omitempty"`
	Target     uint64 `protobuf:"varint,2,opt,name=target,proto3" json:"target,omitempty"`
	UpperBound uint64 `protobuf:"varint,3,opt,name=upper_bound,json=upperBound,proto3" json:"upper_bound,omitempty"`
	// contains filtered or unexported fields
}

func (*Recommendation) Descriptor deprecated 

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

Deprecated: Use Recommendation.ProtoReflect.Descriptor instead.

func (*Recommendation) GetLowerBound 

func (x *Recommendation) GetLowerBound() uint64

func (*Recommendation) GetTarget 

func (x *Recommendation) GetTarget() uint64

func (*Recommendation) GetUpperBound 

func (x *Recommendation) GetUpperBound() uint64

func (*Recommendation) ProtoMessage 

func (*Recommendation) ProtoMessage()

func (*Recommendation) ProtoReflect 

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

func (*Recommendation) Reset 

func (x *Recommendation) Reset()

func (*Recommendation) String 

func (x *Recommendation) String() string

type RouteStatus 

type RouteStatus struct {
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Host          string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	InterfaceName string `protobuf:"bytes,3,opt,name=interface_name,json=interfaceName,proto3" json:"interface_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteStatus) Descriptor deprecated 

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

Deprecated: Use RouteStatus.ProtoReflect.Descriptor instead.

func (*RouteStatus) GetHost 

func (x *RouteStatus) GetHost() string

func (*RouteStatus) GetId 

func (x *RouteStatus) GetId() string

func (*RouteStatus) GetInterfaceName 

func (x *RouteStatus) GetInterfaceName() string

func (*RouteStatus) ProtoMessage 

func (*RouteStatus) ProtoMessage()

func (*RouteStatus) ProtoReflect 

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

func (*RouteStatus) Reset 

func (x *RouteStatus) Reset()

func (*RouteStatus) String 

func (x *RouteStatus) String() string

type ServiceClient 

type ServiceClient interface {
	WatchObjectStatus(ctx context.Context, in *WatchObjectStatusRequest, opts ...grpc.CallOption) (Service_WatchObjectStatusClient, error)
	DryRun(ctx context.Context, in *DryRunRequest, opts ...grpc.CallOption) (*DryRunResponse, error)
	DryRunPluginConfig(ctx context.Context, in *DryRunPluginConfigRequest, opts ...grpc.CallOption) (*DryRunPluginConfigResponse, error)
}

ServiceClient is the client API for Service service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewServiceClient 

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer 

type ServiceServer interface {
	WatchObjectStatus(*WatchObjectStatusRequest, Service_WatchObjectStatusServer) error
	DryRun(context.Context, *DryRunRequest) (*DryRunResponse, error)
	DryRunPluginConfig(context.Context, *DryRunPluginConfigRequest) (*DryRunPluginConfigResponse, error)
	// contains filtered or unexported methods
}

ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility

type Service_WatchObjectStatusClient 

type Service_WatchObjectStatusClient interface {
	Recv() (*WatchObjectStatusResponse, error)
	grpc.ClientStream
}

type Service_WatchObjectStatusServer 

type Service_WatchObjectStatusServer interface {
	Send(*WatchObjectStatusResponse) error
	grpc.ServerStream
}

type StepConfig 

type StepConfig struct {
	Name    string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Plugins []*PluginConfig `protobuf:"bytes,2,rep,name=plugins,proto3" json:"plugins,omitempty"`
	// contains filtered or unexported fields
}

func (*StepConfig) Descriptor deprecated 

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

Deprecated: Use StepConfig.ProtoReflect.Descriptor instead.

func (*StepConfig) GetName 

func (x *StepConfig) GetName() string

func (*StepConfig) GetPlugins 

func (x *StepConfig) GetPlugins() []*PluginConfig

func (*StepConfig) ProtoMessage 

func (*StepConfig) ProtoMessage()

func (*StepConfig) ProtoReflect 

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

func (*StepConfig) Reset 

func (x *StepConfig) Reset()

func (*StepConfig) String 

func (x *StepConfig) String() string

type SubObjectStatus 

type SubObjectStatus struct {
	Name           string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Conditions     []*ObjectCondition      `protobuf:"bytes,3,rep,name=conditions,proto3" json:"conditions,omitempty"`
	Properties     map[string]string       `` /* 161-byte string literal not displayed */
	PlatformStatus []*PlatformObjectStatus `protobuf:"bytes,5,rep,name=platform_status,json=platformStatus,proto3" json:"platform_status,omitempty"`
	// contains filtered or unexported fields
}

func (*SubObjectStatus) Descriptor deprecated 

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

Deprecated: Use SubObjectStatus.ProtoReflect.Descriptor instead.

func (*SubObjectStatus) GetConditions 

func (x *SubObjectStatus) GetConditions() []*ObjectCondition

func (*SubObjectStatus) GetName 

func (x *SubObjectStatus) GetName() string

func (*SubObjectStatus) GetPlatformStatus 

func (x *SubObjectStatus) GetPlatformStatus() []*PlatformObjectStatus

func (*SubObjectStatus) GetProperties 

func (x *SubObjectStatus) GetProperties() map[string]string

func (*SubObjectStatus) ProtoMessage 

func (*SubObjectStatus) ProtoMessage()

func (*SubObjectStatus) ProtoReflect 

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

func (*SubObjectStatus) Reset 

func (x *SubObjectStatus) Reset()

func (*SubObjectStatus) String 

func (x *SubObjectStatus) String() string

type UnimplementedServiceServer 

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceServer) DryRun 

func (UnimplementedServiceServer) DryRun(context.Context, *DryRunRequest) (*DryRunResponse, error)

func (UnimplementedServiceServer) DryRunPluginConfig 

func (UnimplementedServiceServer) DryRunPluginConfig(context.Context, *DryRunPluginConfigRequest) (*DryRunPluginConfigResponse, error)

func (UnimplementedServiceServer) WatchObjectStatus 

func (UnimplementedServiceServer) WatchObjectStatus(*WatchObjectStatusRequest, Service_WatchObjectStatusServer) error

type UnsafeServiceServer 

type UnsafeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceServer will result in compilation errors.

type VerticalPodAutoscalerStatus 

type VerticalPodAutoscalerStatus struct {
	CpuMillis   *Recommendation `protobuf:"bytes,1,opt,name=cpu_millis,json=cpuMillis,proto3" json:"cpu_millis,omitempty"`
	MemoryBytes *Recommendation `protobuf:"bytes,2,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*VerticalPodAutoscalerStatus) Descriptor deprecated 

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

Deprecated: Use VerticalPodAutoscalerStatus.ProtoReflect.Descriptor instead.

func (*VerticalPodAutoscalerStatus) GetCpuMillis 

func (x *VerticalPodAutoscalerStatus) GetCpuMillis() *Recommendation

func (*VerticalPodAutoscalerStatus) GetMemoryBytes 

func (x *VerticalPodAutoscalerStatus) GetMemoryBytes() *Recommendation

func (*VerticalPodAutoscalerStatus) ProtoMessage 

func (*VerticalPodAutoscalerStatus) ProtoMessage()

func (*VerticalPodAutoscalerStatus) ProtoReflect 

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

func (*VerticalPodAutoscalerStatus) Reset 

func (x *VerticalPodAutoscalerStatus) Reset()

func (*VerticalPodAutoscalerStatus) String 

func (x *VerticalPodAutoscalerStatus) String() string

type WatchObjectStatusRequest 

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

func (*WatchObjectStatusRequest) Descriptor deprecated 

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

Deprecated: Use WatchObjectStatusRequest.ProtoReflect.Descriptor instead.

func (*WatchObjectStatusRequest) GetNamespace 

func (x *WatchObjectStatusRequest) GetNamespace() string

func (*WatchObjectStatusRequest) ProtoMessage 

func (*WatchObjectStatusRequest) ProtoMessage()

func (*WatchObjectStatusRequest) ProtoReflect 

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

func (*WatchObjectStatusRequest) Reset 

func (x *WatchObjectStatusRequest) Reset()

func (*WatchObjectStatusRequest) String 

func (x *WatchObjectStatusRequest) String() string

type WatchObjectStatusResponse 

type WatchObjectStatusResponse struct {
	Change *ObjectStatusChange `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchObjectStatusResponse) Descriptor deprecated 

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

Deprecated: Use WatchObjectStatusResponse.ProtoReflect.Descriptor instead.

func (*WatchObjectStatusResponse) GetChange 

func (x *WatchObjectStatusResponse) GetChange() *ObjectStatusChange

func (*WatchObjectStatusResponse) ProtoMessage 

func (*WatchObjectStatusResponse) ProtoMessage()

func (*WatchObjectStatusResponse) ProtoReflect 

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

func (*WatchObjectStatusResponse) Reset 

func (x *WatchObjectStatusResponse) Reset()

func (*WatchObjectStatusResponse) String 

func (x *WatchObjectStatusResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.