v1alpha1

package
v1.15.1 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package v1alpha1 is the v1alpha1 version of the API. +groupName=argoproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true

Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=argoproj.io

Index

Constants

View Source 
const (
	// EventBusConditionDeployed has the status True when the EventBus
	// has its RestfulSet/Deployment ans service created.
	EventBusConditionDeployed common.ConditionType = "Deployed"
	// EventBusConditionConfigured has the status True when the EventBus
	// has its configuration ready.
	EventBusConditionConfigured common.ConditionType = "Configured"
)

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: eventbus.Group, Version: "v1alpha1"}

	// SchemaGroupVersionKind is a group version kind used to attach owner references
	SchemaGroupVersionKind = SchemeGroupVersion.WithKind(eventbus.Kind)

	SchemaGroupVersionResource = SchemeGroupVersion.WithResource(eventbus.Plural)

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

	// AddToScheme is required by pkg/client/...
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

func GetOpenAPIDefinitions 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type AuthStrategy 

type AuthStrategy string

AuthStrategy is the auth strategy of native nats installaion 

var (
	AuthStrategyNone  AuthStrategy = "none"
	AuthStrategyToken AuthStrategy = "token"
)

possible auth strategies

type BusConfig 

type BusConfig struct {
	NATS *NATSConfig `json:"nats,omitempty" protobuf:"bytes,1,opt,name=nats"`
}

BusConfig has the finalized configuration for EventBus

func (*BusConfig) DeepCopy 

func (in *BusConfig) DeepCopy() *BusConfig

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

func (*BusConfig) DeepCopyInto 

func (in *BusConfig) DeepCopyInto(out *BusConfig)

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

func (*BusConfig) Descriptor added in v0.17.0 

func (*BusConfig) Descriptor() ([]byte, []int)

func (*BusConfig) Marshal added in v0.17.0 

func (m *BusConfig) Marshal() (dAtA []byte, err error)

func (*BusConfig) MarshalTo added in v0.17.0 

func (m *BusConfig) MarshalTo(dAtA []byte) (int, error)

func (*BusConfig) MarshalToSizedBuffer added in v0.17.0 

func (m *BusConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BusConfig) ProtoMessage added in v0.17.0 

func (*BusConfig) ProtoMessage()

func (*BusConfig) Reset added in v0.17.0 

func (m *BusConfig) Reset()

func (*BusConfig) Size added in v0.17.0 

func (m *BusConfig) Size() (n int)

func (*BusConfig) String added in v0.17.0 

func (this *BusConfig) String() string

func (*BusConfig) Unmarshal added in v0.17.0 

func (m *BusConfig) Unmarshal(dAtA []byte) error

func (*BusConfig) XXX_DiscardUnknown added in v0.17.0 

func (m *BusConfig) XXX_DiscardUnknown()

func (*BusConfig) XXX_Marshal added in v0.17.0 

func (m *BusConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BusConfig) XXX_Merge added in v0.17.0 

func (m *BusConfig) XXX_Merge(src proto.Message)

func (*BusConfig) XXX_Size added in v0.17.0 

func (m *BusConfig) XXX_Size() int

func (*BusConfig) XXX_Unmarshal added in v0.17.0 

func (m *BusConfig) XXX_Unmarshal(b []byte) error

type ContainerTemplate added in v0.17.0 

type ContainerTemplate struct {
	Resources       corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,1,opt,name=resources"`
	ImagePullPolicy corev1.PullPolicy           `json:"imagePullPolicy,omitempty" protobuf:"bytes,2,opt,name=imagePullPolicy,casttype=PullPolicy"`
	SecurityContext *corev1.SecurityContext     `json:"securityContext,omitempty" protobuf:"bytes,3,opt,name=securityContext"`
}

ContainerTemplate defines customized spec for a container

func (*ContainerTemplate) DeepCopy added in v0.17.0 

func (in *ContainerTemplate) DeepCopy() *ContainerTemplate

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

func (*ContainerTemplate) DeepCopyInto added in v0.17.0 

func (in *ContainerTemplate) DeepCopyInto(out *ContainerTemplate)

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

func (*ContainerTemplate) Descriptor added in v0.17.0 

func (*ContainerTemplate) Descriptor() ([]byte, []int)

func (*ContainerTemplate) Marshal added in v0.17.0 

func (m *ContainerTemplate) Marshal() (dAtA []byte, err error)

