v1

package
v0.0.0-...-750586a Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package v1 is the v1 version of the API. +k8s:deepcopy-gen=package +groupName=flow.knative.dev

Index

Constants

View Source 
const (
	StateMachineRunnerConditionReady                    = apis.ConditionReady
	StateMachineRunnerAddressable    apis.ConditionType = "Addressable"
)
View Source 
const (
	StateMachineConditionReady = apis.ConditionReady
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: statev1.GroupName, Version: "v1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func RegisterAlternateStateMachineConditionSet 

func RegisterAlternateStateMachineConditionSet(conditionSet apis.ConditionSet)

RegisterAlternateStateMachineConditionSet register a apis.ConditionSet for the given statemachine class.

func RegisterAlternateStateMachineRunnerConditionSet 

func RegisterAlternateStateMachineRunnerConditionSet(conditionSet apis.ConditionSet)

RegisterAlternateStateMachineRunnerConditionSet register a apis.ConditionSet for the given broker class.

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type EventType 

type EventType string

EventType represents an extensible event type in the state machine.

type Events 

type Events map[EventType]StateType

Events represents a mapping of events and states.

func (Events) DeepCopy 

func (in Events) DeepCopy() Events

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Events.

func (Events) DeepCopyInto 

func (in Events) DeepCopyInto(out *Events)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type State 

type State struct {
	Events Events `json:"events,omitempty"`
}

State binds a state with an action and a set of events it can handle.

func (*State) DeepCopy 

func (in *State) DeepCopy() *State

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new State.

func (*State) DeepCopyInto 

func (in *State) DeepCopyInto(out *State)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StateMachine 

type StateMachine struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   StateMachineSpec   `json:"spec,omitempty"`
	Status StateMachineStatus `json:"status,omitempty"`
}

StateMachine is the Schema for the StateMachine API

func (*StateMachine) DeepCopy 

func (in *StateMachine) DeepCopy() *StateMachine

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachine.

func (*StateMachine) DeepCopyInto 

func (in *StateMachine) DeepCopyInto(out *StateMachine)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StateMachine) DeepCopyObject 

func (in *StateMachine) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StateMachine) GetConditionSet 

func (sm *StateMachine) GetConditionSet() apis.ConditionSet

GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.

func (*StateMachine) GetGroupVersionKind 

func (t *StateMachine) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for StateMachines

func (*StateMachine) GetStatus 

func (t *StateMachine) GetStatus() *duckv1.Status

GetStatus retrieves the status of the StateMachine. Implements the KRShaped interface.

func (*StateMachine) SetDefaults 

func (sm *StateMachine) SetDefaults(ctx context.Context)

SetDefaults implements apis.Defaultable

func (*StateMachine) Validate 

func (sm *StateMachine) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

type StateMachineDefinition 

type StateMachineDefinition struct {
	Version            string             `json:"version,omitempty"`
	StateMachineStates StateMachineStates `json:"stateMachineStates"`
}

@TODO: delete from here This comes from StateMachineRunner

func (*StateMachineDefinition) DeepCopy 

func (in *StateMachineDefinition) DeepCopy() *StateMachineDefinition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachineDefinition.

func (*StateMachineDefinition) DeepCopyInto 

func (in *StateMachineDefinition) DeepCopyInto(out *StateMachineDefinition)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StateMachineList 

type StateMachineList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []StateMachine `json:"items"`
}

StateMachineList contains a list of StateMachine

func (*StateMachineList) DeepCopy 

func (in *StateMachineList) DeepCopy() *StateMachineList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachineList.

func (*StateMachineList) DeepCopyInto 

func (in *StateMachineList) DeepCopyInto(out *StateMachineList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StateMachineList) DeepCopyObject 

func (in *StateMachineList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type StateMachineRunner 

type StateMachineRunner struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   StateMachineRunnerSpec   `json:"spec,omitempty"`
	Status StateMachineRunnerStatus `json:"status,omitempty"`
}

StateMachineRunner is the Schema for the statemachinerunners API

func (*StateMachineRunner) DeepCopy 

func (in *StateMachineRunner) DeepCopy() *StateMachineRunner

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachineRunner.

func (*StateMachineRunner) DeepCopyInto 

func (in *StateMachineRunner) DeepCopyInto(out *StateMachineRunner)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StateMachineRunner) DeepCopyObject 

func (in *StateMachineRunner) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StateMachineRunner) GetConditionSet 

func (smr *StateMachineRunner) GetConditionSet() apis.ConditionSet

GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.

func (*StateMachineRunner) GetGroupVersionKind 

func (t *StateMachineRunner) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns GroupVersionKind for StateMachines

func (*StateMachineRunner) GetStatus 

func (t *StateMachineRunner) GetStatus() *duckv1.Status

GetStatus retrieves the status of the StateMachine. Implements the KRShaped interface.

func (*StateMachineRunner) SetDefaults 

func (smr *StateMachineRunner) SetDefaults(ctx context.Context)

SetDefaults implements apis.Defaultable

func (*StateMachineRunner) Validate 

func (smr *StateMachineRunner) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

type StateMachineRunnerList 

type StateMachineRunnerList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []StateMachineRunner `json:"items"`
}

StateMachineRunnerList contains a list of StateMachineRunner

func (*StateMachineRunnerList) DeepCopy 

func (in *StateMachineRunnerList) DeepCopy() *StateMachineRunnerList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachineRunnerList.

func (*StateMachineRunnerList) DeepCopyInto 

func (in *StateMachineRunnerList) DeepCopyInto(out *StateMachineRunnerList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StateMachineRunnerList) DeepCopyObject 

func (in *StateMachineRunnerList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type StateMachineRunnerSpec 

type StateMachineRunnerSpec struct {
	StateMachineRef string `json:"stateMachineRef,omitempty"`

	// +optional
	Broker string `json:"broker,omitempty"`

	// +optional
	Sink string `json:"sink,omitempty"`

	// +optional
	RedisHost string `json:"redisHost,omitempty"`
}

StateMachineRunnerSpec defines the desired state of WorkflowRunner

func (*StateMachineRunnerSpec) DeepCopy 

func (in *StateMachineRunnerSpec) DeepCopy() *StateMachineRunnerSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachineRunnerSpec.

func (*StateMachineRunnerSpec) DeepCopyInto 

func (in *StateMachineRunnerSpec) DeepCopyInto(out *StateMachineRunnerSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StateMachineRunnerSpec) Validate 

func (smrs *StateMachineRunnerSpec) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

type StateMachineRunnerStatus 

type StateMachineRunnerStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	RunnerUrl string `json:"runnerUrl,omitempty"`

	RunnerId string `json:"runnerId,omitempty"`

	BrokerUrl string `json:"brokerUrl,omitempty"`

	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the StateMachineRunner that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`
}

StateMachineRunnerStatus defines the observed state of WorkflowRunner

func (*StateMachineRunnerStatus) DeepCopy 

func (in *StateMachineRunnerStatus) DeepCopy() *StateMachineRunnerStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachineRunnerStatus.

func (*StateMachineRunnerStatus) DeepCopyInto 

func (in *StateMachineRunnerStatus) DeepCopyInto(out *StateMachineRunnerStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StateMachineRunnerStatus) GetCondition 

func (smrs *StateMachineRunnerStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*StateMachineRunnerStatus) GetConditionSet 

func (smrs *StateMachineRunnerStatus) GetConditionSet() apis.ConditionSet

GetConditionSet retrieves the condition set for this resource.

func (*StateMachineRunnerStatus) GetTopLevelCondition 

func (smrs *StateMachineRunnerStatus) GetTopLevelCondition() *apis.Condition

GetTopLevelCondition returns the top level Condition.

func (*StateMachineRunnerStatus) InitializeConditions 

func (smrs *StateMachineRunnerStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*StateMachineRunnerStatus) IsReady 

func (smrs *StateMachineRunnerStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*StateMachineRunnerStatus) SetAddress 

func (smrs *StateMachineRunnerStatus) SetAddress(url *apis.URL)

SetAddress makes this Broker addressable by setting the URI. It also sets the BrokerConditionAddressable to true.

type StateMachineSpec 

type StateMachineSpec struct {
	StateMachineDefinition StateMachineDefinition `json:"stateMachine,omitempty"`
}

StateMachineSpec defines the desired state of StateMachine

func (*StateMachineSpec) DeepCopy 

func (in *StateMachineSpec) DeepCopy() *StateMachineSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachineSpec.

func (*StateMachineSpec) DeepCopyInto 

func (in *StateMachineSpec) DeepCopyInto(out *StateMachineSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StateMachineSpec) Validate 

func (sms *StateMachineSpec) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

type StateMachineStates 

type StateMachineStates struct {
	States States `json:"states"`
}

func (*StateMachineStates) DeepCopy 

func (in *StateMachineStates) DeepCopy() *StateMachineStates

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachineStates.

func (*StateMachineStates) DeepCopyInto 

func (in *StateMachineStates) DeepCopyInto(out *StateMachineStates)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StateMachineStatus 

type StateMachineStatus struct {
	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the StateMachine that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`
}

StateMachineStatus defines the observed state of Workflow

func (*StateMachineStatus) DeepCopy 

func (in *StateMachineStatus) DeepCopy() *StateMachineStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StateMachineStatus.

func (*StateMachineStatus) DeepCopyInto 

func (in *StateMachineStatus) DeepCopyInto(out *StateMachineStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StateMachineStatus) GetCondition 

func (sms *StateMachineStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*StateMachineStatus) GetConditionSet 

func (sms *StateMachineStatus) GetConditionSet() apis.ConditionSet

GetConditionSet retrieves the condition set for this resource.

func (*StateMachineStatus) GetTopLevelCondition 

func (sms *StateMachineStatus) GetTopLevelCondition() *apis.Condition

GetTopLevelCondition returns the top level Condition.

func (*StateMachineStatus) InitializeConditions 

func (sms *StateMachineStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*StateMachineStatus) IsReady 

func (sms *StateMachineStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*StateMachineStatus) SetAddress 

func (sms *StateMachineStatus) SetAddress(url *apis.URL)

SetAddress makes this Broker addressable by setting the URI. It also sets the BrokerConditionAddressable to true.

type StateType 

type StateType string

StateType represents an extensible state type in the state machine.

type States 

type States map[StateType]State

States represents a mapping of states and their implementations.

func (States) DeepCopy 

func (in States) DeepCopy() States

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new States.

func (States) DeepCopyInto 

func (in States) DeepCopyInto(out *States)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

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.