optimus

package
v0.14.4 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ChangeImpact_name = map[int32]string{
		0: "CHANGE_IMPACT_TYPE_UNSPECIFIED",
		1: "CHANGE_IMPACT_TYPE_INTERNAL",
		2: "CHANGE_IMPACT_TYPE_BEHAVIOUR",
	}
	ChangeImpact_value = map[string]int32{
		"CHANGE_IMPACT_TYPE_UNSPECIFIED": 0,
		"CHANGE_IMPACT_TYPE_INTERNAL":    1,
		"CHANGE_IMPACT_TYPE_BEHAVIOUR":   2,
	}
)

Enum value maps for ChangeImpact.

View Source 
var (
	OptimusChangeEvent_EventType_name = map[int32]string{
		0:  "EVENT_TYPE_TYPE_UNSPECIFIED",
		1:  "EVENT_TYPE_RESOURCE_CREATE",
		2:  "EVENT_TYPE_RESOURCE_UPDATE",
		11: "EVENT_TYPE_RESOURCE_DELETE",
		3:  "EVENT_TYPE_JOB_CREATE",
		4:  "EVENT_TYPE_JOB_UPDATE",
		5:  "EVENT_TYPE_JOB_DELETE",
		6:  "EVENT_TYPE_JOB_WAIT_UPSTREAM",
		7:  "EVENT_TYPE_JOB_IN_PROGRESS",
		8:  "EVENT_TYPE_JOB_SUCCESS",
		9:  "EVENT_TYPE_JOB_FAILURE",
		10: "EVENT_TYPE_JOB_STATE_CHANGE",
	}
	OptimusChangeEvent_EventType_value = map[string]int32{
		"EVENT_TYPE_TYPE_UNSPECIFIED":  0,
		"EVENT_TYPE_RESOURCE_CREATE":   1,
		"EVENT_TYPE_RESOURCE_UPDATE":   2,
		"EVENT_TYPE_RESOURCE_DELETE":   11,
		"EVENT_TYPE_JOB_CREATE":        3,
		"EVENT_TYPE_JOB_UPDATE":        4,
		"EVENT_TYPE_JOB_DELETE":        5,
		"EVENT_TYPE_JOB_WAIT_UPSTREAM": 6,
		"EVENT_TYPE_JOB_IN_PROGRESS":   7,
		"EVENT_TYPE_JOB_SUCCESS":       8,
		"EVENT_TYPE_JOB_FAILURE":       9,
		"EVENT_TYPE_JOB_STATE_CHANGE":  10,
	}
)

Enum value maps for OptimusChangeEvent_EventType.

View Source 
var File_gotocompany_optimus_integration_v1beta1_event_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ChangeImpact added in v0.12.0 

type ChangeImpact int32
const (
	ChangeImpact_CHANGE_IMPACT_TYPE_UNSPECIFIED ChangeImpact = 0
	ChangeImpact_CHANGE_IMPACT_TYPE_INTERNAL    ChangeImpact = 1
	ChangeImpact_CHANGE_IMPACT_TYPE_BEHAVIOUR   ChangeImpact = 2
)

func (ChangeImpact) Descriptor added in v0.12.0 

func (ChangeImpact) Descriptor() protoreflect.EnumDescriptor

func (ChangeImpact) Enum added in v0.12.0 

func (x ChangeImpact) Enum() *ChangeImpact

func (ChangeImpact) EnumDescriptor deprecated added in v0.12.0 

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

Deprecated: Use ChangeImpact.Descriptor instead.

func (ChangeImpact) Number added in v0.12.0 

func (x ChangeImpact) Number() protoreflect.EnumNumber

func (ChangeImpact) String added in v0.12.0 

func (x ChangeImpact) String() string

func (ChangeImpact) Type added in v0.12.0 

func (ChangeImpact) Type() protoreflect.EnumType

type JobChangePayload 

