v1alpha1

Apr 14, 2020

Changes in this version

type BrokerStatus

+ func (bs *BrokerStatus) PropagateFilterAvailability(ep *corev1.Endpoints)

+ func (bs *BrokerStatus) PropagateIngressAvailability(ep *corev1.Endpoints)

Mar 3, 2020

Changes in this version

type Broker

+ func (sink *Broker) ConvertFrom(ctx context.Context, obj apis.Convertible) error

+ func (source *Broker) ConvertTo(ctx context.Context, obj apis.Convertible) error

type BrokerSpec

+ Config *duckv1.KReference

type EventType

+ func (sink *EventType) ConvertFrom(ctx context.Context, obj apis.Convertible) error

+ func (source *EventType) ConvertTo(ctx context.Context, obj apis.Convertible) error

type Trigger

+ func (sink *Trigger) ConvertFrom(ctx context.Context, obj apis.Convertible) error

+ func (source *Trigger) ConvertTo(ctx context.Context, obj apis.Convertible) error

Jan 21, 2020

Changes in this version

type BrokerSpec

+ Delivery *eventingduckv1alpha1.DeliverySpec

type BrokerStatus

+ func (bs *BrokerStatus) GetTopLevelCondition() *apis.Condition

type EventTypeStatus

+ func (et *EventTypeStatus) GetTopLevelCondition() *apis.Condition

+ func (et *EventTypeStatus) MarkBrokerExistsUnknown(reason, messageFormat string, messageA ...interface{})

+ func (et *EventTypeStatus) MarkBrokerFailed(reason, messageFormat string, messageA ...interface{})

+ func (et *EventTypeStatus) MarkBrokerNotConfigured()

+ func (et *EventTypeStatus) MarkBrokerUnknown(reason, messageFormat string, messageA ...interface{})

+ func (et *EventTypeStatus) PropagateBrokerStatus(bs *BrokerStatus)

type TriggerStatus

+ func (ts *TriggerStatus) GetTopLevelCondition() *apis.Condition

+ func (ts *TriggerStatus) MarkBrokerNotConfigured()

+ func (ts *TriggerStatus) MarkBrokerUnknown(reason, messageFormat string, messageA ...interface{})

+ func (ts *TriggerStatus) MarkDependencyNotConfigured()

+ func (ts *TriggerStatus) MarkSubscribedUnknown(reason, messageFormat string, messageA ...interface{})

+ func (ts *TriggerStatus) MarkSubscriptionNotConfigured()

Nov 13, 2019

Changes in this version

+ const TriggerConditionSubscriberResolved

type TriggerStatus

+ func (ts *TriggerStatus) MarkSubscriberResolvedFailed(reason, messageFormat string, messageA ...interface{})

+ func (ts *TriggerStatus) MarkSubscriberResolvedSucceeded()

+ func (ts *TriggerStatus) MarkSubscriberResolvedUnknown(reason, messageFormat string, messageA ...interface{})

Oct 29, 2019

Changes in this version

+ const InjectionAnnotation

type Broker

+ func (b *Broker) GetUntypedSpec() interface{}

type EventType

+ func (e *EventType) GetUntypedSpec() interface{}

+ func (p *EventType) GetGroupVersionKind() schema.GroupVersionKind

type Trigger

+ func (t *Trigger) GetUntypedSpec() interface{}

Sep 17, 2019

Changes in this version

+ const DependencyAnnotation

+ const TriggerConditionDependency

+ func GetObjRefFromDependencyAnnotation(dependencyAnnotation string) (corev1.ObjectReference, error)

type TriggerStatus

+ func (ts *TriggerStatus) MarkDependencyFailed(reason, messageFormat string, messageA ...interface{})

+ func (ts *TriggerStatus) MarkDependencySucceeded()

+ func (ts *TriggerStatus) MarkDependencyUnknown(reason, messageFormat string, messageA ...interface{})

+ func (ts *TriggerStatus) PropagateDependencyStatus(ks *duckv1alpha1.KResource)

Aug 6, 2019

Changes in this version

type BrokerStatus

+ func (bs *BrokerStatus) MarkIngressSubscriptionNotOwned(sub *Subscription)

