v1

Documentation

Overview

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

Index

• Variables
• type BrokerDefault
  • func (in *BrokerDefault) DeepCopy() *BrokerDefault
  • func (in *BrokerDefault) DeepCopyInto(out *BrokerDefault)
• type DispatcherDefault
  • func (in *DispatcherDefault) DeepCopy() *DispatcherDefault
  • func (in *DispatcherDefault) DeepCopyInto(out *DispatcherDefault)
• type PublisherDefault
  • func (in *PublisherDefault) DeepCopy() *PublisherDefault
  • func (in *PublisherDefault) DeepCopyInto(out *PublisherDefault)
• type StoreDefault
  • func (in *StoreDefault) DeepCopy() *StoreDefault
  • func (in *StoreDefault) DeepCopyInto(out *StoreDefault)
• type StreamControllerConfig
  • func (in *StreamControllerConfig) DeepCopy() *StreamControllerConfig
  • func (in *StreamControllerConfig) DeepCopyInto(out *StreamControllerConfig)
  • func (in *StreamControllerConfig) DeepCopyObject() runtime.Object
• type SubscriptionDefault
  • func (in *SubscriptionDefault) DeepCopy() *SubscriptionDefault
  • func (in *SubscriptionDefault) DeepCopyInto(out *SubscriptionDefault)
• type WorkflowDefault
  • func (in *WorkflowDefault) DeepCopy() *WorkflowDefault
  • func (in *WorkflowDefault) DeepCopyInto(out *WorkflowDefault)

Variables

var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "config.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
)

Types

type BrokerDefault

type BrokerDefault struct {
	Dispatcher DispatcherDefault `json:"dispatcher"`
	Publisher  PublisherDefault  `json:"publisher"`
}

func (*BrokerDefault) DeepCopy

func (in *BrokerDefault) DeepCopy() *BrokerDefault

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

func (*BrokerDefault) DeepCopyInto

func (in *BrokerDefault) DeepCopyInto(out *BrokerDefault)

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

type DispatcherDefault

type DispatcherDefault struct {
	Image                     string          `json:"image"`
	Replicas                  int32           `json:"replicas"`
	MetricsUriFormat          string          `json:"metricsUriFormat"`
	MetricsPort               string          `json:"metricsPort"`
	Timeout                   metav1.Duration `json:"timeout"`
	BrokerSystemPartitionName string          `json:"brokerSystemPartitionName"`
}

func (*DispatcherDefault) DeepCopy

func (in *DispatcherDefault) DeepCopy() *DispatcherDefault

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

func (*DispatcherDefault) DeepCopyInto

func (in *DispatcherDefault) DeepCopyInto(out *DispatcherDefault)

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

type PublisherDefault

type PublisherDefault struct {
	Image    string `json:"image"`
	Replicas int32  `json:"replicas"`
	Port     string `json:"port"`
}

func (*PublisherDefault) DeepCopy

func (in *PublisherDefault) DeepCopy() *PublisherDefault

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

func (*PublisherDefault) DeepCopyInto

func (in *PublisherDefault) DeepCopyInto(out *PublisherDefault)

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

type StoreDefault

type StoreDefault struct {
	Image       string          `json:"image"`
	Replicas    int32           `json:"replicas"`
	Port        string          `json:"port"`
	VolumePath  string          `json:"volumePath"`
	TopologyKey string          `json:"topologyKey"`
	GrpcTimeOut metav1.Duration `json:"grpcTimeOut"`
}

func (*StoreDefault) DeepCopy

func (in *StoreDefault) DeepCopy() *StoreDefault

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

func (*StoreDefault) DeepCopyInto

func (in *StoreDefault) DeepCopyInto(out *StoreDefault)

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

type StreamControllerConfig

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

	// ControllerManagerConfigurationSpec returns the contfigurations for controllers
	cfg.ControllerManagerConfigurationSpec `json:",inline"`

	Workflow WorkflowDefault `json:"workflow"`

	Subscription SubscriptionDefault `json:"subscription"`
	Store        StoreDefault        `json:"store"`
	Broker       BrokerDefault       `json:"broker"`
}

StreamControllerConfig is the Schema for the streamcontrollerconfigs API

func (*StreamControllerConfig) DeepCopy

func (in *StreamControllerConfig) DeepCopy() *StreamControllerConfig

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

func (*StreamControllerConfig) DeepCopyInto

func (in *StreamControllerConfig) DeepCopyInto(out *StreamControllerConfig)

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

func (*StreamControllerConfig) DeepCopyObject

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

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

type SubscriptionDefault

type SubscriptionDefault struct {
	MaxRetries         uint            `json:"maxRetries"`
	MaxRequestDuration metav1.Duration `json:"maxRequestDuration"`
	AckDuration        metav1.Duration `json:"ackDuration"`
}

func (*SubscriptionDefault) DeepCopy

func (in *SubscriptionDefault) DeepCopy() *SubscriptionDefault

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

func (*SubscriptionDefault) DeepCopyInto

func (in *SubscriptionDefault) DeepCopyInto(out *SubscriptionDefault)

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

type WorkflowDefault

type WorkflowDefault struct {
	FinalizerName string          `json:"finalizerName"`
	RetryDuration metav1.Duration `json:"retryDuration"`
}

func (*WorkflowDefault) DeepCopy

func (in *WorkflowDefault) DeepCopy() *WorkflowDefault

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

func (*WorkflowDefault) DeepCopyInto

func (in *WorkflowDefault) DeepCopyInto(out *WorkflowDefault)

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