func (*ContainerTemplate) MarshalTo added in v0.17.0 

func (m *ContainerTemplate) MarshalTo(dAtA []byte) (int, error)

func (*ContainerTemplate) MarshalToSizedBuffer added in v0.17.0 

func (m *ContainerTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerTemplate) ProtoMessage added in v0.17.0 

func (*ContainerTemplate) ProtoMessage()

func (*ContainerTemplate) Reset added in v0.17.0 

func (m *ContainerTemplate) Reset()

func (*ContainerTemplate) Size added in v0.17.0 

func (m *ContainerTemplate) Size() (n int)

func (*ContainerTemplate) String added in v0.17.0 

func (this *ContainerTemplate) String() string

func (*ContainerTemplate) Unmarshal added in v0.17.0 

func (m *ContainerTemplate) Unmarshal(dAtA []byte) error

func (*ContainerTemplate) XXX_DiscardUnknown added in v0.17.0 

func (m *ContainerTemplate) XXX_DiscardUnknown()

func (*ContainerTemplate) XXX_Marshal added in v0.17.0 

func (m *ContainerTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerTemplate) XXX_Merge added in v0.17.0 

func (m *ContainerTemplate) XXX_Merge(src proto.Message)

func (*ContainerTemplate) XXX_Size added in v0.17.0 

func (m *ContainerTemplate) XXX_Size() int

func (*ContainerTemplate) XXX_Unmarshal added in v0.17.0 

func (m *ContainerTemplate) XXX_Unmarshal(b []byte) error

type EventBus 

type EventBus struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Spec              EventBusSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"`
	// +optional
	Status EventBusStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

EventBus is the definition of a eventbus resource +genclient +kubebuilder:resource:singular=eventbus,shortName=eb +kubebuilder:subresource:status +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true

func (*EventBus) DeepCopy 

func (in *EventBus) DeepCopy() *EventBus

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

func (*EventBus) DeepCopyInto 

func (in *EventBus) DeepCopyInto(out *EventBus)

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

func (*EventBus) DeepCopyObject 

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

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

func (*EventBus) Descriptor added in v0.17.0 

func (*EventBus) Descriptor() ([]byte, []int)

func (*EventBus) Marshal added in v0.17.0 

func (m *EventBus) Marshal() (dAtA []byte, err error)

func (*EventBus) MarshalTo added in v0.17.0 

func (m *EventBus) MarshalTo(dAtA []byte) (int, error)

func (*EventBus) MarshalToSizedBuffer added in v0.17.0 

func (m *EventBus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventBus) ProtoMessage added in v0.17.0 

func (*EventBus) ProtoMessage()

func (*EventBus) Reset added in v0.17.0 

func (m *EventBus) Reset()

func (*EventBus) Size added in v0.17.0 

func (m *EventBus) Size() (n int)

func (*EventBus) String added in v0.17.0 

func (this *EventBus) String() string

func (*EventBus) Unmarshal added in v0.17.0 

func (m *EventBus) Unmarshal(dAtA []byte) error

func (*EventBus) XXX_DiscardUnknown added in v0.17.0 

func (m *EventBus) XXX_DiscardUnknown()

func (*EventBus) XXX_Marshal added in v0.17.0 

func (m *EventBus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventBus) XXX_Merge added in v0.17.0 

func (m *EventBus) XXX_Merge(src proto.Message)

func (*EventBus) XXX_Size added in v0.17.0 

func (m *EventBus) XXX_Size() int

func (*EventBus) XXX_Unmarshal added in v0.17.0 

func (m *EventBus) XXX_Unmarshal(b []byte) error

type EventBusList 

