v1alpha1

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2019 License: Apache-2.0 Imports: 14 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	ProcessorConditionReady = knapis.ConditionReady
	// TODO add aggregated streams ready status
	ProcessorConditionFunctionReady   knapis.ConditionType = "FunctionReady"
	ProcessorConditionDeploymentReady knapis.ConditionType = "DeploymentReady"
)
View Source 
const (
	StreamConditionReady                                  = knapis.ConditionReady
	StreamConditionResourceAvailable knapis.ConditionType = "ResourceAvailable"
)

Variables

View Source 
var (

	// AddToScheme adds Build types to the scheme.
	AddToScheme = schemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: streaming.GroupName, Version: "v1alpha1"}

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 Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type Processor 

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

	Spec   ProcessorSpec   `json:"spec"`
	Status ProcessorStatus `json:"status"`
}

func (*Processor) DeepCopy 

func (in *Processor) DeepCopy() *Processor

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

func (*Processor) DeepCopyInto 

func (in *Processor) DeepCopyInto(out *Processor)

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

func (*Processor) DeepCopyObject 

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

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

func (*Processor) GetGroupVersionKind 

func (*Processor) GetGroupVersionKind() schema.GroupVersionKind

func (*Processor) GetStatus 

func (p *Processor) GetStatus() apis.Status

func (*Processor) SetDefaults 

func (p *Processor) SetDefaults(ctx context.Context)

func (*Processor) Validate 

func (p *Processor) Validate(ctx context.Context) *apis.FieldError

type ProcessorList 

type ProcessorList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []Processor `json:"items"`
}

func (*ProcessorList) DeepCopy 

func (in *ProcessorList) DeepCopy() *ProcessorList

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

func (*ProcessorList) DeepCopyInto 

func (in *ProcessorList) DeepCopyInto(out *ProcessorList)

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

func (*ProcessorList) DeepCopyObject 

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

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

type ProcessorSpec 

type ProcessorSpec struct {
	FunctionRef string   `json:"functionRef"`
	Inputs      []string `json:"inputs"`
	Outputs     []string `json:"outputs"`
}

func (*ProcessorSpec) DeepCopy 

func (in *ProcessorSpec) DeepCopy() *ProcessorSpec

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

func (*ProcessorSpec) DeepCopyInto 

func (in *ProcessorSpec) DeepCopyInto(out *ProcessorSpec)

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

func (*ProcessorSpec) SetDefaults 

func (ps *ProcessorSpec) SetDefaults(ctx context.Context)

func (*ProcessorSpec) Validate 

func (ps *ProcessorSpec) Validate(ctx context.Context) *apis.FieldError

type ProcessorStatus 

type ProcessorStatus struct {
	duckv1beta1.Status `json:",inline"`

	InputAddresses     []string `json:"inputAddresses,omitempty"`
	OutputAddresses    []string `json:"outputAddresses,omitempty"`
	OutputContentTypes []string `json:"outputContentTypes,omitempty"`
	DeploymentName     string   `json:"deploymentName,omitempty"`
	FunctionImage      string   `json:"functionImage,omitempty"`
}

func (*ProcessorStatus) DeepCopy 

func (in *ProcessorStatus) DeepCopy() *ProcessorStatus

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

func (*ProcessorStatus) DeepCopyInto 

func (in *ProcessorStatus) DeepCopyInto(out *ProcessorStatus)

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

func (*ProcessorStatus) GetCondition 

func (ps *ProcessorStatus) GetCondition(t knapis.ConditionType) *knapis.Condition

func (*ProcessorStatus) GetObservedGeneration 

func (ps *ProcessorStatus) GetObservedGeneration() int64

func (*ProcessorStatus) GetReadyConditionType 

func (*ProcessorStatus) GetReadyConditionType() knapis.ConditionType

func (*ProcessorStatus) InitializeConditions 

func (ps *ProcessorStatus) InitializeConditions()

func (*ProcessorStatus) IsReady 

func (ps *ProcessorStatus) IsReady() bool

func (*ProcessorStatus) MarkDeploymentNotOwned 

func (ps *ProcessorStatus) MarkDeploymentNotOwned(name string)

func (*ProcessorStatus) MarkFunctionNotFound 

func (ps *ProcessorStatus) MarkFunctionNotFound(name string)

func (*ProcessorStatus) PropagateDeploymentStatus 

func (ps *ProcessorStatus) PropagateDeploymentStatus(ds *appsv1.DeploymentStatus)

func (*ProcessorStatus) PropagateFunctionStatus 

func (ps *ProcessorStatus) PropagateFunctionStatus(fs *buildv1alpha1.FunctionStatus)

type Stream 

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

	Spec   StreamSpec   `json:"spec"`
	Status StreamStatus `json:"status"`
}

func (*Stream) DeepCopy 

func (in *Stream) DeepCopy() *Stream

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

func (*Stream) DeepCopyInto 

func (in *Stream) DeepCopyInto(out *Stream)

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

func (*Stream) DeepCopyObject 

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

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

func (*Stream) GetGroupVersionKind 

func (*Stream) GetGroupVersionKind() schema.GroupVersionKind

func (*Stream) GetStatus 

func (s *Stream) GetStatus() apis.Status

func (*Stream) SetDefaults 

func (s *Stream) SetDefaults(ctx context.Context)

func (*Stream) Validate 

func (s *Stream) Validate(ctx context.Context) *apis.FieldError

type StreamAddress 

type StreamAddress struct {
	Gateway string `json:"gateway,omitempty"`
	Topic   string `json:"topic,omitempty"`
}

func (*StreamAddress) DeepCopy 

func (in *StreamAddress) DeepCopy() *StreamAddress

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

func (*StreamAddress) DeepCopyInto 

func (in *StreamAddress) DeepCopyInto(out *StreamAddress)

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

func (StreamAddress) String 

func (a StreamAddress) String() string

type StreamList 

type StreamList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []Stream `json:"items"`
}

func (*StreamList) DeepCopy 

func (in *StreamList) DeepCopy() *StreamList

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

func (*StreamList) DeepCopyInto 

func (in *StreamList) DeepCopyInto(out *StreamList)

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

func (*StreamList) DeepCopyObject 

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

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

type StreamSpec 

type StreamSpec struct {
	Provider    string `json:"provider"`
	ContentType string `json:"contentType"`
}

func (*StreamSpec) DeepCopy 

func (in *StreamSpec) DeepCopy() *StreamSpec

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

func (*StreamSpec) DeepCopyInto 

func (in *StreamSpec) DeepCopyInto(out *StreamSpec)

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

func (*StreamSpec) SetDefaults 

func (ss *StreamSpec) SetDefaults(ctx context.Context)

func (*StreamSpec) Validate 

func (ss *StreamSpec) Validate(ctx context.Context) *apis.FieldError

type StreamStatus 

type StreamStatus struct {
	duckv1beta1.Status `json:",inline"`

	Address StreamAddress `json:"address,omitempty"`
}

func (*StreamStatus) DeepCopy 

func (in *StreamStatus) DeepCopy() *StreamStatus

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

func (*StreamStatus) DeepCopyInto 

func (in *StreamStatus) DeepCopyInto(out *StreamStatus)

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

func (*StreamStatus) GetCondition 

func (ss *StreamStatus) GetCondition(t knapis.ConditionType) *knapis.Condition

func (*StreamStatus) GetObservedGeneration 

func (ss *StreamStatus) GetObservedGeneration() int64

func (*StreamStatus) GetReadyConditionType 

func (*StreamStatus) GetReadyConditionType() knapis.ConditionType

func (*StreamStatus) InitializeConditions 

func (ss *StreamStatus) InitializeConditions()

func (*StreamStatus) IsReady 

func (ss *StreamStatus) IsReady() bool

func (*StreamStatus) MarkStreamProvisionFailed 

func (ss *StreamStatus) MarkStreamProvisionFailed(message string)

func (*StreamStatus) MarkStreamProvisioned 

func (ss *StreamStatus) MarkStreamProvisioned()

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.