optimus

package
v0.8.5 Latest Latest
Warning

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

 Go to latest Published: Aug 4, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	OptimusChangeEvent_EventType_name = map[int32]string{
		0: "EVENT_TYPE_TYPE_UNSPECIFIED",
		1: "EVENT_TYPE_RESOURCE_CREATE",
		2: "EVENT_TYPE_RESOURCE_UPDATE",
		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",
	}
	OptimusChangeEvent_EventType_value = map[string]int32{
		"EVENT_TYPE_TYPE_UNSPECIFIED":  0,
		"EVENT_TYPE_RESOURCE_CREATE":   1,
		"EVENT_TYPE_RESOURCE_UPDATE":   2,
		"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,
	}
)

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 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 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
	Payload isOptimusChangeEvent_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*OptimusChangeEvent) Descriptor deprecated 

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

Deprecated: Use OptimusChangeEvent.ProtoReflect.Descriptor instead.

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

func (x *OptimusChangeEvent) GetJobRun() *JobRunPayload

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

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_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.