type EventBusList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`

	Items []EventBus `json:"items" protobuf:"bytes,2,rep,name=items"`
}

EventBusList is the list of eventbus resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

func (*EventBusList) DeepCopy 

func (in *EventBusList) DeepCopy() *EventBusList

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

func (*EventBusList) DeepCopyInto 

func (in *EventBusList) DeepCopyInto(out *EventBusList)

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

func (*EventBusList) DeepCopyObject 

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

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

func (*EventBusList) Descriptor added in v0.17.0 

func (*EventBusList) Descriptor() ([]byte, []int)

func (*EventBusList) Marshal added in v0.17.0 

func (m *EventBusList) Marshal() (dAtA []byte, err error)

func (*EventBusList) MarshalTo added in v0.17.0 

func (m *EventBusList) MarshalTo(dAtA []byte) (int, error)

func (*EventBusList) MarshalToSizedBuffer added in v0.17.0 

func (m *EventBusList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventBusList) ProtoMessage added in v0.17.0 

func (*EventBusList) ProtoMessage()

func (*EventBusList) Reset added in v0.17.0 

func (m *EventBusList) Reset()

func (*EventBusList) Size added in v0.17.0 

func (m *EventBusList) Size() (n int)

func (*EventBusList) String added in v0.17.0 

func (this *EventBusList) String() string

func (*EventBusList) Unmarshal added in v0.17.0 

func (m *EventBusList) Unmarshal(dAtA []byte) error

func (*EventBusList) XXX_DiscardUnknown added in v0.17.0 

func (m *EventBusList) XXX_DiscardUnknown()

func (*EventBusList) XXX_Marshal added in v0.17.0 

func (m *EventBusList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventBusList) XXX_Merge added in v0.17.0 

func (m *EventBusList) XXX_Merge(src proto.Message)

func (*EventBusList) XXX_Size added in v0.17.0 

func (m *EventBusList) XXX_Size() int

func (*EventBusList) XXX_Unmarshal added in v0.17.0 

func (m *EventBusList) XXX_Unmarshal(b []byte) error

type EventBusSpec 

type EventBusSpec struct {
	// NATS eventbus
	NATS *NATSBus `json:"nats,omitempty" protobuf:"bytes,1,opt,name=nats"`
}

EventBusSpec refers to specification of eventbus resource

func (*EventBusSpec) DeepCopy 

func (in *EventBusSpec) DeepCopy() *EventBusSpec

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

func (*EventBusSpec) DeepCopyInto 

func (in *EventBusSpec) DeepCopyInto(out *EventBusSpec)

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

func (*EventBusSpec) Descriptor added in v0.17.0 

func (*EventBusSpec) Descriptor() ([]byte, []int)

func (*EventBusSpec) Marshal added in v0.17.0 

func (m *EventBusSpec) Marshal() (dAtA []byte, err error)

func (*EventBusSpec) MarshalTo added in v0.17.0 

func (m *EventBusSpec) MarshalTo(dAtA []byte) (int, error)

func (*EventBusSpec) MarshalToSizedBuffer added in v0.17.0 

func (m *EventBusSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventBusSpec) ProtoMessage added in v0.17.0 

func (*EventBusSpec) ProtoMessage()

func (*EventBusSpec) Reset added in v0.17.0 

func (m *EventBusSpec) Reset()

func (*EventBusSpec) Size added in v0.17.0 

func (m *EventBusSpec) Size() (n int)

func (*EventBusSpec) String added in v0.17.0 

func (this *EventBusSpec) String() string

func (*EventBusSpec) Unmarshal added in v0.17.0 

func (m *EventBusSpec) Unmarshal(dAtA []byte) error

func (*EventBusSpec) XXX_DiscardUnknown added in v0.17.0 

func (m *EventBusSpec) XXX_DiscardUnknown()

func (*EventBusSpec) XXX_Marshal added in v0.17.0 

func (m *EventBusSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventBusSpec) XXX_Merge added in v0.17.0 

func (m *EventBusSpec) XXX_Merge(src proto.Message)

func (*EventBusSpec) XXX_Size added in v0.17.0 

func (m *EventBusSpec) XXX_Size() int

func (*EventBusSpec) XXX_Unmarshal added in v0.17.0 

func (m *EventBusSpec) XXX_Unmarshal(b []byte) error

type EventBusStatus 

type EventBusStatus struct {
	common.Status `json:",inline" protobuf:"bytes,1,opt,name=status"`
	// Config holds the fininalized configuration of EventBus
	Config BusConfig `json:"config,omitempty" protobuf:"bytes,2,opt,name=config"`
}

EventBusStatus holds the status of the eventbus resource

func (*EventBusStatus) DeepCopy 

func (in *EventBusStatus) DeepCopy() *EventBusStatus

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

func (*EventBusStatus) DeepCopyInto 

func (in *EventBusStatus) DeepCopyInto(out *EventBusStatus)

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

func (*EventBusStatus) Descriptor added in v0.17.0 

func (*EventBusStatus) Descriptor() ([]byte, []int)

func (*EventBusStatus) InitConditions 

func (s *EventBusStatus) InitConditions()

InitConditions sets conditions to Unknown state.

func (*EventBusStatus) MarkConfigured 

func (s *EventBusStatus) MarkConfigured()

MarkConfigured set the bus configuration has been done.

func (*EventBusStatus) MarkDeployFailed 

func (s *EventBusStatus) MarkDeployFailed(reason, message string)

MarkDeployFailed set the bus deploy failed

func (*EventBusStatus) MarkDeployed 

func (s *EventBusStatus) MarkDeployed(reason, message string)

MarkDeployed set the bus has been deployed.

func (*EventBusStatus) MarkDeploying 

func (s *EventBusStatus) MarkDeploying(reason, message string)

MarkDeploying set the bus is deploying

func (*EventBusStatus) MarkNotConfigured 

func (s *EventBusStatus) MarkNotConfigured(reason, message string)

MarkNotConfigured set the bus status not configured.

func (*EventBusStatus) Marshal added in v0.17.0 

func (m *EventBusStatus) Marshal() (dAtA []byte, err error)

func (*EventBusStatus) MarshalTo added in v0.17.0 

func (m *EventBusStatus) MarshalTo(dAtA []byte) (int, error)

func (*EventBusStatus) MarshalToSizedBuffer added in v0.17.0 

func (m *EventBusStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventBusStatus) ProtoMessage added in v0.17.0 

func (*EventBusStatus) ProtoMessage()

func (*EventBusStatus) Reset added in v0.17.0 

func (m *EventBusStatus) Reset()

func (*EventBusStatus) Size added in v0.17.0 

func (m *EventBusStatus) Size() (n int)

func (*EventBusStatus) String added in v0.17.0 

func (this *EventBusStatus) String() string

func (*EventBusStatus) Unmarshal added in v0.17.0 

func (m *EventBusStatus) Unmarshal(dAtA []byte) error

func (*EventBusStatus) XXX_DiscardUnknown added in v0.17.0 

func (m *EventBusStatus) XXX_DiscardUnknown()

func (*EventBusStatus) XXX_Marshal added in v0.17.0 

func (m *EventBusStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventBusStatus) XXX_Merge added in v0.17.0 

func (m *EventBusStatus) XXX_Merge(src proto.Message)

func (*EventBusStatus) XXX_Size added in v0.17.0 

func (m *EventBusStatus) XXX_Size() int

func (*EventBusStatus) XXX_Unmarshal added in v0.17.0 

func (m *EventBusStatus) XXX_Unmarshal(b []byte) error

type NATSBus 

type NATSBus struct {
	// Native means to bring up a native NATS service
	Native *NativeStrategy `json:"native,omitempty" protobuf:"bytes,1,opt,name=native"`
	// Exotic holds an exotic NATS config
	Exotic *NATSConfig `json:"exotic,omitempty" protobuf:"bytes,2,opt,name=exotic"`
}

NATSBus holds the NATS eventbus information

func (*NATSBus) DeepCopy 

func (in *NATSBus) DeepCopy() *NATSBus

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

func (*NATSBus) DeepCopyInto 

func (in *NATSBus) DeepCopyInto(out *NATSBus)

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

func (*NATSBus) Descriptor added in v0.17.0 

func (*NATSBus) Descriptor() ([]byte, []int)

func (*NATSBus) Marshal added in v0.17.0 

func (m *NATSBus) Marshal() (dAtA []byte, err error)

func (*NATSBus) MarshalTo added in v0.17.0 

func (m *NATSBus) MarshalTo(dAtA []byte) (int, error)

func (*NATSBus) MarshalToSizedBuffer added in v0.17.0 

func (m *NATSBus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NATSBus) ProtoMessage added in v0.17.0 

func (*NATSBus) ProtoMessage()

func (*NATSBus) Reset added in v0.17.0 

func (m *NATSBus) Reset()

func (*NATSBus) Size added in v0.17.0 

func (m *NATSBus) Size() (n int)

func (*NATSBus) String added in v0.17.0 

func (this *NATSBus) String() string

func (*NATSBus) Unmarshal added in v0.17.0 

func (m *NATSBus) Unmarshal(dAtA []byte) error

func (*NATSBus) XXX_DiscardUnknown added in v0.17.0 

func (m *NATSBus) XXX_DiscardUnknown()

func (*NATSBus) XXX_Marshal added in v0.17.0 

func (m *NATSBus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NATSBus) XXX_Merge added in v0.17.0 

func (m *NATSBus) XXX_Merge(src proto.Message)

func (*NATSBus) XXX_Size added in v0.17.0 

func (m *NATSBus) XXX_Size() int

func (*NATSBus) XXX_Unmarshal added in v0.17.0 

func (m *NATSBus) XXX_Unmarshal(b []byte) error

type NATSConfig 

type NATSConfig struct {
	// NATS streaming url
	URL string `json:"url,omitempty" protobuf:"bytes,1,opt,name=url"`
	// Cluster ID for nats streaming
	ClusterID *string `json:"clusterID,omitempty" protobuf:"bytes,2,opt,name=clusterID"`
	// Auth strategy, default to AuthStrategyNone
	// +optional
	Auth *AuthStrategy `json:"auth,omitempty" protobuf:"bytes,3,opt,name=auth,casttype=AuthStrategy"`
	// Secret for auth
	// +optional
	AccessSecret *corev1.SecretKeySelector `json:"accessSecret,omitempty" protobuf:"bytes,4,opt,name=accessSecret"`
}

NATSConfig holds the config of NATS

func (*NATSConfig) DeepCopy 

func (in *NATSConfig) DeepCopy() *NATSConfig

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

func (*NATSConfig) DeepCopyInto 

func (in *NATSConfig) DeepCopyInto(out *NATSConfig)

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

func (*NATSConfig) Descriptor added in v0.17.0 

func (*NATSConfig) Descriptor() ([]byte, []int)

func (*NATSConfig) Marshal added in v0.17.0 

func (m *NATSConfig) Marshal() (dAtA []byte, err error)

func (*NATSConfig) MarshalTo added in v0.17.0 

func (m *NATSConfig) MarshalTo(dAtA []byte) (int, error)

func (*NATSConfig) MarshalToSizedBuffer added in v0.17.0 

func (m *NATSConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NATSConfig) ProtoMessage added in v0.17.0 

func (*NATSConfig) ProtoMessage()

func (*NATSConfig) Reset added in v0.17.0 

func (m *NATSConfig) Reset()

func (*NATSConfig) Size added in v0.17.0 

func (m *NATSConfig) Size() (n int)

func (*NATSConfig) String added in v0.17.0 

func (this *NATSConfig) String() string

func (*NATSConfig) Unmarshal added in v0.17.0 

func (m *NATSConfig) Unmarshal(dAtA []byte) error

func (*NATSConfig) XXX_DiscardUnknown added in v0.17.0 

func (m *NATSConfig) XXX_DiscardUnknown()

func (*NATSConfig) XXX_Marshal added in v0.17.0 

func (m *NATSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NATSConfig) XXX_Merge added in v0.17.0 

func (m *NATSConfig) XXX_Merge(src proto.Message)

func (*NATSConfig) XXX_Size added in v0.17.0 

func (m *NATSConfig) XXX_Size() int

func (*NATSConfig) XXX_Unmarshal added in v0.17.0 

func (m *NATSConfig) XXX_Unmarshal(b []byte) error

type NativeStrategy 

type NativeStrategy struct {
	// Size is the NATS StatefulSet size
	Replicas int32         `json:"replicas,omitempty" protobuf:"varint,1,opt,name=replicas"`
	Auth     *AuthStrategy `json:"auth,omitempty" protobuf:"bytes,2,opt,name=auth,casttype=AuthStrategy"`
	// +optional
	Persistence *PersistenceStrategy `json:"persistence,omitempty" protobuf:"bytes,3,opt,name=persistence"`
	// ContainerTemplate contains customized spec for NATS container
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,4,opt,name=containerTemplate"`
	// MetricsContainerTemplate contains customized spec for metrics container
	// +optional
	MetricsContainerTemplate *ContainerTemplate `json:"metricsContainerTemplate,omitempty" protobuf:"bytes,5,opt,name=metricsContainerTemplate"`
	// NodeSelector is a selector which must be true for the pod to fit on a node.
	// Selector which must match a node's labels for the pod to be scheduled on that node.
	// More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,6,rep,name=nodeSelector"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,7,rep,name=tolerations"`
	// Metadata sets the pods's metadata, i.e. annotations and labels
	Metadata *common.Metadata `json:"metadata,omitempty" protobuf:"bytes,8,opt,name=metadata"`
	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,9,opt,name=securityContext"`
	// Max Age of existing messages, i.e. "72h", “4h35m”
	// +optional
	MaxAge *string `json:"maxAge,omitempty" protobuf:"bytes,10,opt,name=maxAge"`
	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec.
	// If specified, these secrets will be passed to individual puller implementations for them to use. For example,
	// in the case of docker, only DockerConfig type secrets are honored.
	// More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,11,rep,name=imagePullSecrets"`
	// ServiceAccountName to apply to NATS StatefulSet
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,12,opt,name=serviceAccountName"`
	// If specified, indicates the EventSource pod's priority. "system-node-critical"
	// and "system-cluster-critical" are two special keywords which indicate the
	// highest priorities with the former being the highest priority. Any other
	// name must be defined by creating a PriorityClass object with that name.
	// If not specified, the pod priority will be default or zero if there is no
	// default.
	// More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/
	// +optional
	PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,13,opt,name=priorityClassName"`
	// The priority value. Various system components use this field to find the
	// priority of the EventSource pod. When Priority Admission Controller is enabled,
	// it prevents users from setting this field. The admission controller populates
	// this field from PriorityClassName.
	// The higher the value, the higher the priority.
	// More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/
	// +optional
	Priority *int32 `json:"priority,omitempty" protobuf:"bytes,14,opt,name=priority"`
	// The pod's scheduling constraints
	// More info: https://kubernetes.io/docs/concepts/scheduling-eviction/assign-pod-node/
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty" protobuf:"bytes,15,opt,name=affinity"`
	// Maximum number of messages per channel, 0 means unlimited. Defaults to 1000000
	MaxMsgs *uint64 `json:"maxMsgs,omitempty" protobuf:"bytes,16,opt,name=maxMsgs"`
	// Total size of messages per channel, 0 means unlimited. Defaults to 1GB
	MaxBytes *string `json:"maxBytes,omitempty" protobuf:"bytes,17,opt,name=maxBytes"`
	// Maximum number of subscriptions per channel, 0 means unlimited. Defaults to 1000
	MaxSubs *uint64 `json:"maxSubs,omitempty" protobuf:"bytes,18,opt,name=maxSubs"`
	// Maximum number of bytes in a message payload, 0 means unlimited. Defaults to 1MB
	MaxPayload *string `json:"maxPayload,omitempty" protobuf:"bytes,19,opt,name=maxPayload"`
	// Specifies the time in follower state without a leader before attempting an election, i.e. "72h", “4h35m”. Defaults to 2s
	RaftHeartbeatTimeout *string `json:"raftHeartbeatTimeout,omitempty" protobuf:"bytes,20,opt,name=raftHeartbeatTimeout"`
	// Specifies the time in candidate state without a leader before attempting an election, i.e. "72h", “4h35m”. Defaults to 2s
	RaftElectionTimeout *string `json:"raftElectionTimeout,omitempty" protobuf:"bytes,21,opt,name=raftElectionTimeout"`
	// Specifies how long a leader waits without being able to contact a quorum of nodes before stepping down as leader, i.e. "72h", “4h35m”. Defaults to 1s
	RaftLeaseTimeout *string `json:"raftLeaseTimeout,omitempty" protobuf:"bytes,22,opt,name=raftLeaseTimeout"`
	// Specifies the time without an Apply() operation before sending an heartbeat to ensure timely commit, i.e. "72h", “4h35m”. Defaults to 100ms
	RaftCommitTimeout *string `json:"raftCommitTimeout,omitempty" protobuf:"bytes,23,opt,name=raftCommitTimeout"`
}

