v1alpha1

package
v0.0.0-...-d5b48cf Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2018 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Copyright 2018 The Knative Authors Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

+k8s:deepcopy-gen=package Package v1alpha1 is the v1alpha1 version of the API. +groupName=channels.knative.dev

Index

Constants

This section is empty.

Variables

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

type Argument struct {
	// Name is the name of the Parameter this Argument is for.
	Name string `json:"name"`

	// Value is the value for the Parameter.
	Value string `json:"value"`
}

Argument represents a value for a named parameter.

func (*Argument) DeepCopy 

func (in *Argument) DeepCopy() *Argument

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

func (*Argument) DeepCopyInto 

func (in *Argument) DeepCopyInto(out *Argument)

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

type Bus 

type Bus struct {
	meta_v1.TypeMeta   `json:",inline"`
	meta_v1.ObjectMeta `json:"metadata"`
	Spec               BusSpec   `json:"spec"`
	Status             BusStatus `json:"status,omitempty"`
}

Bus represents how channels and subscriptions should be managed and corresponds to the buses.channels.knative.dev CRD. Buses will frequently, but not always, be backed by an event broker.

func (*Bus) BacksChannel 

func (b *Bus) BacksChannel(channel *Channel) bool

func (*Bus) CheckImmutableFields 

func (current *Bus) CheckImmutableFields(og apis.Immutable) *apis.FieldError

func (*Bus) DeepCopy 

func (in *Bus) DeepCopy() *Bus

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

func (*Bus) DeepCopyInto 

func (in *Bus) DeepCopyInto(out *Bus)

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

func (*Bus) DeepCopyObject 

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

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

func (*Bus) GetSpec 

func (b *Bus) GetSpec() *BusSpec

func (*Bus) GetSpecJSON 

func (b *Bus) GetSpecJSON() ([]byte, error)

func (*Bus) SetDefaults 

func (b *Bus) SetDefaults()

func (*Bus) Validate 

func (b *Bus) Validate() *apis.FieldError

type BusCondition 

type BusCondition struct {
	// Type of bus condition.
	Type BusConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status kapi.ConditionStatus `json:"status"`
	// The last time this condition was updated.
	LastUpdateTime meta_v1.Time `json:"lastUpdateTime,omitempty"`
	// Last time the condition transitioned from one status to another.
	LastTransitionTime meta_v1.Time `json:"lastTransitionTime,omitempty"`
	// The reason for the condition's last transition.
	Reason string `json:"reason,omitempty"`
	// A human readable message indicating details about the transition.
	Message string `json:"message,omitempty"`
}

BusCondition describes the state of a bus at a point in time.

func (*BusCondition) DeepCopy 

func (in *BusCondition) DeepCopy() *BusCondition

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

func (*BusCondition) DeepCopyInto 

func (in *BusCondition) DeepCopyInto(out *BusCondition)

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

type BusConditionType 

type BusConditionType string
const (
	// Ready is set when all other conditions are met and the bus is ready to accept traffic.
	BusReady BusConditionType = "Ready"

	// Serviceable means the service addressing the bus exists.
	BusServiceable BusConditionType = "Serviceable"

	// Provisioning means the deployment for the bus provisioner exists.
	BusProvisioning BusConditionType = "Provisioning"

	// Dispatching means the deployment for the bus dispatcher exists.
	BusDispatching = "Dispatching"
)

type BusList 

type BusList struct {
	meta_v1.TypeMeta `json:",inline"`
	meta_v1.ListMeta `json:"metadata"`
	Items            []Bus `json:"items"`
}

BusList returned in list operations

func (*BusList) DeepCopy 

func (in *BusList) DeepCopy() *BusList

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

func (*BusList) DeepCopyInto 

func (in *BusList) DeepCopyInto(out *BusList)

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

func (*BusList) DeepCopyObject 

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

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

type BusParameters 

type BusParameters struct {
	// Channel configuration params for channels on the bus
	Channel *[]Parameter `json:"channel,omitempty"`

	// Subscription configuration params for subscriptions on the bus
	Subscription *[]Parameter `json:"subscription,omitempty"`
}

