cron

package
v0.9.4 Latest Latest
Warning

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

Go to latest
Published: Dec 22, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultCronTimeout = 10 * time.Second

Variables

View Source
var (
	CronjobState_name = map[int32]string{
		0: "CRONJOB_STATE_UNSPECIFIED",
		1: "CRONJOB_STATE_WAITING",
		2: "CRONJOB_STATE_PENDING",
		3: "CRONJOB_STATE_RUNNING",
	}
	CronjobState_value = map[string]int32{
		"CRONJOB_STATE_UNSPECIFIED": 0,
		"CRONJOB_STATE_WAITING":     1,
		"CRONJOB_STATE_PENDING":     2,
		"CRONJOB_STATE_RUNNING":     3,
	}
)

Enum value maps for CronjobState.

View Source
var File_resources_common_cron_cron_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Cronjob

type Cronjob struct {
	Name             string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Schedule         string               `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`
	State            CronjobState         `protobuf:"varint,3,opt,name=state,proto3,enum=resources.common.cron.CronjobState" json:"state,omitempty"`
	NextScheduleTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=next_schedule_time,json=nextScheduleTime,proto3" json:"next_schedule_time,omitempty"`
	LastAttemptTime  *timestamp.Timestamp `protobuf:"bytes,5,opt,name=last_attempt_time,json=lastAttemptTime,proto3,oneof" json:"last_attempt_time,omitempty"`
	StartedTime      *timestamp.Timestamp `protobuf:"bytes,6,opt,name=started_time,json=startedTime,proto3,oneof" json:"started_time,omitempty"`
	Timeout          *durationpb.Duration `protobuf:"bytes,7,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
	Data             *CronjobData         `protobuf:"bytes,8,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Cronjob) Descriptor deprecated

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

Deprecated: Use Cronjob.ProtoReflect.Descriptor instead.

func (*Cronjob) GetData

func (x *Cronjob) GetData() *CronjobData

func (*Cronjob) GetLastAttemptTime

func (x *Cronjob) GetLastAttemptTime() *timestamp.Timestamp

func (*Cronjob) GetName

func (x *Cronjob) GetName() string

func (*Cronjob) GetNextScheduleTime

func (x *Cronjob) GetNextScheduleTime() *timestamp.Timestamp

func (*Cronjob) GetRunTimeout added in v0.9.4

func (x *Cronjob) GetRunTimeout() time.Duration

func (*Cronjob) GetSchedule

func (x *Cronjob) GetSchedule() string

func (*Cronjob) GetStartedTime added in v0.9.4

func (x *Cronjob) GetStartedTime() *timestamp.Timestamp

func (*Cronjob) GetState

func (x *Cronjob) GetState() CronjobState

func (*Cronjob) GetTimeout added in v0.9.4

func (x *Cronjob) GetTimeout() *durationpb.Duration

func (*Cronjob) Merge

func (x *Cronjob) Merge(in *Cronjob) *Cronjob

func (*Cronjob) ProtoMessage

func (*Cronjob) ProtoMessage()

func (*Cronjob) ProtoReflect

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

func (*Cronjob) Reset

func (x *Cronjob) Reset()

func (*Cronjob) Sanitize added in v0.9.4

func (m *Cronjob) Sanitize() error

func (*Cronjob) String

func (x *Cronjob) String() string

func (*Cronjob) Validate

func (m *Cronjob) Validate() error

Validate checks the field values on Cronjob with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Cronjob) ValidateAll

func (m *Cronjob) ValidateAll() error

ValidateAll checks the field values on Cronjob with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CronjobMultiError, or nil if none found.

type CronjobCompletedEvent

