pipeline

package
v0.0.0-...-4352c8b Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2024 License: Apache-2.0 Imports: 9 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

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,
		},
	},
	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"`
	// 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) 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 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 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 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"`
	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) 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
	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) 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) 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_Route 

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

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

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)
	// 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 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) 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 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.