NativeStrategy indicates to install a native NATS service

func (*NativeStrategy) DeepCopy 

func (in *NativeStrategy) DeepCopy() *NativeStrategy

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

func (*NativeStrategy) DeepCopyInto 

func (in *NativeStrategy) DeepCopyInto(out *NativeStrategy)

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

func (*NativeStrategy) Descriptor added in v0.17.0 

func (*NativeStrategy) Descriptor() ([]byte, []int)

func (*NativeStrategy) GetReplicas added in v0.17.0 

func (in *NativeStrategy) GetReplicas() int

GetReplicas return the replicas of statefulset

func (*NativeStrategy) Marshal added in v0.17.0 

func (m *NativeStrategy) Marshal() (dAtA []byte, err error)

func (*NativeStrategy) MarshalTo added in v0.17.0 

func (m *NativeStrategy) MarshalTo(dAtA []byte) (int, error)

func (*NativeStrategy) MarshalToSizedBuffer added in v0.17.0 

func (m *NativeStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NativeStrategy) ProtoMessage added in v0.17.0 

func (*NativeStrategy) ProtoMessage()

func (*NativeStrategy) Reset added in v0.17.0 

func (m *NativeStrategy) Reset()

func (*NativeStrategy) Size 

func (m *NativeStrategy) Size() (n int)