type JobChangePayload struct {
	JobName string                    `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	JobSpec *v1beta1.JobSpecification `protobuf:"bytes,2,opt,name=job_spec,json=jobSpec,proto3" json:"job_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*JobChangePayload) Descriptor deprecated 

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

Deprecated: Use JobChangePayload.ProtoReflect.Descriptor instead.

func (*JobChangePayload) GetJobName 

func (x *JobChangePayload) GetJobName() string

func (*JobChangePayload) GetJobSpec 

func (x *JobChangePayload) GetJobSpec() *v1beta1.JobSpecification

func (*JobChangePayload) ProtoMessage 

func (*JobChangePayload) ProtoMessage()

func (*JobChangePayload) ProtoReflect 

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

func (*JobChangePayload) Reset 

func (x *JobChangePayload) Reset()

func (*JobChangePayload) String 

func (x *JobChangePayload) String() string

type JobRunPayload 

type JobRunPayload struct {
	JobName     string                 `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	ScheduledAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	JobRunId    string                 `protobuf:"bytes,3,opt,name=job_run_id,json=jobRunId,proto3" json:"job_run_id,omitempty"`
	StartTime   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRunPayload) Descriptor deprecated 

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

Deprecated: Use JobRunPayload.ProtoReflect.Descriptor instead.

func (*JobRunPayload) GetJobName 

func (x *JobRunPayload) GetJobName() string

func (*JobRunPayload) GetJobRunId 

func (x *JobRunPayload) GetJobRunId() string

func (*JobRunPayload) GetScheduledAt 

func (x *JobRunPayload) GetScheduledAt() *timestamppb.Timestamp

func (*JobRunPayload) GetStartTime 

func (x *JobRunPayload) GetStartTime() *timestamppb.Timestamp

func (*JobRunPayload) ProtoMessage 

func (*JobRunPayload) ProtoMessage()

func (*JobRunPayload) ProtoReflect 

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

func (*JobRunPayload) Reset 

func (x *JobRunPayload) Reset()

func (*JobRunPayload) String 

func (x *JobRunPayload) String() string

type JobStateChangePayload added in v0.9.0 

type JobStateChangePayload struct {
	JobName string           `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	State   v1beta1.JobState `protobuf:"varint,2,opt,name=state,proto3,enum=gotocompany.optimus.core.v1beta1.JobState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStateChangePayload) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use JobStateChangePayload.ProtoReflect.Descriptor instead.

func (*JobStateChangePayload) GetJobName added in v0.9.0 

func (x *JobStateChangePayload) GetJobName() string

func (*JobStateChangePayload) GetState added in v0.9.0 

func (x *JobStateChangePayload) GetState() v1beta1.JobState

func (*JobStateChangePayload) ProtoMessage added in v0.9.0 

func (*JobStateChangePayload) ProtoMessage()

func (*JobStateChangePayload) ProtoReflect added in v0.9.0 

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

func (*JobStateChangePayload) Reset added in v0.9.0 

func (x *JobStateChangePayload) Reset()

func (*JobStateChangePayload) String added in v0.9.0 

func (x *JobStateChangePayload) String() string

type OptimusChangeEvent 

type OptimusChangeEvent struct {
	EventId       string                       `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	OccurredAt    *timestamppb.Timestamp       `protobuf:"bytes,2,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	ProjectName   string                       `protobuf:"bytes,3,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string                       `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	EventType     OptimusChangeEvent_EventType `` /* 163-byte string literal not displayed */
	// Types that are assignable to Payload:
	//
	//	*OptimusChangeEvent_JobChange
	//	*OptimusChangeEvent_ResourceChange
	//	*OptimusChangeEvent_JobRun
	//	*OptimusChangeEvent_JobStateChange
	Payload      isOptimusChangeEvent_Payload `protobuf_oneof:"payload"`
	JobName      string                       `protobuf:"bytes,10,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	ChangeImpact ChangeImpact                 `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OptimusChangeEvent) Descriptor deprecated 

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

Deprecated: Use OptimusChangeEvent.ProtoReflect.Descriptor instead.

func (*OptimusChangeEvent) GetChangeImpact added in v0.12.0 

func (x *OptimusChangeEvent) GetChangeImpact() ChangeImpact

func (*OptimusChangeEvent) GetEventId 

func (x *OptimusChangeEvent) GetEventId() string

func (*OptimusChangeEvent) GetEventType 

func (x *OptimusChangeEvent) GetEventType() OptimusChangeEvent_EventType

func (*OptimusChangeEvent) GetJobChange 

func (x *OptimusChangeEvent) GetJobChange() *JobChangePayload

func (*OptimusChangeEvent) GetJobName added in v0.11.3 

func (x *OptimusChangeEvent) GetJobName() string

func (*OptimusChangeEvent) GetJobRun 

func (x *OptimusChangeEvent) GetJobRun() *JobRunPayload

func (*OptimusChangeEvent) GetJobStateChange added in v0.9.0 

func (x *OptimusChangeEvent) GetJobStateChange() *JobStateChangePayload

func (*OptimusChangeEvent) GetNamespaceName 

func (x *OptimusChangeEvent) GetNamespaceName() string

func (*OptimusChangeEvent) GetOccurredAt 

func (x *OptimusChangeEvent) GetOccurredAt() *timestamppb.Timestamp

func (*OptimusChangeEvent) GetPayload 

func (m *OptimusChangeEvent) GetPayload() isOptimusChangeEvent_Payload

func (*OptimusChangeEvent) GetProjectName 

func (x *OptimusChangeEvent) GetProjectName() string

func (*OptimusChangeEvent) GetResourceChange 

func (x *OptimusChangeEvent) GetResourceChange() *ResourceChangePayload

func (*OptimusChangeEvent) ProtoMessage 

func (*OptimusChangeEvent) ProtoMessage()

func (*OptimusChangeEvent) ProtoReflect 

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

func (*OptimusChangeEvent) Reset 

func (x *OptimusChangeEvent) Reset()

func (*OptimusChangeEvent) String 

func (x *OptimusChangeEvent) String() string

type OptimusChangeEvent_EventType 

type OptimusChangeEvent_EventType int32
const (
	OptimusChangeEvent_EVENT_TYPE_TYPE_UNSPECIFIED  OptimusChangeEvent_EventType = 0
	OptimusChangeEvent_EVENT_TYPE_RESOURCE_CREATE   OptimusChangeEvent_EventType = 1
	OptimusChangeEvent_EVENT_TYPE_RESOURCE_UPDATE   OptimusChangeEvent_EventType = 2
	OptimusChangeEvent_EVENT_TYPE_RESOURCE_DELETE   OptimusChangeEvent_EventType = 11
	OptimusChangeEvent_EVENT_TYPE_JOB_CREATE        OptimusChangeEvent_EventType = 3
	OptimusChangeEvent_EVENT_TYPE_JOB_UPDATE        OptimusChangeEvent_EventType = 4
	OptimusChangeEvent_EVENT_TYPE_JOB_DELETE        OptimusChangeEvent_EventType = 5
	OptimusChangeEvent_EVENT_TYPE_JOB_WAIT_UPSTREAM OptimusChangeEvent_EventType = 6
	OptimusChangeEvent_EVENT_TYPE_JOB_IN_PROGRESS   OptimusChangeEvent_EventType = 7
	OptimusChangeEvent_EVENT_TYPE_JOB_SUCCESS       OptimusChangeEvent_EventType = 8
	OptimusChangeEvent_EVENT_TYPE_JOB_FAILURE       OptimusChangeEvent_EventType = 9
	OptimusChangeEvent_EVENT_TYPE_JOB_STATE_CHANGE  OptimusChangeEvent_EventType = 10
)

func (OptimusChangeEvent_EventType) Descriptor 

func (OptimusChangeEvent_EventType) Descriptor() protoreflect.EnumDescriptor

func (OptimusChangeEvent_EventType) Enum 

func (x OptimusChangeEvent_EventType) Enum() *OptimusChangeEvent_EventType

func (OptimusChangeEvent_EventType) EnumDescriptor deprecated 

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

Deprecated: Use OptimusChangeEvent_EventType.Descriptor instead.

func (OptimusChangeEvent_EventType) Number 

func (x OptimusChangeEvent_EventType) Number() protoreflect.EnumNumber

func (OptimusChangeEvent_EventType) String 

func (x OptimusChangeEvent_EventType) String() string

func (OptimusChangeEvent_EventType) Type 

func (OptimusChangeEvent_EventType) Type() protoreflect.EnumType

type OptimusChangeEvent_JobChange 

type OptimusChangeEvent_JobChange struct {
	JobChange *JobChangePayload `protobuf:"bytes,6,opt,name=job_change,json=jobChange,proto3,oneof"`
}

type OptimusChangeEvent_JobRun 

type OptimusChangeEvent_JobRun struct {
	JobRun *JobRunPayload `protobuf:"bytes,8,opt,name=job_run,json=jobRun,proto3,oneof"`
}

type OptimusChangeEvent_JobStateChange added in v0.9.0 

type OptimusChangeEvent_JobStateChange struct {
	JobStateChange *JobStateChangePayload `protobuf:"bytes,9,opt,name=job_state_change,json=jobStateChange,proto3,oneof"`
}

type OptimusChangeEvent_ResourceChange 

type OptimusChangeEvent_ResourceChange struct {
	ResourceChange *ResourceChangePayload `protobuf:"bytes,7,opt,name=resource_change,json=resourceChange,proto3,oneof"`
}

type ResourceChangePayload 

type ResourceChangePayload struct {
	DatastoreName string                         `protobuf:"bytes,1,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	Resource      *v1beta1.ResourceSpecification `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceChangePayload) Descriptor deprecated 

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

Deprecated: Use ResourceChangePayload.ProtoReflect.Descriptor instead.

func (*ResourceChangePayload) GetDatastoreName 

func (x *ResourceChangePayload) GetDatastoreName() string

func (*ResourceChangePayload) GetResource 

func (x *ResourceChangePayload) GetResource() *v1beta1.ResourceSpecification

func (*ResourceChangePayload) ProtoMessage 

func (*ResourceChangePayload) ProtoMessage()

func (*ResourceChangePayload) ProtoReflect 

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

func (*ResourceChangePayload) Reset 

func (x *ResourceChangePayload) Reset()

func (*ResourceChangePayload) String 

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