v1alpha1

package

v0.0.0-...-f464250 Latest Latest Go to latest Published: Aug 3, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cowbon/brokerchannel

Links

Open Source Insights

Documentation ¶

Overview ¶

+k8s:deepcopy-gen=package +groupName=samples.knative.dev

Index ¶

Constants
Variables
func Kind(kind string) schema.GroupKind
func Resource(resource string) schema.GroupResource
type BrokerChannel
type BrokerChannelList
type BrokerChannelSpec
type BrokerChannelStatus

Constants ¶

View Source

const (
	// SequenceConditionReady has status True when all subconditions below have been set to True.
	BrokerChannelConditionReady                    = apis.ConditionReady
	BrokerChannelSinkProvided   apis.ConditionType = "SinkProvided"
)

Variables ¶

View Source

var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)

View Source

var SchemeGroupVersion = schema.GroupVersion{Group: samples.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 BrokerChannel ¶

type BrokerChannel struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty"`

	// Spec holds the desired state of the SampleSource (from the client).
	Spec BrokerChannelSpec `json:"spec,omitempty"`

	// Status communicates the observed state of the SampleSource (from the controller).
	// +optional
	Status BrokerChannelStatus `json:"status,omitempty"`
}

+genclient +genreconciler +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*BrokerChannel) DeepCopy ¶

func (in *BrokerChannel) DeepCopy() *BrokerChannel

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

func (*BrokerChannel) DeepCopyInto ¶

func (in *BrokerChannel) DeepCopyInto(out *BrokerChannel)

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

func (*BrokerChannel) DeepCopyObject ¶

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

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

func (*BrokerChannel) GetConditionSet ¶

func (*BrokerChannel) GetConditionSet() apis.ConditionSet

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

func (*BrokerChannel) GetGroupVersionKind ¶

func (*BrokerChannel) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns the GroupVersionKind.

func (*BrokerChannel) GetStatus ¶

func (bc *BrokerChannel) GetStatus() *duckv1.Status

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

func (*BrokerChannel) GetUntypedSpec ¶

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

GetUntypedSpec returns the spec of the Sequence.

func (*BrokerChannel) SetDefaults ¶

func (bc *BrokerChannel) SetDefaults(ctx context.Context)

SetDefaults mutates SampleSource.

func (*BrokerChannel) Validate ¶

func (bc *BrokerChannel) Validate(ctx context.Context) *apis.FieldError

type BrokerChannelList ¶

type BrokerChannelList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []BrokerChannel `json:"items"`
}

SampleSourceList is a list of SampleSource resources

func (*BrokerChannelList) DeepCopy ¶

func (in *BrokerChannelList) DeepCopy() *BrokerChannelList

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

func (*BrokerChannelList) DeepCopyInto ¶

func (in *BrokerChannelList) DeepCopyInto(out *BrokerChannelList)

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

func (*BrokerChannelList) DeepCopyObject ¶

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

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

type BrokerChannelSpec ¶

type BrokerChannelSpec struct {
	BrokerAddr string `json:"brokeraddr"`
	// +optional
	BrokerPort int    `json:"brokerport"`
	Topic      string `json:"topic"`
	// +optional
	duckv1.SourceSpec `json:",inline"`
}

SampleSourceSpec holds the desired state of the SampleSource (from the client).

func (*BrokerChannelSpec) DeepCopy ¶

func (in *BrokerChannelSpec) DeepCopy() *BrokerChannelSpec

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

func (*BrokerChannelSpec) DeepCopyInto ¶

func (in *BrokerChannelSpec) DeepCopyInto(out *BrokerChannelSpec)

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

func (*BrokerChannelSpec) SetDefaults ¶

func (bcs *BrokerChannelSpec) SetDefaults(ctx context.Context)

func (*BrokerChannelSpec) Validate ¶

func (bcs *BrokerChannelSpec) Validate(ctx context.Context) *apis.FieldError

type BrokerChannelStatus ¶

type BrokerChannelStatus struct {
	// inherits duck/v1 SourceStatus, 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.
	// * SinkURI - the current active sink URI that has been configured for the
	//   Source.
	duckv1.SourceStatus `json:",inline"`
}

SampleSourceStatus communicates the observed state of the SampleSource (from the controller).

func (*BrokerChannelStatus) DeepCopy ¶

func (in *BrokerChannelStatus) DeepCopy() *BrokerChannelStatus

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

func (*BrokerChannelStatus) DeepCopyInto ¶

func (in *BrokerChannelStatus) DeepCopyInto(out *BrokerChannelStatus)

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

func (*BrokerChannelStatus) GetCondition ¶

func (ss *BrokerChannelStatus) GetCondition(t apis.ConditionType) *apis.Condition

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

func (*BrokerChannelStatus) InitializeConditions ¶

func (ss *BrokerChannelStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*BrokerChannelStatus) IsReady ¶

func (ss *BrokerChannelStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*BrokerChannelStatus) MarkNoSink ¶

func (bcs *BrokerChannelStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})

MarkNoSink sets the condition that the source does not have a sink configured.

func (*BrokerChannelStatus) MarkSink ¶

func (bcs *BrokerChannelStatus) MarkSink(uri *apis.URL)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL