v1alpha1

Jan 9, 2024

Changes in this version

type EventBusSpec

+ JetStreamExotic *JetStreamConfig

May 8, 2023

Changes in this version

type BusConfig

+ Kafka *KafkaBus

type EventBusSpec

+ Kafka *KafkaBus

+ type KafkaBus struct

+ ConsumerGroup *KafkaConsumerGroup

+ SASL *apicommon.SASLConfig

+ TLS *apicommon.TLSConfig

+ Topic string

+ URL string

+ Version string

+ func (*KafkaBus) Descriptor() ([]byte, []int)

+ func (*KafkaBus) ProtoMessage()

+ func (in *KafkaBus) DeepCopy() *KafkaBus

+ func (in *KafkaBus) DeepCopyInto(out *KafkaBus)

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

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

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

+ func (m *KafkaBus) Reset()

+ func (m *KafkaBus) Size() (n int)

+ func (m *KafkaBus) Unmarshal(dAtA []byte) error

+ func (m *KafkaBus) XXX_DiscardUnknown()

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

+ func (m *KafkaBus) XXX_Merge(src proto.Message)

+ func (m *KafkaBus) XXX_Size() int

+ func (m *KafkaBus) XXX_Unmarshal(b []byte) error

+ func (this *KafkaBus) String() string

+ type KafkaConsumerGroup struct

+ GroupName string

+ RebalanceStrategy string

+ StartOldest bool

+ func (*KafkaConsumerGroup) Descriptor() ([]byte, []int)

+ func (*KafkaConsumerGroup) ProtoMessage()

+ func (in *KafkaConsumerGroup) DeepCopy() *KafkaConsumerGroup

+ func (in *KafkaConsumerGroup) DeepCopyInto(out *KafkaConsumerGroup)

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

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

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

+ func (m *KafkaConsumerGroup) Reset()

+ func (m *KafkaConsumerGroup) Size() (n int)

+ func (m *KafkaConsumerGroup) Unmarshal(dAtA []byte) error

+ func (m *KafkaConsumerGroup) XXX_DiscardUnknown()

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

+ func (m *KafkaConsumerGroup) XXX_Merge(src proto.Message)

+ func (m *KafkaConsumerGroup) XXX_Size() int

+ func (m *KafkaConsumerGroup) XXX_Unmarshal(b []byte) error

+ func (this *KafkaConsumerGroup) String() string

Sep 12, 2022

Changes in this version

type JetStreamBus

+ MaxPayload *string

May 4, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type AuthStrategy

+ var AuthStrategyBasic AuthStrategy = "basic"

type BusConfig

+ JetStream *JetStreamConfig

type EventBusSpec

+ JetStream *JetStreamBus

+ type JetStreamBus struct

+ Affinity *corev1.Affinity

+ ContainerTemplate *ContainerTemplate

+ ImagePullSecrets []corev1.LocalObjectReference

+ Metadata *common.Metadata

+ MetricsContainerTemplate *ContainerTemplate

+ NodeSelector map[string]string

+ Persistence *PersistenceStrategy

+ Priority *int32

+ PriorityClassName string

+ ReloaderContainerTemplate *ContainerTemplate

+ Replicas *int32

+ SecurityContext *corev1.PodSecurityContext

+ ServiceAccountName string

+ Settings *string

+ StartArgs []string

+ StreamConfig *string

+ Tolerations []corev1.Toleration

+ Version string

+ func (*JetStreamBus) Descriptor() ([]byte, []int)

+ func (*JetStreamBus) ProtoMessage()

+ func (in *JetStreamBus) DeepCopy() *JetStreamBus

+ func (in *JetStreamBus) DeepCopyInto(out *JetStreamBus)

+ func (j JetStreamBus) GetReplicas() int

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

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

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

+ func (m *JetStreamBus) Reset()

+ func (m *JetStreamBus) Size() (n int)

+ func (m *JetStreamBus) Unmarshal(dAtA []byte) error

+ func (m *JetStreamBus) XXX_DiscardUnknown()

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

+ func (m *JetStreamBus) XXX_Merge(src proto.Message)

+ func (m *JetStreamBus) XXX_Size() int

+ func (m *JetStreamBus) XXX_Unmarshal(b []byte) error

+ func (this *JetStreamBus) String() string

