Documentation
¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the sinks v1alpha1 API group +k8s:deepcopy-gen=package +groupName=sources.knative.dev
Index ¶
- Constants
- Variables
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type RedisStreamSink
- func (in *RedisStreamSink) DeepCopy() *RedisStreamSink
- func (in *RedisStreamSink) DeepCopyInto(out *RedisStreamSink)
- func (in *RedisStreamSink) DeepCopyObject() runtime.Object
- func (*RedisStreamSink) GetConditionSet() apis.ConditionSet
- func (s *RedisStreamSink) GetGroupVersionKind() schema.GroupVersionKind
- func (p *RedisStreamSink) GetStatus() *duckv1.Status
- func (s *RedisStreamSink) GetUntypedSpec() interface{}
- type RedisStreamSinkList
- type RedisStreamSinkSpec
- type RedisStreamSinkStatus
- func (in *RedisStreamSinkStatus) DeepCopy() *RedisStreamSinkStatus
- func (in *RedisStreamSinkStatus) DeepCopyInto(out *RedisStreamSinkStatus)
- func (s *RedisStreamSinkStatus) GetCondition(t apis.ConditionType) *apis.Condition
- func (s *RedisStreamSinkStatus) GetTopLevelCondition() *apis.Condition
- func (s *RedisStreamSinkStatus) InitializeConditions()
- func (s *RedisStreamSinkStatus) IsReady() bool
- func (s *RedisStreamSinkStatus) MarkKnativeService()
- func (s *RedisStreamSinkStatus) MarkNoKnativeService(reason string)
- func (s *RedisStreamSinkStatus) MarkNoRoleBinding(reason string)
- func (s *RedisStreamSinkStatus) MarkNoServiceAccount(reason string)
- func (s *RedisStreamSinkStatus) MarkRoleBinding()
- func (s *RedisStreamSinkStatus) MarkServiceAccount()
- func (s *RedisStreamSinkStatus) PropagateKnativeServiceAddress(ks *servingv1.Service) bool
Constants ¶
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 ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: sinks.GroupName, Version: "v1alpha1"}
SchemeGroupVersion is group version used to register these objects
Functions ¶
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