func (*NativeStrategy) String added in v0.17.0 

func (this *NativeStrategy) String() string

func (*NativeStrategy) Unmarshal added in v0.17.0 

func (m *NativeStrategy) Unmarshal(dAtA []byte) error

func (*NativeStrategy) XXX_DiscardUnknown added in v0.17.0 

func (m *NativeStrategy) XXX_DiscardUnknown()

func (*NativeStrategy) XXX_Marshal added in v0.17.0 

func (m *NativeStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NativeStrategy) XXX_Merge added in v0.17.0 

func (m *NativeStrategy) XXX_Merge(src proto.Message)

func (*NativeStrategy) XXX_Size added in v0.17.0 

func (m *NativeStrategy) XXX_Size() int

func (*NativeStrategy) XXX_Unmarshal added in v0.17.0 

func (m *NativeStrategy) XXX_Unmarshal(b []byte) error

type PersistenceStrategy 

type PersistenceStrategy struct {
	// Name of the StorageClass required by the claim.
	// More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#class-1
	// +optional
	StorageClassName *string `json:"storageClassName,omitempty" protobuf:"bytes,1,opt,name=storageClassName"`
	// Available access modes such as ReadWriteOnce, ReadWriteMany
	// https://kubernetes.io/docs/concepts/storage/persistent-volumes/#access-modes
	// +optional
	AccessMode *corev1.PersistentVolumeAccessMode `json:"accessMode,omitempty" protobuf:"bytes,2,opt,name=accessMode,casttype=k8s.io/api/core/v1.PersistentVolumeAccessMode"`
	// Volume size, e.g. 10Gi
	VolumeSize *apiresource.Quantity `json:"volumeSize,omitempty" protobuf:"bytes,3,opt,name=volumeSize"`
}

