v1alpha1

Documentation

Overview

+kubebuilder:object:generate=true +groupName=dapr.io

Index

• Constants
• Variables
• func GroupKindFromKind(kind string) schema.GroupKind
• func Resource(resource string) schema.GroupResource
• type BulkSubscribe
  • func (in *BulkSubscribe) DeepCopy() *BulkSubscribe
  • func (in *BulkSubscribe) DeepCopyInto(out *BulkSubscribe)
• type Subscription
  • func (Subscription) APIVersion() string
  • func (s Subscription) ClientObject() client.Object
  • func (in *Subscription) DeepCopy() *Subscription
  • func (in *Subscription) DeepCopyInto(out *Subscription)
  • func (in *Subscription) DeepCopyObject() runtime.Object
  • func (s Subscription) EmptyMetaDeepCopy() metav1.Object
  • func (s Subscription) GetName() string
  • func (s Subscription) GetNamespace() string
  • func (s Subscription) GetScopes() []string
  • func (s Subscription) GetSecretStore() string
  • func (*Subscription) Hub()
  • func (Subscription) Kind() string
  • func (s Subscription) LogName() string
  • func (s Subscription) NameValuePairs() []common.NameValuePair
• type SubscriptionList
  • func (in *SubscriptionList) DeepCopy() *SubscriptionList
  • func (in *SubscriptionList) DeepCopyInto(out *SubscriptionList)
  • func (in *SubscriptionList) DeepCopyObject() runtime.Object
• type SubscriptionSpec
  • func (in *SubscriptionSpec) DeepCopy() *SubscriptionSpec
  • func (in *SubscriptionSpec) DeepCopyInto(out *SubscriptionSpec)

Constants

const (
	Kind    = "Subscription"
	Version = "v1alpha1"
)

Variables

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

var SchemeGroupVersion = schema.GroupVersion{Group: subscriptions.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects.

Functions

func GroupKindFromKind

func GroupKindFromKind(kind string) schema.GroupKind

GroupKindFromKind 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 BulkSubscribe

type BulkSubscribe struct {
	Enabled bool `json:"enabled"`
	// +optional
	MaxMessagesCount   int32 `json:"maxMessagesCount,omitempty"`
	MaxAwaitDurationMs int32 `json:"maxAwaitDurationMs,omitempty"`
}

BulkSubscribe encapsulates the bulk subscription configuration for a topic.

func (*BulkSubscribe) DeepCopy

func (in *BulkSubscribe) DeepCopy() *BulkSubscribe

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

func (*BulkSubscribe) DeepCopyInto

func (in *BulkSubscribe) DeepCopyInto(out *BulkSubscribe)

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

type Subscription

type Subscription struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SubscriptionSpec `json:"spec,omitempty"`
	// +optional
	Scopes []string `json:"scopes,omitempty"`
}

Subscription describes an pub/sub event subscription.

func (Subscription) APIVersion

func (Subscription) APIVersion() string

func (Subscription) ClientObject

func (s Subscription) ClientObject() client.Object

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) EmptyMetaDeepCopy

func (s Subscription) EmptyMetaDeepCopy() metav1.Object

EmptyMetaDeepCopy returns a new instance of the subscription type with the TypeMeta's Kind and APIVersion fields set.

func (Subscription) GetName

func (s Subscription) GetName() string

func (Subscription) GetNamespace

func (s Subscription) GetNamespace() string

func (Subscription) GetScopes

func (s Subscription) GetScopes() []string

func (Subscription) GetSecretStore

func (s Subscription) GetSecretStore() string

func (*Subscription) Hub

func (*Subscription) Hub()

Hub marks this type as a conversion hub.

func (Subscription) Kind

func (Subscription) Kind() string

func (Subscription) LogName

func (s Subscription) LogName() string

func (Subscription) NameValuePairs

func (s Subscription) NameValuePairs() []common.NameValuePair

type SubscriptionList

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

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

SubscriptionList is a list of Dapr event sources.

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 {
	Topic      string `json:"topic"`
	Pubsubname string `json:"pubsubname"`
	// +optional
	Metadata        map[string]string `json:"metadata,omitempty"`
	Route           string            `json:"route"`
	BulkSubscribe   BulkSubscribe     `json:"bulkSubscribe,omitempty"`
	DeadLetterTopic string            `json:"deadLetterTopic,omitempty"`
}

SubscriptionSpec is the spec for an event 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.