BusParameters represents the arguments that must be passed by Channels and Subscriptions.

func (*BusParameters) DeepCopy 

func (in *BusParameters) DeepCopy() *BusParameters

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

func (*BusParameters) DeepCopyInto 

func (in *BusParameters) DeepCopyInto(out *BusParameters)

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

func (*BusParameters) SetDefaults 

func (bp *BusParameters) SetDefaults()

func (*BusParameters) Validate 

func (bp *BusParameters) Validate() *apis.FieldError

type BusSpec 

type BusSpec struct {
	// Parameters defines the parameters that must be passed by this Bus'
	// Channels and their Subscriptions. Channels and Subscriptions fulfill
	// these parameters with Arguments.
	Parameters *BusParameters `json:"parameters,omitempty"`

	// Provisioner defines how the provisioner container for this bus should be
	// run. Provisioners are responsible for provisioning the underlying
	// infrastructure for Channels and Subscriptions. The exact work done by the
	// provisioner varies by Bus; one example of work done by a provisioner
	// could be creating a messaging topic that backs a channel.
	Provisioner *kapi.Container `json:"provisioner,omitempty"`

	// Dispatcher defines how the dispatcher container for this bus should be
	// run. Dispatchers are responsible for performing two types of event
	// dispatch: dispatching incoming events to the Bus' Channels and
	// dispatching events in the Channel to the Channel's Subscriptions.
	Dispatcher kapi.Container `json:"dispatcher"`

	// Volumes to be mounted inside the provisioner or dispatcher containers
	Volumes *[]kapi.Volume `json:"volumes,omitempty"`
}

BusSpec specifies the Bus' parameters for Channels and Subscriptions, how the provisioner and dispatcher for a bus should be run, and which volumes should be mounted into them.

func (*BusSpec) DeepCopy 

func (in *BusSpec) DeepCopy() *BusSpec

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

func (*BusSpec) DeepCopyInto 

func (in *BusSpec) DeepCopyInto(out *BusSpec)

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

func (*BusSpec) SetDefaults 

func (bs *BusSpec) SetDefaults()

func (*BusSpec) Validate 

func (bs *BusSpec) Validate() *apis.FieldError

type BusStatus 

