v1

package
v0.0.0-...-3f6117e Latest Latest
Warning

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

 Go to latest Published: May 25, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package v1 contains API Schema definitions for the knative v1 API group +kubebuilder:object:generate=true +groupName=knative.stream-stack.tanx

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "knative.stream-stack.tanx", Version: "v1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var BrokerDefaulters = make([]base.ResourceDefaulter, 0)
View Source 
var BrokerValidators = make([]base.ResourceValidator, 0)
View Source 
var DefaultAckDuration = &metav1.Duration{Duration: 5 * time.Second}
View Source 
var DefaultMaxRequestDuration = &metav1.Duration{Duration: 5 * time.Second}
View Source 
var DefaultMaxRetries = 3

Functions

func DefaultConfigInit 

func DefaultConfigInit(config configv1.StreamControllerConfig)

Types

type Broker 

type Broker struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   BrokerSpec   `json:"spec,omitempty"`
	Status BrokerStatus `json:"status,omitempty"`
}

Broker is the Schema for the brokers API

func (*Broker) DeepCopy 

func (in *Broker) DeepCopy() *Broker

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

func (*Broker) DeepCopyInto 

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

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

func (*Broker) DeepCopyObject 

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

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

func (*Broker) Default 

func (r *Broker) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Broker) SetupWebhookWithManager 

func (r *Broker) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Broker) ValidateCreate 

func (r *Broker) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Broker) ValidateDelete 

func (r *Broker) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Broker) ValidateUpdate 

func (r *Broker) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type BrokerList 

type BrokerList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Broker `json:"items"`
}

BrokerList contains a list of Broker

func (*BrokerList) DeepCopy 

func (in *BrokerList) DeepCopy() *BrokerList

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

func (*BrokerList) DeepCopyInto 

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

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

func (*BrokerList) DeepCopyObject 

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

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

type BrokerPartition 

type BrokerPartition struct {
	//按照 数量，数据量，时间 三种策略进行分区
	Counter *BrokerPartitionCounter `json:"counter,omitempty"`
}

func (*BrokerPartition) AllocatePartition 

func (in *BrokerPartition) AllocatePartition(statistics *dispatcher.Statistics, sets []*operator.StoreSet) (*operator.StoreSet, uint64, error)

func (*BrokerPartition) DeepCopy 

func (in *BrokerPartition) DeepCopy() *BrokerPartition

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

func (*BrokerPartition) DeepCopyInto 

func (in *BrokerPartition) DeepCopyInto(out *BrokerPartition)

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

type BrokerPartitionCounter 

type BrokerPartitionCounter struct {
	Count uint64 `json:"count"`
}

func (*BrokerPartitionCounter) AllocatePartition 

func (c *BrokerPartitionCounter) AllocatePartition(statistics *dispatcher.Statistics, sets []*operator.StoreSet) (*operator.StoreSet, uint64, error)

func (*BrokerPartitionCounter) DeepCopy 

func (in *BrokerPartitionCounter) DeepCopy() *BrokerPartitionCounter

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

func (*BrokerPartitionCounter) DeepCopyInto 

func (in *BrokerPartitionCounter) DeepCopyInto(out *BrokerPartitionCounter)

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

type BrokerSpec 

type BrokerSpec struct {
	Uuid       string                `json:"uuid,omitempty"`
	Selector   *metav1.LabelSelector `json:"selector,omitempty"`
	Partition  BrokerPartition       `json:"partition,omitempty"`
	Dispatcher DispatcherSpec        `json:"dispatcher,omitempty"`
	Publisher  PublisherSpec         `json:"publisher,omitempty"`
}

BrokerSpec defines the desired state of Broker

func (*BrokerSpec) DeepCopy 

func (in *BrokerSpec) DeepCopy() *BrokerSpec

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

func (*BrokerSpec) DeepCopyInto 

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

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

type BrokerStatus 

type BrokerStatus struct {
	Uuid       string           `json:"uuid,omitempty"`
	Dispatcher DispatcherStatus `json:"dispatcher,omitempty"`
	Publisher  PublisherStatus  `json:"publisher,omitempty"`
}

BrokerStatus defines the observed state of Broker

func (*BrokerStatus) DeepCopy 

func (in *BrokerStatus) DeepCopy() *BrokerStatus

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

func (*BrokerStatus) DeepCopyInto 

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

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

type DispatcherSpec 

type DispatcherSpec struct {
	Replicas int32  `json:"replicas,omitempty"`
	Image    string `json:"image,omitempty"`
}

func (*DispatcherSpec) DeepCopy 

func (in *DispatcherSpec) DeepCopy() *DispatcherSpec

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

func (*DispatcherSpec) DeepCopyInto 

func (in *DispatcherSpec) DeepCopyInto(out *DispatcherSpec)

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

type DispatcherStatus 

type DispatcherStatus struct {
	WorkloadStatus v1.DeploymentStatus `json:"workloadStatus,omitempty"`
	SvcName        string              `json:"svcName,omitempty"`
}

func (*DispatcherStatus) DeepCopy 

func (in *DispatcherStatus) DeepCopy() *DispatcherStatus

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

func (*DispatcherStatus) DeepCopyInto 

func (in *DispatcherStatus) DeepCopyInto(out *DispatcherStatus)

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