type CronjobCompletedEvent struct {
	Name    string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Sucess  bool                 `protobuf:"varint,2,opt,name=sucess,proto3" json:"sucess,omitempty"`
	EndDate *timestamp.Timestamp `protobuf:"bytes,3,opt,name=endDate,proto3" json:"endDate,omitempty"`
	Elapsed *durationpb.Duration `protobuf:"bytes,4,opt,name=elapsed,proto3" json:"elapsed,omitempty"`
	Data    *CronjobData         `protobuf:"bytes,5,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CronjobCompletedEvent) Descriptor deprecated

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

Deprecated: Use CronjobCompletedEvent.ProtoReflect.Descriptor instead.

func (*CronjobCompletedEvent) GetData

func (x *CronjobCompletedEvent) GetData() *CronjobData

func (*CronjobCompletedEvent) GetElapsed

func (x *CronjobCompletedEvent) GetElapsed() *durationpb.Duration

func (*CronjobCompletedEvent) GetEndDate

func (x *CronjobCompletedEvent) GetEndDate() *timestamp.Timestamp

func (*CronjobCompletedEvent) GetName

func (x *CronjobCompletedEvent) GetName() string

func (*CronjobCompletedEvent) GetSucess

func (x *CronjobCompletedEvent) GetSucess() bool

func (*CronjobCompletedEvent) ProtoMessage

func (*CronjobCompletedEvent) ProtoMessage()

func (*CronjobCompletedEvent) ProtoReflect

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

func (*CronjobCompletedEvent) Reset

func (x *CronjobCompletedEvent) Reset()

func (*CronjobCompletedEvent) Sanitize added in v0.9.4

func (m *CronjobCompletedEvent) Sanitize() error

func (*CronjobCompletedEvent) String

func (x *CronjobCompletedEvent) String() string

func (*CronjobCompletedEvent) Validate

func (m *CronjobCompletedEvent) Validate() error

Validate checks the field values on CronjobCompletedEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CronjobCompletedEvent) ValidateAll

func (m *CronjobCompletedEvent) ValidateAll() error

ValidateAll checks the field values on CronjobCompletedEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CronjobCompletedEventMultiError, or nil if none found.

type CronjobCompletedEventMultiError

type CronjobCompletedEventMultiError []error

CronjobCompletedEventMultiError is an error wrapping multiple validation errors returned by CronjobCompletedEvent.ValidateAll() if the designated constraints aren't met.

func (CronjobCompletedEventMultiError) AllErrors

func (m CronjobCompletedEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CronjobCompletedEventMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type CronjobCompletedEventValidationError

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

CronjobCompletedEventValidationError is the validation error returned by CronjobCompletedEvent.Validate if the designated constraints aren't met.

func (CronjobCompletedEventValidationError) Cause

Cause function returns cause value.

func (CronjobCompletedEventValidationError) Error

Error satisfies the builtin error interface

func (CronjobCompletedEventValidationError) ErrorName

ErrorName returns error name.

func (CronjobCompletedEventValidationError) Field

Field function returns field value.

func (CronjobCompletedEventValidationError) Key

Key function returns key value.

func (CronjobCompletedEventValidationError) Reason

Reason function returns reason value.

type CronjobData

type CronjobData struct {
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,1,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Data      *anypb.Any           `protobuf:"bytes,2,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CronjobData) Descriptor deprecated

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

Deprecated: Use CronjobData.ProtoReflect.Descriptor instead.

func (*CronjobData) GetData

func (x *CronjobData) GetData() *anypb.Any

func (*CronjobData) GetUpdatedAt

func (x *CronjobData) GetUpdatedAt() *timestamp.Timestamp

func (*CronjobData) Merge

func (x *CronjobData) Merge(in *CronjobData) *CronjobData

func (*CronjobData) ProtoMessage

func (*CronjobData) ProtoMessage()

func (*CronjobData) ProtoReflect

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

func (*CronjobData) Reset

func (x *CronjobData) Reset()

func (*CronjobData) Sanitize added in v0.9.4

func (m *CronjobData) Sanitize() error

func (*CronjobData) String

func (x *CronjobData) String() string

func (*CronjobData) Validate

func (m *CronjobData) Validate() error

Validate checks the field values on CronjobData with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CronjobData) ValidateAll

func (m *CronjobData) ValidateAll() error

ValidateAll checks the field values on CronjobData with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CronjobDataMultiError, or nil if none found.

type CronjobDataMultiError

type CronjobDataMultiError []error

CronjobDataMultiError is an error wrapping multiple validation errors returned by CronjobData.ValidateAll() if the designated constraints aren't met.

func (CronjobDataMultiError) AllErrors

func (m CronjobDataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CronjobDataMultiError) Error

func (m CronjobDataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CronjobDataValidationError

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

CronjobDataValidationError is the validation error returned by CronjobData.Validate if the designated constraints aren't met.

func (CronjobDataValidationError) Cause

Cause function returns cause value.

func (CronjobDataValidationError) Error

Error satisfies the builtin error interface

func (CronjobDataValidationError) ErrorName

func (e CronjobDataValidationError) ErrorName() string

ErrorName returns error name.

func (CronjobDataValidationError) Field

Field function returns field value.

func (CronjobDataValidationError) Key

Key function returns key value.

func (CronjobDataValidationError) Reason

Reason function returns reason value.

type CronjobLockOwnerState

type CronjobLockOwnerState struct {
	Hostname  string               `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*CronjobLockOwnerState) Descriptor deprecated

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

Deprecated: Use CronjobLockOwnerState.ProtoReflect.Descriptor instead.

func (*CronjobLockOwnerState) GetHostname

func (x *CronjobLockOwnerState) GetHostname() string

func (*CronjobLockOwnerState) GetUpdatedAt

func (x *CronjobLockOwnerState) GetUpdatedAt() *timestamp.Timestamp

func (*CronjobLockOwnerState) ProtoMessage

func (*CronjobLockOwnerState) ProtoMessage()

func (*CronjobLockOwnerState) ProtoReflect

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

func (*CronjobLockOwnerState) Reset

func (x *CronjobLockOwnerState) Reset()

func (*CronjobLockOwnerState) Sanitize added in v0.9.4

func (m *CronjobLockOwnerState) Sanitize() error

func (*CronjobLockOwnerState) String

func (x *CronjobLockOwnerState) String() string

func (*CronjobLockOwnerState) Validate

func (m *CronjobLockOwnerState) Validate() error

Validate checks the field values on CronjobLockOwnerState with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CronjobLockOwnerState) ValidateAll

func (m *CronjobLockOwnerState) ValidateAll() error

ValidateAll checks the field values on CronjobLockOwnerState with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CronjobLockOwnerStateMultiError, or nil if none found.

type CronjobLockOwnerStateMultiError

type CronjobLockOwnerStateMultiError []error

CronjobLockOwnerStateMultiError is an error wrapping multiple validation errors returned by CronjobLockOwnerState.ValidateAll() if the designated constraints aren't met.

func (CronjobLockOwnerStateMultiError) AllErrors

func (m CronjobLockOwnerStateMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CronjobLockOwnerStateMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type CronjobLockOwnerStateValidationError

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

CronjobLockOwnerStateValidationError is the validation error returned by CronjobLockOwnerState.Validate if the designated constraints aren't met.

func (CronjobLockOwnerStateValidationError) Cause

Cause function returns cause value.

func (CronjobLockOwnerStateValidationError) Error

Error satisfies the builtin error interface

func (CronjobLockOwnerStateValidationError) ErrorName

ErrorName returns error name.

func (CronjobLockOwnerStateValidationError) Field

Field function returns field value.

func (CronjobLockOwnerStateValidationError) Key

Key function returns key value.

func (CronjobLockOwnerStateValidationError) Reason

Reason function returns reason value.

type CronjobMultiError

type CronjobMultiError []error

CronjobMultiError is an error wrapping multiple validation errors returned by Cronjob.ValidateAll() if the designated constraints aren't met.

func (CronjobMultiError) AllErrors

func (m CronjobMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CronjobMultiError) Error

func (m CronjobMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CronjobSchedulerEvent

type CronjobSchedulerEvent struct {
	Cronjob *Cronjob `protobuf:"bytes,1,opt,name=cronjob,proto3" json:"cronjob,omitempty"`
	// contains filtered or unexported fields
}

func (*CronjobSchedulerEvent) Descriptor deprecated

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

Deprecated: Use CronjobSchedulerEvent.ProtoReflect.Descriptor instead.

func (*CronjobSchedulerEvent) GetCronjob

func (x *CronjobSchedulerEvent) GetCronjob() *Cronjob

func (*CronjobSchedulerEvent) ProtoMessage

func (*CronjobSchedulerEvent) ProtoMessage()

func (*CronjobSchedulerEvent) ProtoReflect

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

func (*CronjobSchedulerEvent) Reset

func (x *CronjobSchedulerEvent) Reset()

func (*CronjobSchedulerEvent) Sanitize added in v0.9.4

func (m *CronjobSchedulerEvent) Sanitize() error

func (*CronjobSchedulerEvent) String

func (x *CronjobSchedulerEvent) String() string

func (*CronjobSchedulerEvent) Validate

func (m *CronjobSchedulerEvent) Validate() error

Validate checks the field values on CronjobSchedulerEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CronjobSchedulerEvent) ValidateAll

func (m *CronjobSchedulerEvent) ValidateAll() error

ValidateAll checks the field values on CronjobSchedulerEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CronjobSchedulerEventMultiError, or nil if none found.

type CronjobSchedulerEventMultiError

type CronjobSchedulerEventMultiError []error

CronjobSchedulerEventMultiError is an error wrapping multiple validation errors returned by CronjobSchedulerEvent.ValidateAll() if the designated constraints aren't met.

func (CronjobSchedulerEventMultiError) AllErrors

func (m CronjobSchedulerEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CronjobSchedulerEventMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type CronjobSchedulerEventValidationError

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

CronjobSchedulerEventValidationError is the validation error returned by CronjobSchedulerEvent.Validate if the designated constraints aren't met.

func (CronjobSchedulerEventValidationError) Cause

Cause function returns cause value.

func (CronjobSchedulerEventValidationError) Error

Error satisfies the builtin error interface

func (CronjobSchedulerEventValidationError) ErrorName

ErrorName returns error name.

func (CronjobSchedulerEventValidationError) Field

Field function returns field value.

func (CronjobSchedulerEventValidationError) Key

Key function returns key value.

func (CronjobSchedulerEventValidationError) Reason

Reason function returns reason value.

type CronjobState

type CronjobState int32
const (
	CronjobState_CRONJOB_STATE_UNSPECIFIED CronjobState = 0
	CronjobState_CRONJOB_STATE_WAITING     CronjobState = 1
	CronjobState_CRONJOB_STATE_PENDING     CronjobState = 2
	CronjobState_CRONJOB_STATE_RUNNING     CronjobState = 3
)

func (CronjobState) Descriptor

func (CronjobState) Enum

func (x CronjobState) Enum() *CronjobState

func (CronjobState) EnumDescriptor deprecated

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

Deprecated: Use CronjobState.Descriptor instead.

func (CronjobState) Number

func (CronjobState) String

func (x CronjobState) String() string

func (CronjobState) Type

type CronjobValidationError

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

CronjobValidationError is the validation error returned by Cronjob.Validate if the designated constraints aren't met.

func (CronjobValidationError) Cause

func (e CronjobValidationError) Cause() error

Cause function returns cause value.

func (CronjobValidationError) Error

func (e CronjobValidationError) Error() string

Error satisfies the builtin error interface

func (CronjobValidationError) ErrorName

func (e CronjobValidationError) ErrorName() string

ErrorName returns error name.

func (CronjobValidationError) Field

func (e CronjobValidationError) Field() string

Field function returns field value.

func (CronjobValidationError) Key

func (e CronjobValidationError) Key() bool

Key function returns key value.

func (CronjobValidationError) Reason

func (e CronjobValidationError) Reason() string

Reason function returns reason value.

type GenericCronData added in v0.9.4

type GenericCronData struct {

	// @sanitize: method=StripTags
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GenericCronData) Descriptor deprecated added in v0.9.4

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

Deprecated: Use GenericCronData.ProtoReflect.Descriptor instead.

func (*GenericCronData) GetAttributes added in v0.9.4

func (x *GenericCronData) GetAttributes() map[string]string

func (*GenericCronData) ProtoMessage added in v0.9.4

func (*GenericCronData) ProtoMessage()

func (*GenericCronData) ProtoReflect added in v0.9.4

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

func (*GenericCronData) Reset added in v0.9.4

func (x *GenericCronData) Reset()

func (*GenericCronData) Sanitize added in v0.9.4

func (m *GenericCronData) Sanitize() error

func (*GenericCronData) String added in v0.9.4

func (x *GenericCronData) String() string

func (*GenericCronData) Validate added in v0.9.4

func (m *GenericCronData) Validate() error

Validate checks the field values on GenericCronData with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GenericCronData) ValidateAll added in v0.9.4

func (m *GenericCronData) ValidateAll() error

ValidateAll checks the field values on GenericCronData with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GenericCronDataMultiError, or nil if none found.

type GenericCronDataMultiError added in v0.9.4

type GenericCronDataMultiError []error

GenericCronDataMultiError is an error wrapping multiple validation errors returned by GenericCronData.ValidateAll() if the designated constraints aren't met.

func (GenericCronDataMultiError) AllErrors added in v0.9.4

func (m GenericCronDataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GenericCronDataMultiError) Error added in v0.9.4

Error returns a concatenation of all the error messages it wraps.

type GenericCronDataValidationError added in v0.9.4

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

GenericCronDataValidationError is the validation error returned by GenericCronData.Validate if the designated constraints aren't met.

func (GenericCronDataValidationError) Cause added in v0.9.4

Cause function returns cause value.

func (GenericCronDataValidationError) Error added in v0.9.4

Error satisfies the builtin error interface

func (GenericCronDataValidationError) ErrorName added in v0.9.4

func (e GenericCronDataValidationError) ErrorName() string

ErrorName returns error name.

func (GenericCronDataValidationError) Field added in v0.9.4

Field function returns field value.

func (GenericCronDataValidationError) Key added in v0.9.4

Key function returns key value.

func (GenericCronDataValidationError) Reason added in v0.9.4

Reason function returns reason value.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL