v1alpha1

package
v0.43.0 Latest Latest
Warning

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

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

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the sinks v1alpha1 API group +k8s:deepcopy-gen=package +groupName=sources.knative.dev

Index

Constants

View Source 
const (
	// RedisStreamConditionReady has status True when the RedisStreamSink is ready to send events.
	RedisStreamConditionReady = apis.ConditionReady

	// RedisStreamConditionServiceReady has status True when the RedisStreamSink has had it's Knative service created and ready
	RedisStreamConditionServiceReady apis.ConditionType = "ServiceReady"
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: sinks.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 RedisStreamSink 

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

	Spec   RedisStreamSinkSpec   `json:"spec,omitempty"`
	Status RedisStreamSinkStatus `json:"status,omitempty"`
}

RedisStreamSink is the Schema for the RedisStream API.

func (*RedisStreamSink) DeepCopy 

func (in *RedisStreamSink) DeepCopy() *RedisStreamSink

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

func (*RedisStreamSink) DeepCopyInto 

func (in *RedisStreamSink) DeepCopyInto(out *RedisStreamSink)

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

func (*RedisStreamSink) DeepCopyObject 

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

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

func (*RedisStreamSink) GetConditionSet 

func (*RedisStreamSink) GetConditionSet() apis.ConditionSet

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

func (*RedisStreamSink) GetGroupVersionKind 

func (s *RedisStreamSink) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns the GroupVersionKind.

func (*RedisStreamSink) GetStatus 

func (p *RedisStreamSink) GetStatus() *duckv1.Status

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

func (*RedisStreamSink) GetUntypedSpec 

func (s *RedisStreamSink) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the RedisStreamSink.

type RedisStreamSinkList 

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

RedisStreamSinkList contains a list of RedisStreamSink.

func (*RedisStreamSinkList) DeepCopy 

func (in *RedisStreamSinkList) DeepCopy() *RedisStreamSinkList

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

func (*RedisStreamSinkList) DeepCopyInto 

func (in *RedisStreamSinkList) DeepCopyInto(out *RedisStreamSinkList)

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

func (*RedisStreamSinkList) DeepCopyObject 

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

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

type RedisStreamSinkSpec 

type RedisStreamSinkSpec struct {
	// RedisConnection represents the address and options to connect
	// to a Redis instance
	apisv1alpha1.RedisConnection `json:",inline"`

	// Stream is the name of the stream to send events to
	Stream string `json:"stream"`
}

RedisStreamSinkSpec defines the desired state of the RedisStreamSink.

func (*RedisStreamSinkSpec) DeepCopy 

func (in *RedisStreamSinkSpec) DeepCopy() *RedisStreamSinkSpec

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

func (*RedisStreamSinkSpec) DeepCopyInto 

func (in *RedisStreamSinkSpec) DeepCopyInto(out *RedisStreamSinkSpec)

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

type RedisStreamSinkStatus 

type RedisStreamSinkStatus struct {
	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Service that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`
	// AddressStatus is the part where this Sink fulfills the Addressable contract.
	duckv1.AddressStatus `json:",inline"`
}

RedisStreamSinkStatus defines the observed state of RedisStreamSink.

func (*RedisStreamSinkStatus) DeepCopy 

func (in *RedisStreamSinkStatus) DeepCopy() *RedisStreamSinkStatus

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

func (*RedisStreamSinkStatus) DeepCopyInto 

func (in *RedisStreamSinkStatus) DeepCopyInto(out *RedisStreamSinkStatus)

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

func (*RedisStreamSinkStatus) GetCondition 

func (s *RedisStreamSinkStatus) GetCondition(t apis.ConditionType) *apis.Condition

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

func (*RedisStreamSinkStatus) GetTopLevelCondition 

func (s *RedisStreamSinkStatus) GetTopLevelCondition() *apis.Condition

GetTopLevelCondition returns the top level condition.

func (*RedisStreamSinkStatus) InitializeConditions 

func (s *RedisStreamSinkStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*RedisStreamSinkStatus) IsReady 

func (s *RedisStreamSinkStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*RedisStreamSinkStatus) MarkKnativeService 

func (s *RedisStreamSinkStatus) MarkKnativeService()

MarkKnativeService sets the annotation that the sink has a Knative Service

func (*RedisStreamSinkStatus) MarkNoKnativeService 

func (s *RedisStreamSinkStatus) MarkNoKnativeService(reason string)

MarkNoKnativeService sets the annotation that the sink does not have a Knative Service

func (*RedisStreamSinkStatus) MarkNoRoleBinding 

func (s *RedisStreamSinkStatus) MarkNoRoleBinding(reason string)

MarkNoRoleBinding sets the annotation that the sink does not have a role binding

func (*RedisStreamSinkStatus) MarkNoServiceAccount 

func (s *RedisStreamSinkStatus) MarkNoServiceAccount(reason string)

MarkNoServiceAccount sets the annotation that the sink does not have a service account

func (*RedisStreamSinkStatus) MarkRoleBinding 

func (s *RedisStreamSinkStatus) MarkRoleBinding()

MarkRoleBinding sets the annotation that the sink has a role binding

func (*RedisStreamSinkStatus) MarkServiceAccount 

func (s *RedisStreamSinkStatus) MarkServiceAccount()

MarkRoleBinding sets the annotation that the sink has a service account

func (*RedisStreamSinkStatus) PropagateKnativeServiceAddress 

func (s *RedisStreamSinkStatus) PropagateKnativeServiceAddress(ks *servingv1.Service) bool

PropagateKnativeServiceAddress propagates the Ksvc address to the sink

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.