type TriggerFilter

+ Attributes *TriggerFilterAttributes

+ DeprecatedSourceAndType *TriggerFilterSourceAndType

+ type TriggerFilterAttributes map[string]string

+ func (in TriggerFilterAttributes) DeepCopy() TriggerFilterAttributes

+ func (in TriggerFilterAttributes) DeepCopyInto(out *TriggerFilterAttributes)

type TriggerStatus

+ func (ts *TriggerStatus) MarkSubscriptionNotOwned(sub *Subscription)

Jun 25, 2019

Changes in this version

+ const SubscriptionConditionAddedToChannel

+ func IsValidObjectReference(f corev1.ObjectReference) *apis.FieldError

+ func IsValidSubscriberSpec(s SubscriberSpec) *apis.FieldError

type Broker

+ func (b *Broker) GetSpec() interface{}

type BrokerSpec

+ DeprecatedChannelTemplate *ChannelSpec

type BrokerStatus

+ IngressChannel *corev1.ObjectReference

+ TriggerChannel *corev1.ObjectReference

+ func (bs *BrokerStatus) PropagateIngressChannelReadinessCRD(cs *duckv1alpha1.ChannelableStatus)

+ func (bs *BrokerStatus) PropagateTriggerChannelReadinessCRD(cs *duckv1alpha1.ChannelableStatus)

+ func (cs *BrokerStatus) MarkDeprecated(reason, msg string)

type Channel

+ func (c *Channel) GetSpec() interface{}

+ type ChannelTemplateSpec struct

+ Spec runtime.RawExtension

+ func (in *ChannelTemplateSpec) DeepCopy() *ChannelTemplateSpec

+ func (in *ChannelTemplateSpec) DeepCopyInto(out *ChannelTemplateSpec)

+ func (in *ChannelTemplateSpec) DeepCopyObject() runtime.Object

+ type ChannelTemplateSpecInternal struct

+ Spec runtime.RawExtension

+ func (in *ChannelTemplateSpecInternal) DeepCopy() *ChannelTemplateSpecInternal

+ func (in *ChannelTemplateSpecInternal) DeepCopyInto(out *ChannelTemplateSpecInternal)

+ func (in *ChannelTemplateSpecInternal) DeepCopyObject() runtime.Object

+ type HasSpec interface

+ GetSpec func() interface{}

type Subscription

+ func (s *Subscription) GetSpec() interface{}

+ func (t *Subscription) GetGroupVersionKind() schema.GroupVersionKind

type SubscriptionStatus

+ func (ss *SubscriptionStatus) AreReferencesResolved() bool

+ func (ss *SubscriptionStatus) IsAddedToChannel() bool

+ func (ss *SubscriptionStatus) MarkAddedToChannel()

+ func (ss *SubscriptionStatus) MarkChannelNotReady(reason, messageFormat string, messageA ...interface{})

+ func (ss *SubscriptionStatus) MarkNotAddedToChannel(reason, messageFormat string, messageA ...interface{})

+ func (ss *SubscriptionStatus) MarkReferencesNotResolved(reason, messageFormat string, messageA ...interface{})

type Trigger

+ func (t *Trigger) GetSpec() interface{}

May 14, 2019

Changes in this version

+ const EventTypeConditionBrokerExists

+ const EventTypeConditionBrokerReady

+ const EventTypeConditionReady

+ const TriggerConditionBroker

+ var TestHelper = testHelper

type Broker

+ func (t *Broker) GetGroupVersionKind() schema.GroupVersionKind

type BrokerStatus

+ func (bs *BrokerStatus) PropagateFilterDeploymentAvailability(d *v1.Deployment)

+ func (bs *BrokerStatus) PropagateIngressChannelReadiness(cs *ChannelStatus)

+ func (bs *BrokerStatus) PropagateIngressDeploymentAvailability(d *v1.Deployment)

+ func (bs *BrokerStatus) PropagateIngressSubscriptionReadiness(ss *SubscriptionStatus)

+ func (bs *BrokerStatus) PropagateTriggerChannelReadiness(cs *ChannelStatus)

type Channel

+ func (c *Channel) GetGroupVersionKind() schema.GroupVersionKind