+ type JetStreamConfig struct

+ AccessSecret *corev1.SecretKeySelector

+ StreamConfig string

+ URL string

+ func (*JetStreamConfig) Descriptor() ([]byte, []int)

+ func (*JetStreamConfig) ProtoMessage()

+ func (in *JetStreamConfig) DeepCopy() *JetStreamConfig

+ func (in *JetStreamConfig) DeepCopyInto(out *JetStreamConfig)

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

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

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

+ func (m *JetStreamConfig) Reset()

+ func (m *JetStreamConfig) Size() (n int)

+ func (m *JetStreamConfig) Unmarshal(dAtA []byte) error

+ func (m *JetStreamConfig) XXX_DiscardUnknown()

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

+ func (m *JetStreamConfig) XXX_Merge(src proto.Message)

+ func (m *JetStreamConfig) XXX_Size() int

+ func (m *JetStreamConfig) XXX_Unmarshal(b []byte) error

+ func (this *JetStreamConfig) String() string

Apr 23, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 3, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 2, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Feb 27, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Feb 13, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ var SchemaGroupVersionResource = SchemeGroupVersion.WithResource(eventbus.Plural)

type ContainerTemplate

+ SecurityContext *corev1.SecurityContext

type NativeStrategy

+ MaxPayload *string

+ RaftCommitTimeout *string

+ RaftElectionTimeout *string

+ RaftHeartbeatTimeout *string

+ RaftLeaseTimeout *string

Jan 12, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Dec 19, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Dec 10, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Nov 22, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Nov 9, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Nov 8, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Oct 12, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Sep 30, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Sep 21, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Sep 1, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type ContainerTemplate

+ ImagePullPolicy corev1.PullPolicy

type NativeStrategy

+ MaxSubs *uint64

Jul 12, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type NativeStrategy

+ MaxBytes *string

+ MaxMsgs *uint64

May 4, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Apr 12, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type NativeStrategy

+ Affinity *corev1.Affinity

+ DeprecatedAntiAffinity bool

+ Priority *int32

+ PriorityClassName string

Apr 8, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Apr 5, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 31, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 23, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Feb 18, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jan 27, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jan 26, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jan 8, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type NativeStrategy

+ ImagePullSecrets []corev1.LocalObjectReference

+ ServiceAccountName string

Nov 16, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type NativeStrategy

+ MaxAge *string

+ Metadata *common.Metadata

+ SecurityContext *corev1.PodSecurityContext

Nov 5, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Sep 4, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type NativeStrategy

+ Tolerations []corev1.Toleration

Aug 26, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Aug 16, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Aug 7, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jul 24, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ var ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")

type BusConfig

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

+ func (*BusConfig) ProtoMessage()

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

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

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

+ func (m *BusConfig) Reset()

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

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

+ func (m *BusConfig) XXX_DiscardUnknown()

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

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

+ func (m *BusConfig) XXX_Size() int

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

+ func (this *BusConfig) String() string

+ type ContainerTemplate struct

+ Resources corev1.ResourceRequirements

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

+ func (*ContainerTemplate) ProtoMessage()

+ func (in *ContainerTemplate) DeepCopy() *ContainerTemplate

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

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

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

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

+ func (m *ContainerTemplate) Reset()

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

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

+ func (m *ContainerTemplate) XXX_DiscardUnknown()

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

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

+ func (m *ContainerTemplate) XXX_Size() int

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

+ func (this *ContainerTemplate) String() string

type EventBus

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

+ func (*EventBus) ProtoMessage()

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

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

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

+ func (m *EventBus) Reset()

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

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

+ func (m *EventBus) XXX_DiscardUnknown()

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

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

+ func (m *EventBus) XXX_Size() int

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

+ func (this *EventBus) String() string

type EventBusList

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

+ func (*EventBusList) ProtoMessage()

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

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

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

+ func (m *EventBusList) Reset()

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

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

+ func (m *EventBusList) XXX_DiscardUnknown()

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

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

+ func (m *EventBusList) XXX_Size() int

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

+ func (this *EventBusList) String() string

type EventBusSpec

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

+ func (*EventBusSpec) ProtoMessage()

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

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

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

+ func (m *EventBusSpec) Reset()

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

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

+ func (m *EventBusSpec) XXX_DiscardUnknown()

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

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

