Documentation
¶
Overview ¶
Package v1alpha1 is the v1alpha1 version of the API. +k8s:deepcopy-gen=package +groupName=messaging.reiggermesh.io
Index ¶
- Constants
- Variables
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type LoudVentsChannel
- func (in *LoudVentsChannel) DeepCopy() *LoudVentsChannel
- func (in *LoudVentsChannel) DeepCopyInto(out *LoudVentsChannel)
- func (in *LoudVentsChannel) DeepCopyObject() runtime.Object
- func (*LoudVentsChannel) GetConditionSet() apis.ConditionSet
- func (*LoudVentsChannel) GetGroupVersionKind() schema.GroupVersionKind
- func (t *LoudVentsChannel) GetStatus() *duckv1.Status
- func (i *LoudVentsChannel) GetUntypedSpec() interface{}
- func (lvc *LoudVentsChannel) IsReady() bool
- type LoudVentsChannelList
- type LoudVentsChannelSpec
- type LoudVentsChannelStatus
- func (in *LoudVentsChannelStatus) DeepCopy() *LoudVentsChannelStatus
- func (in *LoudVentsChannelStatus) DeepCopyInto(out *LoudVentsChannelStatus)
- func (lvcs *LoudVentsChannelStatus) GetCondition(t apis.ConditionType) *apis.Condition
- func (lvcs *LoudVentsChannelStatus) InitializeConditions()
- func (lvcs *LoudVentsChannelStatus) MarkChannelServiceFailed(reason, messageFormat string, messageA ...interface{})
- func (lvcs *LoudVentsChannelStatus) MarkChannelServiceTrue()
- func (lvcs *LoudVentsChannelStatus) MarkChannelServiceUnknown(reason, messageFormat string, messageA ...interface{})
- func (lvcs *LoudVentsChannelStatus) MarkDeadLetterSinkNotConfigured()
- func (lvcs *LoudVentsChannelStatus) MarkDeadLetterSinkResolvedFailed(reason, messageFormat string, messageA ...interface{})
- func (lvcs *LoudVentsChannelStatus) MarkDeadLetterSinkResolvedSucceeded(deadLetterSinkURI *apis.URL)
- func (lvcs *LoudVentsChannelStatus) MarkDispatcherFailed(reason, messageFormat string, messageA ...interface{})
- func (lvcs *LoudVentsChannelStatus) MarkDispatcherUnknown(reason, messageFormat string, messageA ...interface{})
- func (lvcs *LoudVentsChannelStatus) MarkEndpointsFailed(reason, messageFormat string, messageA ...interface{})
- func (lvcs *LoudVentsChannelStatus) MarkEndpointsTrue()
- func (lvcs *LoudVentsChannelStatus) MarkEndpointsUnknown(reason, messageFormat string, messageA ...interface{})
- func (lvcs *LoudVentsChannelStatus) MarkServiceFailed(reason, messageFormat string, messageA ...interface{})
- func (lvcs *LoudVentsChannelStatus) MarkServiceTrue()
- func (lvcs *LoudVentsChannelStatus) MarkServiceUnknown(reason, messageFormat string, messageA ...interface{})
- func (lvcs *LoudVentsChannelStatus) PropagateDispatcherStatus(ds *appsv1.DeploymentStatus)
- func (lvcs *LoudVentsChannelStatus) SetAddress(url *apis.URL)
Constants ¶
const ( // LoudVentsChannelConditionReady has status True when all subconditions below have been set to True. LoudVentsChannelConditionReady = apis.ConditionReady // LoudVentsChannelConditionDispatcherReady has status True when a Dispatcher deployment is ready // Keyed off appsv1.DeploymentAvailable, which means minimum available replicas required are up // and running for at least minReadySeconds. LoudVentsChannelConditionDispatcherReady apis.ConditionType = "DispatcherReady" // LoudVentsChannelConditionServiceReady has status True when a k8s Service is ready. This // basically just means it exists because there's no meaningful status in Service. See Endpoints // below. LoudVentsChannelConditionServiceReady apis.ConditionType = "ServiceReady" // LoudVentsChannelConditionEndpointsReady has status True when a k8s Service Endpoints are backed // by at least one endpoint. LoudVentsChannelConditionEndpointsReady apis.ConditionType = "EndpointsReady" // LoudVentsChannelConditionAddressable has status true when this LoudVentsChannel meets // the Addressable contract and has a non-empty hostname. LoudVentsChannelConditionAddressable apis.ConditionType = "Addressable" // LoudVentsChannelConditionServiceReady has status True when a k8s Service representing the channel is ready. // Because this uses ExternalName, there are no endpoints to check. LoudVentsChannelConditionChannelServiceReady apis.ConditionType = "ChannelServiceReady" // LoudVentsChannelConditionDeadLetterSinkResolved has status True when there is a Dead Letter Sink ref or URI // defined in the Spec.Delivery, is a valid destination and its correctly resolved into a valid URI LoudVentsChannelConditionDeadLetterSinkResolved apis.ConditionType = "DeadLetterSinkResolved" )
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: messaging.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 LoudVentsChannel ¶
type LoudVentsChannel struct { metav1.TypeMeta `json:",inline"` // +optional metav1.ObjectMeta `json:"metadata,omitempty"` // Spec defines the desired state of the Channel. Spec LoudVentsChannelSpec `json:"spec,omitempty"` // Status represents the current state of the Channel. This data may be out of // date. // +optional Status LoudVentsChannelStatus `json:"status,omitempty"` }
LoudVentsChannel is a resource representing a loudvents channel
func (*LoudVentsChannel) DeepCopy ¶
func (in *LoudVentsChannel) DeepCopy() *LoudVentsChannel
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoudVentsChannel.
func (*LoudVentsChannel) DeepCopyInto ¶
func (in *LoudVentsChannel) DeepCopyInto(out *LoudVentsChannel)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LoudVentsChannel) DeepCopyObject ¶
func (in *LoudVentsChannel) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*LoudVentsChannel) GetConditionSet ¶
func (*LoudVentsChannel) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*LoudVentsChannel) GetGroupVersionKind ¶
func (*LoudVentsChannel) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind returns GroupVersionKind for LoudVentsChannels
func (*LoudVentsChannel) GetStatus ¶
func (t *LoudVentsChannel) GetStatus() *duckv1.Status
GetStatus retrieves the status of the LoudVentsChannel. Implements the KRShaped interface.
func (*LoudVentsChannel) GetUntypedSpec ¶
func (i *LoudVentsChannel) GetUntypedSpec() interface{}
GetUntypedSpec returns the spec of the LoudVentsChannel.
func (*LoudVentsChannel) IsReady ¶
func (lvc *LoudVentsChannel) IsReady() bool
IsReady returns true if the Status condition LoudVentsChannelConditionReady is true and the latest spec has been observed.
type LoudVentsChannelList ¶
type LoudVentsChannelList struct { metav1.TypeMeta `json:",inline"` // +optional metav1.ListMeta `json:"metadata,omitempty"` Items []LoudVentsChannel `json:"items"` }
LoudVentsChannelList is a collection of loudvents channels.
func (*LoudVentsChannelList) DeepCopy ¶
func (in *LoudVentsChannelList) DeepCopy() *LoudVentsChannelList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoudVentsChannelList.
func (*LoudVentsChannelList) DeepCopyInto ¶
func (in *LoudVentsChannelList) DeepCopyInto(out *LoudVentsChannelList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LoudVentsChannelList) DeepCopyObject ¶
func (in *LoudVentsChannelList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type LoudVentsChannelSpec ¶
type LoudVentsChannelSpec struct { // Channel conforms to Duck type Channelable. eventingduckv1.ChannelableSpec `json:",inline"` }
LoudVentsChannelSpec defines which subscribers have expressed interest in receiving events from this LoudVentsChannel. arguments for a Channel.
func (*LoudVentsChannelSpec) DeepCopy ¶
func (in *LoudVentsChannelSpec) DeepCopy() *LoudVentsChannelSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoudVentsChannelSpec.
func (*LoudVentsChannelSpec) DeepCopyInto ¶
func (in *LoudVentsChannelSpec) DeepCopyInto(out *LoudVentsChannelSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LoudVentsChannelStatus ¶
type LoudVentsChannelStatus struct { // Channel conforms to Duck type ChannelableStatus. eventingduckv1.ChannelableStatus `json:",inline"` }
LoudVentsChannelStatus represents the current state of a Channel.
func (*LoudVentsChannelStatus) DeepCopy ¶
func (in *LoudVentsChannelStatus) DeepCopy() *LoudVentsChannelStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoudVentsChannelStatus.
func (*LoudVentsChannelStatus) DeepCopyInto ¶
func (in *LoudVentsChannelStatus) DeepCopyInto(out *LoudVentsChannelStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*LoudVentsChannelStatus) GetCondition ¶
func (lvcs *LoudVentsChannelStatus) GetCondition(t apis.ConditionType) *apis.Condition
GetCondition returns the condition currently associated with the given type, or nil.
func (*LoudVentsChannelStatus) InitializeConditions ¶
func (lvcs *LoudVentsChannelStatus) InitializeConditions()
InitializeConditions sets relevant unset conditions to Unknown state.
func (*LoudVentsChannelStatus) MarkChannelServiceFailed ¶
func (lvcs *LoudVentsChannelStatus) MarkChannelServiceFailed(reason, messageFormat string, messageA ...interface{})
func (*LoudVentsChannelStatus) MarkChannelServiceTrue ¶
func (lvcs *LoudVentsChannelStatus) MarkChannelServiceTrue()
func (*LoudVentsChannelStatus) MarkChannelServiceUnknown ¶
func (lvcs *LoudVentsChannelStatus) MarkChannelServiceUnknown(reason, messageFormat string, messageA ...interface{})
func (*LoudVentsChannelStatus) MarkDeadLetterSinkNotConfigured ¶
func (lvcs *LoudVentsChannelStatus) MarkDeadLetterSinkNotConfigured()
func (*LoudVentsChannelStatus) MarkDeadLetterSinkResolvedFailed ¶
func (lvcs *LoudVentsChannelStatus) MarkDeadLetterSinkResolvedFailed(reason, messageFormat string, messageA ...interface{})
func (*LoudVentsChannelStatus) MarkDeadLetterSinkResolvedSucceeded ¶
func (lvcs *LoudVentsChannelStatus) MarkDeadLetterSinkResolvedSucceeded(deadLetterSinkURI *apis.URL)
func (*LoudVentsChannelStatus) MarkDispatcherFailed ¶
func (lvcs *LoudVentsChannelStatus) MarkDispatcherFailed(reason, messageFormat string, messageA ...interface{})
func (*LoudVentsChannelStatus) MarkDispatcherUnknown ¶
func (lvcs *LoudVentsChannelStatus) MarkDispatcherUnknown(reason, messageFormat string, messageA ...interface{})
func (*LoudVentsChannelStatus) MarkEndpointsFailed ¶
func (lvcs *LoudVentsChannelStatus) MarkEndpointsFailed(reason, messageFormat string, messageA ...interface{})
func (*LoudVentsChannelStatus) MarkEndpointsTrue ¶
func (lvcs *LoudVentsChannelStatus) MarkEndpointsTrue()
func (*LoudVentsChannelStatus) MarkEndpointsUnknown ¶
func (lvcs *LoudVentsChannelStatus) MarkEndpointsUnknown(reason, messageFormat string, messageA ...interface{})
func (*LoudVentsChannelStatus) MarkServiceFailed ¶
func (lvcs *LoudVentsChannelStatus) MarkServiceFailed(reason, messageFormat string, messageA ...interface{})
func (*LoudVentsChannelStatus) MarkServiceTrue ¶
func (lvcs *LoudVentsChannelStatus) MarkServiceTrue()
func (*LoudVentsChannelStatus) MarkServiceUnknown ¶
func (lvcs *LoudVentsChannelStatus) MarkServiceUnknown(reason, messageFormat string, messageA ...interface{})
func (*LoudVentsChannelStatus) PropagateDispatcherStatus ¶
func (lvcs *LoudVentsChannelStatus) PropagateDispatcherStatus(ds *appsv1.DeploymentStatus)
TODO: Unify this with the ones from Eventing. Say: Broker, Trigger.
func (*LoudVentsChannelStatus) SetAddress ¶
func (lvcs *LoudVentsChannelStatus) SetAddress(url *apis.URL)