type ChannelStatus

+ func (cs *ChannelStatus) MarkDeprecated(reason, msg string)

type ClusterChannelProvisioner

+ func (ccp *ClusterChannelProvisioner) GetGroupVersionKind() schema.GroupVersionKind

+ type EventType struct

+ Spec EventTypeSpec

+ Status EventTypeStatus

+ func (et *EventType) CheckImmutableFields(ctx context.Context, og apis.Immutable) *apis.FieldError

+ func (et *EventType) SetDefaults(ctx context.Context)

+ func (et *EventType) Validate(ctx context.Context) *apis.FieldError

+ func (in *EventType) DeepCopy() *EventType

+ func (in *EventType) DeepCopyInto(out *EventType)

+ func (in *EventType) DeepCopyObject() runtime.Object

+ type EventTypeList struct

+ Items []EventType

+ func (in *EventTypeList) DeepCopy() *EventTypeList

+ func (in *EventTypeList) DeepCopyInto(out *EventTypeList)

+ func (in *EventTypeList) DeepCopyObject() runtime.Object

+ type EventTypeSpec struct

+ Broker string

+ Description string

+ Schema string

+ Source string

+ Type string

+ func (ets *EventTypeSpec) SetDefaults(ctx context.Context)

+ func (ets *EventTypeSpec) Validate(ctx context.Context) *apis.FieldError

+ func (in *EventTypeSpec) DeepCopy() *EventTypeSpec

+ func (in *EventTypeSpec) DeepCopyInto(out *EventTypeSpec)

+ type EventTypeStatus struct