type PublisherSpec 

type PublisherSpec struct {
	Replicas int32  `json:"replicas,omitempty"`
	Image    string `json:"image,omitempty"`
}

func (*PublisherSpec) DeepCopy 

func (in *PublisherSpec) DeepCopy() *PublisherSpec

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

func (*PublisherSpec) DeepCopyInto 

func (in *PublisherSpec) DeepCopyInto(out *PublisherSpec)

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

type PublisherStatus 

type PublisherStatus struct {
	WorkloadStatus v1.DeploymentStatus `json:"workloadStatus,omitempty"`
}

func (*PublisherStatus) DeepCopy 

func (in *PublisherStatus) DeepCopy() *PublisherStatus

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

func (*PublisherStatus) DeepCopyInto 

func (in *PublisherStatus) DeepCopyInto(out *PublisherStatus)

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

type ServiceStatus 

type ServiceStatus struct {
	v12.ServiceStatus `json:",inline"`
	Name              string `json:"name,omitempty"`
}

func (*ServiceStatus) DeepCopy 

func (in *ServiceStatus) DeepCopy() *ServiceStatus

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

func (*ServiceStatus) DeepCopyInto 

func (in *ServiceStatus) DeepCopyInto(out *ServiceStatus)

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

type Subscriber 

type Subscriber struct {
	Uri     *SubscriberUri     `json:"uri,omitempty"`
	Service *SubscriberService `json:"service,omitempty"`
	Pod     *SubscriberPod     `json:"pod,omitempty"`
}

func (*Subscriber) DeepCopy 

func (in *Subscriber) DeepCopy() *Subscriber

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

func (*Subscriber) DeepCopyInto 

func (in *Subscriber) DeepCopyInto(out *Subscriber)

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

type SubscriberDelivery 

type SubscriberDelivery struct {
	//TODO:定义发送消息的方式
	MaxRequestDuration *metav1.Duration `json:"maxRequestDuration,omitempty"`
	MaxRetries         *int             `json:"maxRetries,omitempty"`
	AckDuration        *metav1.Duration `json:"ackDuration,omitempty"`
}

func (*SubscriberDelivery) DeepCopy 

func (in *SubscriberDelivery) DeepCopy() *SubscriberDelivery

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

func (*SubscriberDelivery) DeepCopyInto 

func (in *SubscriberDelivery) DeepCopyInto(out *SubscriberDelivery)

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

type SubscriberFilter 

type SubscriberFilter struct {
}

func (*SubscriberFilter) DeepCopy 

func (in *SubscriberFilter) DeepCopy() *SubscriberFilter

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

func (*SubscriberFilter) DeepCopyInto 

func (in *SubscriberFilter) DeepCopyInto(out *SubscriberFilter)

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

type SubscriberPod 

type SubscriberPod struct {
	Namespace string                `json:"namespace,omitempty"`
	Selector  *metav1.LabelSelector `json:"selector,omitempty"`
	Protocol  string                `json:"protocol,omitempty"`
	Port      int32                 `json:"port,omitempty"`
	Path      string                `json:"path,omitempty"`
}

func (*SubscriberPod) DeepCopy 

func (in *SubscriberPod) DeepCopy() *SubscriberPod

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

func (*SubscriberPod) DeepCopyInto 

func (in *SubscriberPod) DeepCopyInto(out *SubscriberPod)

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

type SubscriberService 

type SubscriberService struct {
	Name      string `json:"name,omitempty"`
	Namespace string `json:"namespace,omitempty"`
	Port      int32  `json:"port,omitempty"`
	Path      string `json:"path,omitempty"`
}

func (*SubscriberService) DeepCopy 

func (in *SubscriberService) DeepCopy() *SubscriberService

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

func (*SubscriberService) DeepCopyInto 

func (in *SubscriberService) DeepCopyInto(out *SubscriberService)

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

type SubscriberUri 

type SubscriberUri struct {
	Uri      string `json:"uri,omitempty"`
	Protocol string `json:"protocol,omitempty"`
}

func (*SubscriberUri) DeepCopy 

func (in *SubscriberUri) DeepCopy() *SubscriberUri

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

func (*SubscriberUri) DeepCopyInto 

func (in *SubscriberUri) DeepCopyInto(out *SubscriberUri)

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"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   SubscriptionSpec   `json:"spec,omitempty"`
	Status SubscriptionStatus `json:"status,omitempty"`
}

Subscription is the Schema for the subscriptions API

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

func (r *Subscription) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*Subscription) SetupWebhookWithManager 

func (r *Subscription) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Subscription) ValidateCreate 

func (r *Subscription) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Subscription) ValidateDelete 

func (r *Subscription) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Subscription) ValidateUpdate 

func (r *Subscription) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type SubscriptionList 

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

SubscriptionList contains a list of Subscription

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 {
	Broker     string              `json:"broker"`
	Delivery   *SubscriberDelivery `json:"delivery,omitempty"`
	Filter     *SubscriberFilter   `json:"filter,omitempty"`
	Subscriber Subscriber          `json:"subscriber,omitempty"`
}

SubscriptionSpec defines the desired state of 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.

type SubscriptionStatus 

type SubscriptionStatus struct {
}

SubscriptionStatus defines the observed state of 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.

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.