+ func (m *EventBusSpec) XXX_Size() int

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

+ func (this *EventBusSpec) String() string

type EventBusStatus

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

+ func (*EventBusStatus) ProtoMessage()

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

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

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

+ func (m *EventBusStatus) Reset()

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

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

+ func (m *EventBusStatus) XXX_DiscardUnknown()

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

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

+ func (m *EventBusStatus) XXX_Size() int

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

+ func (this *EventBusStatus) String() string

type NATSBus

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

+ func (*NATSBus) ProtoMessage()

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

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

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

+ func (m *NATSBus) Reset()

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

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

+ func (m *NATSBus) XXX_DiscardUnknown()

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

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

+ func (m *NATSBus) XXX_Size() int

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

+ func (this *NATSBus) String() string

type NATSConfig

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

+ func (*NATSConfig) ProtoMessage()

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

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

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

+ func (m *NATSConfig) Reset()

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

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

+ func (m *NATSConfig) XXX_DiscardUnknown()

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

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

+ func (m *NATSConfig) XXX_Size() int

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

+ func (this *NATSConfig) String() string

type NativeStrategy

+ ContainerTemplate *ContainerTemplate

+ MetricsContainerTemplate *ContainerTemplate

+ NodeSelector map[string]string

+ Replicas int32

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

+ func (*NativeStrategy) ProtoMessage()

+ func (in *NativeStrategy) GetReplicas() int

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

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

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

+ func (m *NativeStrategy) Reset()

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

+ func (m *NativeStrategy) XXX_DiscardUnknown()

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

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

+ func (m *NativeStrategy) XXX_Size() int

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

+ func (this *NativeStrategy) String() string

type PersistenceStrategy

+ VolumeSize *apiresource.Quantity

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

+ func (*PersistenceStrategy) ProtoMessage()

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

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

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

+ func (m *PersistenceStrategy) Reset()

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

+ func (m *PersistenceStrategy) XXX_DiscardUnknown()

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

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

+ func (m *PersistenceStrategy) XXX_Size() int

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

+ func (this *PersistenceStrategy) String() string

Jun 14, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ const EventBusConditionConfigured

+ const EventBusConditionDeployed

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var SchemaGroupVersionKind = schema.GroupVersionKind

+ var SchemeBuilder = &scheme.Builder

+ var SchemeGroupVersion = schema.GroupVersion

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

+ func Resource(resource string) schema.GroupResource

+ type AuthStrategy string

+ var AuthStrategyNone AuthStrategy = "none"

+ var AuthStrategyToken AuthStrategy = "token"

+ type BusConfig struct

+ NATS *NATSConfig

+ func (in *BusConfig) DeepCopy() *BusConfig

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

+ type EventBus struct

+ Spec EventBusSpec

+ Status EventBusStatus

+ func (in *EventBus) DeepCopy() *EventBus

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

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

+ type EventBusList struct

+ Items []EventBus

+ func (in *EventBusList) DeepCopy() *EventBusList

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

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

+ type EventBusSpec struct

+ NATS *NATSBus

+ func (in *EventBusSpec) DeepCopy() *EventBusSpec

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

+ type EventBusStatus struct

+ Config BusConfig

+ Status common.Status

+ func (in *EventBusStatus) DeepCopy() *EventBusStatus

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

+ func (s *EventBusStatus) InitConditions()

+ func (s *EventBusStatus) MarkConfigured()

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

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

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

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

+ type NATSBus struct

+ Exotic *NATSConfig

+ Native *NativeStrategy

+ func (in *NATSBus) DeepCopy() *NATSBus

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

+ type NATSConfig struct

+ AccessSecret *corev1.SecretKeySelector

+ Auth *AuthStrategy

+ ClusterID *string

+ URL string

+ func (in *NATSConfig) DeepCopy() *NATSConfig

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

+ type NativeStrategy struct

+ AntiAffinity bool

+ Auth *AuthStrategy

+ Persistence *PersistenceStrategy

+ Size int

+ func (in *NativeStrategy) DeepCopy() *NativeStrategy

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

+ type PersistenceStrategy struct

+ AccessMode *corev1.PersistentVolumeAccessMode

+ Size *apiresource.Quantity

+ StorageClassName *string

+ func (in *PersistenceStrategy) DeepCopy() *PersistenceStrategy

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