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: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "STATE_RUNNING",
		2: "STATE_ABORTED",
		3: "STATE_COMPLETED",
	}
	State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"STATE_RUNNING":     1,
		"STATE_ABORTED":     2,
		"STATE_COMPLETED":   3,
	}
)

Enum value maps for State.

View Source 
var (
	PhaseState_name = map[int32]string{
		0: "PHASE_STATE_UNSPECIFIED",
		1: "PHASE_STATE_NOT_READY",
		2: "PHASE_STATE_READY",
		3: "PHASE_STATE_PROMOTED",
	}
	PhaseState_value = map[string]int32{
		"PHASE_STATE_UNSPECIFIED": 0,
		"PHASE_STATE_NOT_READY":   1,
		"PHASE_STATE_READY":       2,
		"PHASE_STATE_PROMOTED":    3,
	}
)

Enum value maps for PhaseState.

View Source 
var File_api_v1_capsule_pipeline_status_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type PhaseMessage 

type PhaseMessage struct {
	Message   string                 `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*PhaseMessage) Descriptor deprecated 

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

Deprecated: Use PhaseMessage.ProtoReflect.Descriptor instead.

func (*PhaseMessage) GetMessage 

func (x *PhaseMessage) GetMessage() string

func (*PhaseMessage) GetTimestamp 

func (x *PhaseMessage) GetTimestamp() *timestamppb.Timestamp

func (*PhaseMessage) ProtoMessage 

func (*PhaseMessage) ProtoMessage()

func (*PhaseMessage) ProtoReflect 

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

func (*PhaseMessage) Reset 

func (x *PhaseMessage) Reset()

func (*PhaseMessage) String 

func (x *PhaseMessage) String() string

type PhaseState 

type PhaseState int32
const (
	// The state is unspecified.
	PhaseState_PHASE_STATE_UNSPECIFIED PhaseState = 0
	// The phase is not ready for promotion
	PhaseState_PHASE_STATE_NOT_READY PhaseState = 1
	// The phase is ready for promotion
	PhaseState_PHASE_STATE_READY PhaseState = 2
	// The phase is promoted
	PhaseState_PHASE_STATE_PROMOTED PhaseState = 3
)

func (PhaseState) Descriptor 

func (PhaseState) Descriptor() protoreflect.EnumDescriptor

func (PhaseState) Enum 

func (x PhaseState) Enum() *PhaseState

func (PhaseState) EnumDescriptor deprecated 

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

Deprecated: Use PhaseState.Descriptor instead.

func (PhaseState) Number 

func (x PhaseState) Number() protoreflect.EnumNumber

func (PhaseState) String 

func (x PhaseState) String() string

func (PhaseState) Type 

func (PhaseState) Type() protoreflect.EnumType

type PhaseStatus 

type PhaseStatus struct {
	EnvironmentId string                 `protobuf:"bytes,1,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"`
	State         PhaseState             `protobuf:"varint,2,opt,name=state,proto3,enum=api.v1.capsule.pipeline.PhaseState" json:"state,omitempty"`
	RolloutId     uint64                 `protobuf:"varint,3,opt,name=rollout_id,json=rolloutId,proto3" json:"rollout_id,omitempty"`
	Messages      []*PhaseMessage        `protobuf:"bytes,4,rep,name=messages,proto3" json:"messages,omitempty"`
	StartedAt     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PhaseStatus) Descriptor deprecated 

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

Deprecated: Use PhaseStatus.ProtoReflect.Descriptor instead.

func (*PhaseStatus) GetEnvironmentId 

func (x *PhaseStatus) GetEnvironmentId() string

func (*PhaseStatus) GetMessages 

func (x *PhaseStatus) GetMessages() []*PhaseMessage

func (*PhaseStatus) GetRolloutId 

func (x *PhaseStatus) GetRolloutId() uint64

func (*PhaseStatus) GetStartedAt 

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

func (*PhaseStatus) GetState 

func (x *PhaseStatus) GetState() PhaseState

func (*PhaseStatus) ProtoMessage 

func (*PhaseStatus) ProtoMessage()

func (*PhaseStatus) ProtoReflect 

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

func (*PhaseStatus) Reset 

func (x *PhaseStatus) Reset()

func (*PhaseStatus) String 

func (x *PhaseStatus) String() string

type State 

type State int32
const (
	// The state is unspecified.
	State_STATE_UNSPECIFIED State = 0
	// The pipeline has started.
	State_STATE_RUNNING State = 1
	// The pipeline is aborted.
	State_STATE_ABORTED State = 2
	// The pipeline is completed.
	State_STATE_COMPLETED State = 3
)

func (State) Descriptor 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type 

func (State) Type() protoreflect.EnumType

type Status 

type Status struct {

	// The name of the pipeline.
	PipelineName string `protobuf:"bytes,1,opt,name=pipeline_name,json=pipelineName,proto3" json:"pipeline_name,omitempty"`
	// The capsule that is executing the pipeline.
	CapsuleId string `protobuf:"bytes,2,opt,name=capsule_id,json=capsuleId,proto3" json:"capsule_id,omitempty"`
	// The ID of the pipeline execution
	ExecutionId uint64 `protobuf:"varint,3,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// The overall state of the pipeline execution.
	State State `protobuf:"varint,4,opt,name=state,proto3,enum=api.v1.capsule.pipeline.State" json:"state,omitempty"`
	// The statuses of the phases in the pipeline.
	PhaseStatuses []*PhaseStatus `protobuf:"bytes,5,rep,name=phase_statuses,json=phaseStatuses,proto3" json:"phase_statuses,omitempty"`
	// When the pipeline was started.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// When the pipeline was last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// current phase
	CurrentPhase uint32 `protobuf:"varint,8,opt,name=current_phase,json=currentPhase,proto3" json:"current_phase,omitempty"`
	// the configured pipeline
	Config *model.Pipeline `protobuf:"bytes,9,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCapsuleId 

func (x *Status) GetCapsuleId() string

func (*Status) GetConfig 

func (x *Status) GetConfig() *model.Pipeline

func (*Status) GetCurrentPhase 

func (x *Status) GetCurrentPhase() uint32

func (*Status) GetExecutionId 

func (x *Status) GetExecutionId() uint64

func (*Status) GetPhaseStatuses 

func (x *Status) GetPhaseStatuses() []*PhaseStatus

func (*Status) GetPipelineName 

func (x *Status) GetPipelineName() string

func (*Status) GetStartedAt 

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

func (*Status) GetState 

func (x *Status) GetState() State

func (*Status) GetUpdatedAt 

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

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

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