PersistenceStrategy defines the strategy of persistence

func (*PersistenceStrategy) DeepCopy 

func (in *PersistenceStrategy) DeepCopy() *PersistenceStrategy

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

func (*PersistenceStrategy) DeepCopyInto 

func (in *PersistenceStrategy) DeepCopyInto(out *PersistenceStrategy)

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

func (*PersistenceStrategy) Descriptor added in v0.17.0 

func (*PersistenceStrategy) Descriptor() ([]byte, []int)

func (*PersistenceStrategy) Marshal added in v0.17.0 

func (m *PersistenceStrategy) Marshal() (dAtA []byte, err error)

func (*PersistenceStrategy) MarshalTo added in v0.17.0 

func (m *PersistenceStrategy) MarshalTo(dAtA []byte) (int, error)

func (*PersistenceStrategy) MarshalToSizedBuffer added in v0.17.0 

func (m *PersistenceStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PersistenceStrategy) ProtoMessage added in v0.17.0 

func (*PersistenceStrategy) ProtoMessage()

func (*PersistenceStrategy) Reset added in v0.17.0 

func (m *PersistenceStrategy) Reset()

func (*PersistenceStrategy) Size 

func (m *PersistenceStrategy) Size() (n int)

func (*PersistenceStrategy) String added in v0.17.0 

func (this *PersistenceStrategy) String() string

func (*PersistenceStrategy) Unmarshal added in v0.17.0 

func (m *PersistenceStrategy) Unmarshal(dAtA []byte) error

func (*PersistenceStrategy) XXX_DiscardUnknown added in v0.17.0 

func (m *PersistenceStrategy) XXX_DiscardUnknown()

func (*PersistenceStrategy) XXX_Marshal added in v0.17.0 

func (m *PersistenceStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PersistenceStrategy) XXX_Merge added in v0.17.0 

func (m *PersistenceStrategy) XXX_Merge(src proto.Message)

func (*PersistenceStrategy) XXX_Size added in v0.17.0 

func (m *PersistenceStrategy) XXX_Size() int

func (*PersistenceStrategy) XXX_Unmarshal added in v0.17.0 

func (m *PersistenceStrategy) XXX_Unmarshal(b []byte) error

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.