type BusStatus struct {
	// A reference to the k8s Service fronting this bus, if successfully synced.
	Service *kapi.LocalObjectReference `json:"service,omitempty"`

	// Represents the latest available observations of a bus's current state.
	// +patchMergeKey=type
	// +patchStrategy=merge
	Conditions []BusCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

BusStatus (computed) for a bus

func (*BusStatus) DeepCopy 

func (in *BusStatus) DeepCopy() *BusStatus

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

func (*BusStatus) DeepCopyInto 

func (in *BusStatus) DeepCopyInto(out *BusStatus)

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

type Channel 

type Channel struct {
	meta_v1.TypeMeta   `json:",inline"`
	meta_v1.ObjectMeta `json:"metadata"`
	Spec               ChannelSpec   `json:"spec"`
	Status             ChannelStatus `json:"status,omitempty"`
}

Channel represents a named endpoint on which a Bus accepts event delivery and corresponds to the channels.channels.knative.dev CRD. The Bus handles provisioning channels, delivering events to Channels, and delivering events from Channels to their Subscriptions.

func (*Channel) CheckImmutableFields 

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

func (*Channel) DeepCopy 

func (in *Channel) DeepCopy() *Channel

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

func (*Channel) DeepCopyInto 

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

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

func (*Channel) DeepCopyObject 

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

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

func (*Channel) GetSpecJSON 

func (c *Channel) GetSpecJSON() ([]byte, error)

func (*Channel) SetDefaults 

func (c *Channel) SetDefaults()

func (*Channel) Validate 

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

type ChannelCondition 

type ChannelCondition struct {
	// Type of channel condition.
	Type ChannelConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status v1.ConditionStatus `json:"status"`
	// The last time this condition was updated.
	LastUpdateTime meta_v1.Time `json:"lastUpdateTime,omitempty"`
	// Last time the condition transitioned from one status to another.
	LastTransitionTime meta_v1.Time `json:"lastTransitionTime,omitempty"`
	// The reason for the condition's last transition.
	Reason string `json:"reason,omitempty"`
	// A human readable message indicating details about the transition.
	Message string `json:"message,omitempty"`
}

ChannelCondition describes the state of a channel at a point in time.

func (*ChannelCondition) DeepCopy 

func (in *ChannelCondition) DeepCopy() *ChannelCondition

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

func (*ChannelCondition) DeepCopyInto 

func (in *ChannelCondition) DeepCopyInto(out *ChannelCondition)

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

type ChannelConditionType 

type ChannelConditionType string
const (

	// Ready is set when all other conditions are met and the channel is ready to accept traffic.
	ChannelReady ChannelConditionType = "Ready"

	// Serviceable means the service addressing the channel exists.
	ChannelServiceable ChannelConditionType = "Serviceable"

	// Routable means the virtual service forwarding traffic from the channel service to the
	// bus is created.
	ChannelRoutable ChannelConditionType = "Routeable"

	// Provisioned means the channel backing construct on the bus middleware has been set up.
	ChannelProvisioned ChannelConditionType = "Provisioned"
)

type ChannelList 

type ChannelList struct {
	meta_v1.TypeMeta `json:",inline"`
	meta_v1.ListMeta `json:"metadata"`
	Items            []Channel `json:"items"`
}

ChannelList returned in list operations

func (*ChannelList) DeepCopy 

func (in *ChannelList) DeepCopy() *ChannelList

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

func (*ChannelList) DeepCopyInto 

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

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

func (*ChannelList) DeepCopyObject 

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

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

type ChannelSpec 

type ChannelSpec struct {
	// Name of the bus backing this channel (optional)
	Bus string `json:"bus,omitempty"`

	// ClusterBus name of the clusterbus backing this channel (mutually exclusive with Bus)
	ClusterBus string `json:"clusterBus,omitempty"`

	// Arguments is a list of configuration arguments for the Channel. The
	// Arguments for a channel must contain values for each of the Parameters
	// specified by the Bus' spec.parameters.Channels field except the
	// Parameters that have a default value. If a Parameter has a default value
	// and it is not in the list of Arguments, the default value will be used; a
	// Parameter without a default value that does not have an Argument will
	// result in an error setting up the Channel.
	Arguments *[]Argument `json:"arguments,omitempty"`
}

ChannelSpec specifies the Bus backing a channel and the configuration arguments for the channel.

func (*ChannelSpec) DeepCopy 

func (in *ChannelSpec) DeepCopy() *ChannelSpec

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

func (*ChannelSpec) DeepCopyInto 

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

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

func (*ChannelSpec) SetDefaults 

func (fs *ChannelSpec) SetDefaults()

func (*ChannelSpec) Validate 

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

type ChannelStatus 

type ChannelStatus struct {
	// A reference to the k8s Service backing this channel, if successfully synced.
	Service *v1.LocalObjectReference `json:"service,omitempty"`

	// A reference to the istio VirtualService backing this channel, if successfully synced.
	VirtualService *v1.LocalObjectReference `json:"virtualService,omitempty"`

	// Represents the latest available observations of a channel's current state.
	// +patchMergeKey=type
	// +patchStrategy=merge
	Conditions []ChannelCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`

	// DomainInternal holds the top-level domain that will distribute traffic
	// over the provided targets from inside the cluster. It generally has the
	// form {channel}.{namespace}.svc.cluster.local
	// +optional
	DomainInternal string `json:"domainInternal,omitempty"`
}

ChannelStatus (computed) for a channel

func (*ChannelStatus) DeepCopy 

func (in *ChannelStatus) DeepCopy() *ChannelStatus

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

func (*ChannelStatus) DeepCopyInto 

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

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

func (*ChannelStatus) GetCondition 

func (cs *ChannelStatus) GetCondition(t ChannelConditionType) *ChannelCondition

type ClusterBus 

type ClusterBus struct {
	meta_v1.TypeMeta   `json:",inline"`
	meta_v1.ObjectMeta `json:"metadata"`
	Spec               ClusterBusSpec   `json:"spec"`
	Status             ClusterBusStatus `json:"status,omitempty"`
}

ClusterBus represents the clusterbuses.channels.knative.dev CRD

func (*ClusterBus) BacksChannel 

func (b *ClusterBus) BacksChannel(channel *Channel) bool

func (*ClusterBus) CheckImmutableFields 

func (current *ClusterBus) CheckImmutableFields(og apis.Immutable) *apis.FieldError

func (*ClusterBus) DeepCopy 

func (in *ClusterBus) DeepCopy() *ClusterBus

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

func (*ClusterBus) DeepCopyInto 

func (in *ClusterBus) DeepCopyInto(out *ClusterBus)

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

func (*ClusterBus) DeepCopyObject 

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

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

func (*ClusterBus) GetSpec 

func (b *ClusterBus) GetSpec() *BusSpec

func (*ClusterBus) GetSpecJSON 

func (b *ClusterBus) GetSpecJSON() ([]byte, error)

func (*ClusterBus) SetDefaults 

func (b *ClusterBus) SetDefaults()

func (*ClusterBus) Validate 

func (b *ClusterBus) Validate() *apis.FieldError

type ClusterBusList 

type ClusterBusList struct {
	meta_v1.TypeMeta `json:",inline"`
	meta_v1.ListMeta `json:"metadata"`
	Items            []ClusterBus `json:"items"`
}

ClusterBusList returned in list operations

func (*ClusterBusList) DeepCopy 

func (in *ClusterBusList) DeepCopy() *ClusterBusList

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

func (*ClusterBusList) DeepCopyInto 

func (in *ClusterBusList) DeepCopyInto(out *ClusterBusList)

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

func (*ClusterBusList) DeepCopyObject 

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

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

type ClusterBusSpec 

type ClusterBusSpec = BusSpec

ClusterBusSpec (what the user wants) for a clusterbus

type ClusterBusStatus 

type ClusterBusStatus struct {
}

ClusterBusStatus (computed) for a clusterbus

func (*ClusterBusStatus) DeepCopy 

func (in *ClusterBusStatus) DeepCopy() *ClusterBusStatus

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

func (*ClusterBusStatus) DeepCopyInto 

func (in *ClusterBusStatus) DeepCopyInto(out *ClusterBusStatus)

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

type GenericBus 

type GenericBus interface {
	runtime.Object
	meta_v1.ObjectMetaAccessor
	BacksChannel(channel *Channel) bool
	GetSpec() *BusSpec

	// Needed for generic webhook support
	apis.Defaultable
	apis.Immutable
	apis.Validatable
}

GenericBus may be backed by Bus or ClusterBus

type Parameter 

type Parameter struct {
	// Name is the name of the Parameter.
	Name string `json:"name"`

	// Description is the human friendly description of the parameter.
	Description string `json:"description"`

	// Default is the value to use if an Argument for this Parameter is not
	// explicitly set.
	Default *string `json:"default,omitempty"`
}

Parameter represents a named configuration parameter that must be supplied to create a particular resource by an Argument. Parameters may optionally have a default value that will be used if an Argument is not supplied.

func (*Parameter) DeepCopy 

func (in *Parameter) DeepCopy() *Parameter

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

func (*Parameter) DeepCopyInto 

func (in *Parameter) DeepCopyInto(out *Parameter)

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

type Subscription 

type Subscription struct {
	meta_v1.TypeMeta   `json:",inline"`
	meta_v1.ObjectMeta `json:"metadata"`
	Spec               SubscriptionSpec   `json:"spec"`
	Status             SubscriptionStatus `json:"status,omitempty"`
}

Subscription routes events received on a Channel to a DNS name and corresponds to the subscriptions.channels.knative.dev CRD.

func (*Subscription) CheckImmutableFields 

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

func (*Subscription) DeepCopy 

func (in *Subscription) DeepCopy() *Subscription

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

func (*Subscription) DeepCopyInto 

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

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

func (*Subscription) DeepCopyObject 

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

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

func (*Subscription) GetSpecJSON 

func (s *Subscription) GetSpecJSON() ([]byte, error)

func (*Subscription) SetDefaults 

func (s *Subscription) SetDefaults()

func (*Subscription) Validate 

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

type SubscriptionCondition 

type SubscriptionCondition struct {
	// Type of subscription condition.
	Type SubscriptionConditionType `json:"type"`
	// Status of the condition, one of True, False, Unknown.
	Status v1.ConditionStatus `json:"status"`
	// The last time this condition was updated.
	LastUpdateTime meta_v1.Time `json:"lastUpdateTime,omitempty"`
	// Last time the condition transitioned from one status to another.
	LastTransitionTime meta_v1.Time `json:"lastTransitionTime,omitempty"`
	// The reason for the condition's last transition.
	Reason string `json:"reason,omitempty"`
	// A human readable message indicating details about the transition.
	Message string `json:"message,omitempty"`
}

SubscriptionCondition describes the state of a subscription at a point in time.

func (*SubscriptionCondition) DeepCopy 

func (in *SubscriptionCondition) DeepCopy() *SubscriptionCondition

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

func (*SubscriptionCondition) DeepCopyInto 

func (in *SubscriptionCondition) DeepCopyInto(out *SubscriptionCondition)

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

type SubscriptionConditionType 

type SubscriptionConditionType string
const (
	// Dispatching means the subscription is actively listening for incoming events on its channel and dispatching them.
	SubscriptionDispatching SubscriptionConditionType = "Dispatching"
)

type SubscriptionList 

type SubscriptionList struct {
	meta_v1.TypeMeta `json:",inline"`
	meta_v1.ListMeta `json:"metadata"`
	Items            []Subscription `json:"items"`
}

SubscriptionList returned in list operations

func (*SubscriptionList) DeepCopy 

func (in *SubscriptionList) DeepCopy() *SubscriptionList

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

func (*SubscriptionList) DeepCopyInto 

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

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

func (*SubscriptionList) DeepCopyObject 

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

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

type SubscriptionSpec 

type SubscriptionSpec struct {
	// Channel is the name of the channel to subscribe to.
	Channel string `json:"channel"`

	// Subscriber is the name of the subscriber service DNS name.
	Subscriber string `json:"subscriber"`

	// Target service DNS name for replies returned by the subscriber.
	ReplyTo string `json:"replyTo,omitempty"`

	// Arguments is a list of configuration arguments for the Subscription. The
	// Arguments for a channel must contain values for each of the Parameters
	// specified by the Bus' spec.parameters.Subscriptions field except the
	// Parameters that have a default value. If a Parameter has a default value
	// and it is not in the list of Arguments, the default value will be used; a
	// Parameter without a default value that does not have an Argument will
	// result in an error setting up the Subscription.
	Arguments *[]Argument `json:"arguments,omitempty"`
}

SubscriptionSpec specifies the Channel and Subscriber and the configuration arguments for the Subscription.

func (*SubscriptionSpec) DeepCopy 

func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec

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

func (*SubscriptionSpec) DeepCopyInto 

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

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

func (*SubscriptionSpec) SetDefaults 

func (ss *SubscriptionSpec) SetDefaults()

func (*SubscriptionSpec) Validate 

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

type SubscriptionStatus 

type SubscriptionStatus struct {

	// Represents the latest available observations of a subscription's current state.
	// +patchMergeKey=type
	// +patchStrategy=merge
	Conditions []SubscriptionCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

SubscriptionStatus (computed) for a subscription

func (*SubscriptionStatus) DeepCopy 

func (in *SubscriptionStatus) DeepCopy() *SubscriptionStatus

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

func (*SubscriptionStatus) DeepCopyInto 

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

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

func (*SubscriptionStatus) GetCondition 

func (ss *SubscriptionStatus) GetCondition(t SubscriptionConditionType) *SubscriptionCondition

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.