+ func (et *EventTypeStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition

+ func (et *EventTypeStatus) InitializeConditions()

+ func (et *EventTypeStatus) IsReady() bool

+ func (et *EventTypeStatus) MarkBrokerDoesNotExist()

+ func (et *EventTypeStatus) MarkBrokerExists()

+ func (et *EventTypeStatus) MarkBrokerNotReady()

+ func (et *EventTypeStatus) MarkBrokerReady()

+ func (in *EventTypeStatus) DeepCopy() *EventTypeStatus

+ func (in *EventTypeStatus) DeepCopyInto(out *EventTypeStatus)

type Trigger

+ func (t *Trigger) GetGroupVersionKind() schema.GroupVersionKind

type TriggerStatus

+ func (ts *TriggerStatus) MarkBrokerFailed(reason, messageFormat string, messageA ...interface{})

+ func (ts *TriggerStatus) PropagateBrokerStatus(bs *BrokerStatus)

+ func (ts *TriggerStatus) PropagateSubscriptionStatus(ss *SubscriptionStatus)

Apr 2, 2019

Changes in this version

+ const BrokerConditionAddressable

+ const BrokerConditionFilter

+ const BrokerConditionIngress

+ const BrokerConditionIngressChannel

+ const BrokerConditionIngressSubscription

+ const BrokerConditionReady

+ const BrokerConditionTriggerChannel

+ const ChannelConditionProvisionerInstalled

+ const TriggerAnyFilter

+ const TriggerConditionBrokerExists

+ const TriggerConditionKubernetesService

+ const TriggerConditionReady

+ const TriggerConditionSubscribed

+ const TriggerConditionVirtualService

+ type Broker struct

+ Spec BrokerSpec

+ Status BrokerStatus

+ func (b *Broker) CheckImmutableFields(ctx context.Context, og apis.Immutable) *apis.FieldError

+ func (b *Broker) SetDefaults(ctx context.Context)

+ func (b *Broker) Validate(ctx context.Context) *apis.FieldError

+ func (in *Broker) DeepCopy() *Broker

+ func (in *Broker) DeepCopyInto(out *Broker)

+ func (in *Broker) DeepCopyObject() runtime.Object

+ type BrokerList struct

+ Items []Broker

+ func (in *BrokerList) DeepCopy() *BrokerList

+ func (in *BrokerList) DeepCopyInto(out *BrokerList)

+ func (in *BrokerList) DeepCopyObject() runtime.Object

+ type BrokerSpec struct

+ ChannelTemplate *ChannelSpec

+ func (bs *BrokerSpec) SetDefaults(ctx context.Context)

+ func (bs *BrokerSpec) Validate(ctx context.Context) *apis.FieldError

+ func (in *BrokerSpec) DeepCopy() *BrokerSpec

+ func (in *BrokerSpec) DeepCopyInto(out *BrokerSpec)

+ type BrokerStatus struct

+ Address duckv1alpha1.Addressable

+ func (bs *BrokerStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition

+ func (bs *BrokerStatus) InitializeConditions()

+ func (bs *BrokerStatus) IsReady() bool

+ func (bs *BrokerStatus) MarkFilterFailed(err error)

+ func (bs *BrokerStatus) MarkFilterReady()

+ func (bs *BrokerStatus) MarkIngressChannelFailed(err error)

+ func (bs *BrokerStatus) MarkIngressChannelReady()

+ func (bs *BrokerStatus) MarkIngressFailed(err error)

+ func (bs *BrokerStatus) MarkIngressReady()

+ func (bs *BrokerStatus) MarkIngressSubscriptionFailed(err error)

+ func (bs *BrokerStatus) MarkIngressSubscriptionReady()

+ func (bs *BrokerStatus) MarkTriggerChannelFailed(err error)

+ func (bs *BrokerStatus) MarkTriggerChannelReady()

+ func (bs *BrokerStatus) SetAddress(hostname string)

+ func (in *BrokerStatus) DeepCopy() *BrokerStatus

+ func (in *BrokerStatus) DeepCopyInto(out *BrokerStatus)

type ChannelStatus

+ func (cs *ChannelStatus) MarkProvisionerInstalled()

+ func (cs *ChannelStatus) MarkProvisionerNotInstalled(reason, messageFormat string, messageA ...interface{})

type SubscriberSpec

+ DeprecatedDNSName *string

+ URI *string

+ type Trigger struct

+ Spec TriggerSpec

+ Status TriggerStatus

+ func (in *Trigger) DeepCopy() *Trigger

+ func (in *Trigger) DeepCopyInto(out *Trigger)

+ func (in *Trigger) DeepCopyObject() runtime.Object

+ func (t *Trigger) CheckImmutableFields(ctx context.Context, og apis.Immutable) *apis.FieldError

+ func (t *Trigger) SetDefaults(ctx context.Context)

+ func (t *Trigger) Validate(ctx context.Context) *apis.FieldError

+ type TriggerFilter struct

+ SourceAndType *TriggerFilterSourceAndType

+ func (in *TriggerFilter) DeepCopy() *TriggerFilter

+ func (in *TriggerFilter) DeepCopyInto(out *TriggerFilter)

+ type TriggerFilterSourceAndType struct

+ Source string

+ Type string

+ func (in *TriggerFilterSourceAndType) DeepCopy() *TriggerFilterSourceAndType

+ func (in *TriggerFilterSourceAndType) DeepCopyInto(out *TriggerFilterSourceAndType)

+ type TriggerList struct

+ Items []Trigger

+ func (in *TriggerList) DeepCopy() *TriggerList

+ func (in *TriggerList) DeepCopyInto(out *TriggerList)

+ func (in *TriggerList) DeepCopyObject() runtime.Object

+ type TriggerSpec struct

+ Broker string

+ Filter *TriggerFilter

+ Subscriber *SubscriberSpec

+ func (in *TriggerSpec) DeepCopy() *TriggerSpec

+ func (in *TriggerSpec) DeepCopyInto(out *TriggerSpec)

+ func (ts *TriggerSpec) SetDefaults(ctx context.Context)

+ func (ts *TriggerSpec) Validate(ctx context.Context) *apis.FieldError

+ type TriggerStatus struct

+ SubscriberURI string

+ func (in *TriggerStatus) DeepCopy() *TriggerStatus

+ func (in *TriggerStatus) DeepCopyInto(out *TriggerStatus)

+ func (ts *TriggerStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition

+ func (ts *TriggerStatus) InitializeConditions()

+ func (ts *TriggerStatus) IsReady() bool

+ func (ts *TriggerStatus) MarkBrokerDoesNotExist()

+ func (ts *TriggerStatus) MarkBrokerExists()

+ func (ts *TriggerStatus) MarkKubernetesServiceExists()

+ func (ts *TriggerStatus) MarkNotSubscribed(reason, messageFormat string, messageA ...interface{})

+ func (ts *TriggerStatus) MarkSubscribed()

+ func (ts *TriggerStatus) MarkVirtualServiceExists()

Feb 15, 2019

Changes in this version

type ChannelStatus

+ Internal *runtime.RawExtension

Jan 9, 2019

Changes in this version

type ChannelSpec

+ DeprecatedGeneration int64

type ClusterChannelProvisionerSpec

+ DeprecatedGeneration int64

type SubscriptionSpec

+ DeprecatedGeneration int64

Nov 28, 2018

Changes in this version

+ type ChannelProvisionerDefaulter interface

+ GetDefault func(c *Channel) (*corev1.ObjectReference, *runtime.RawExtension)

+ var ChannelDefaulterSingleton ChannelProvisionerDefaulter

Nov 10, 2018

Changes in this version

+ const ChannelConditionAddressable

+ const ChannelConditionProvisioned

+ const ChannelConditionReady

+ const ClusterChannelProvisionerConditionReady

+ const SubscriptionConditionChannelReady

+ const SubscriptionConditionReady

+ const SubscriptionConditionReferencesResolved

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ type Channel struct

+ Spec ChannelSpec

+ Status ChannelStatus

+ func (c *Channel) SetDefaults()

+ func (c *Channel) Validate() *apis.FieldError

+ func (current *Channel) CheckImmutableFields(og apis.Immutable) *apis.FieldError

+ func (in *Channel) DeepCopy() *Channel

+ func (in *Channel) DeepCopyInto(out *Channel)

+ func (in *Channel) DeepCopyObject() runtime.Object

+ type ChannelList struct

+ Items []Channel

+ func (in *ChannelList) DeepCopy() *ChannelList

+ func (in *ChannelList) DeepCopyInto(out *ChannelList)

+ func (in *ChannelList) DeepCopyObject() runtime.Object

+ type ChannelSpec struct

+ Arguments *runtime.RawExtension

+ Generation int64

+ Provisioner *corev1.ObjectReference

+ Subscribable *eventingduck.Subscribable

+ func (cs *ChannelSpec) Validate() *apis.FieldError

+ func (fs *ChannelSpec) SetDefaults()

+ func (in *ChannelSpec) DeepCopy() *ChannelSpec

+ func (in *ChannelSpec) DeepCopyInto(out *ChannelSpec)

+ type ChannelStatus struct

+ Address duckv1alpha1.Addressable

+ Conditions duckv1alpha1.Conditions

+ ObservedGeneration int64

+ func (cs *ChannelStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition

+ func (cs *ChannelStatus) InitializeConditions()

+ func (cs *ChannelStatus) IsReady() bool

+ func (cs *ChannelStatus) MarkNotProvisioned(reason, messageFormat string, messageA ...interface{})

+ func (cs *ChannelStatus) MarkProvisioned()

+ func (cs *ChannelStatus) SetAddress(hostname string)

+ func (in *ChannelStatus) DeepCopy() *ChannelStatus

+ func (in *ChannelStatus) DeepCopyInto(out *ChannelStatus)

+ type ClusterChannelProvisioner struct

+ Spec ClusterChannelProvisionerSpec

+ Status ClusterChannelProvisionerStatus

+ func (in *ClusterChannelProvisioner) DeepCopy() *ClusterChannelProvisioner

+ func (in *ClusterChannelProvisioner) DeepCopyInto(out *ClusterChannelProvisioner)

+ func (in *ClusterChannelProvisioner) DeepCopyObject() runtime.Object

+ func (p *ClusterChannelProvisioner) SetDefaults()

+ func (p *ClusterChannelProvisioner) Validate() *apis.FieldError

+ type ClusterChannelProvisionerList struct

+ Items []ClusterChannelProvisioner

+ func (in *ClusterChannelProvisionerList) DeepCopy() *ClusterChannelProvisionerList

+ func (in *ClusterChannelProvisionerList) DeepCopyInto(out *ClusterChannelProvisionerList)

+ func (in *ClusterChannelProvisionerList) DeepCopyObject() runtime.Object

+ type ClusterChannelProvisionerSpec struct

+ Generation int64

+ func (in *ClusterChannelProvisionerSpec) DeepCopy() *ClusterChannelProvisionerSpec

+ func (in *ClusterChannelProvisionerSpec) DeepCopyInto(out *ClusterChannelProvisionerSpec)

+ func (ps *ClusterChannelProvisionerSpec) SetDefaults()

+ func (ps *ClusterChannelProvisionerSpec) Validate() *apis.FieldError

+ type ClusterChannelProvisionerStatus struct

+ Conditions duckv1alpha1.Conditions

+ ObservedGeneration int64

+ func (in *ClusterChannelProvisionerStatus) DeepCopy() *ClusterChannelProvisionerStatus

+ func (in *ClusterChannelProvisionerStatus) DeepCopyInto(out *ClusterChannelProvisionerStatus)

+ func (ps *ClusterChannelProvisionerStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition

+ func (ps *ClusterChannelProvisionerStatus) InitializeConditions()

+ func (ps *ClusterChannelProvisionerStatus) IsReady() bool

+ func (ps *ClusterChannelProvisionerStatus) MarkNotReady(reason, messageFormat string, messageA ...interface{})

+ func (ps *ClusterChannelProvisionerStatus) MarkReady()

+ type ReplyStrategy struct

+ Channel *corev1.ObjectReference

+ func (in *ReplyStrategy) DeepCopy() *ReplyStrategy

+ func (in *ReplyStrategy) DeepCopyInto(out *ReplyStrategy)

+ type SubscriberSpec struct

+ DNSName *string

+ Ref *corev1.ObjectReference

+ func (in *SubscriberSpec) DeepCopy() *SubscriberSpec

+ func (in *SubscriberSpec) DeepCopyInto(out *SubscriberSpec)

+ type Subscription struct

+ Spec SubscriptionSpec

+ Status SubscriptionStatus

+ func (current *Subscription) CheckImmutableFields(og apis.Immutable) *apis.FieldError

+ func (in *Subscription) DeepCopy() *Subscription

+ func (in *Subscription) DeepCopyInto(out *Subscription)

+ func (in *Subscription) DeepCopyObject() runtime.Object

+ func (s *Subscription) SetDefaults()

+ func (s *Subscription) Validate() *apis.FieldError

+ type SubscriptionList struct

+ Items []Subscription

+ func (in *SubscriptionList) DeepCopy() *SubscriptionList

+ func (in *SubscriptionList) DeepCopyInto(out *SubscriptionList)

+ func (in *SubscriptionList) DeepCopyObject() runtime.Object

+ type SubscriptionSpec struct

+ Channel corev1.ObjectReference

+ Generation int64

+ Reply *ReplyStrategy

+ Subscriber *SubscriberSpec

+ func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec

+ func (in *SubscriptionSpec) DeepCopyInto(out *SubscriptionSpec)

+ func (ss *SubscriptionSpec) SetDefaults()

+ func (ss *SubscriptionSpec) Validate() *apis.FieldError

+ type SubscriptionStatus struct

+ Conditions duckv1alpha1.Conditions

+ PhysicalSubscription SubscriptionStatusPhysicalSubscription

+ func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus

+ func (in *SubscriptionStatus) DeepCopyInto(out *SubscriptionStatus)

+ func (ss *SubscriptionStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition

+ func (ss *SubscriptionStatus) InitializeConditions()

+ func (ss *SubscriptionStatus) IsReady() bool

+ func (ss *SubscriptionStatus) MarkChannelReady()

+ func (ss *SubscriptionStatus) MarkReferencesResolved()

+ type SubscriptionStatusPhysicalSubscription struct

+ ReplyURI string

+ SubscriberURI string

+ func (in *SubscriptionStatusPhysicalSubscription) DeepCopy() *SubscriptionStatusPhysicalSubscription

+ func (in *SubscriptionStatusPhysicalSubscription) DeepCopyInto(out *SubscriptionStatusPhysicalSubscription)