v1alpha1

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2021 License: Apache-2.0 Imports: 18 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

This section is empty.

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: apis.Group, Version: "v1alpha1"}

	// SchemaGroupVersionKind is a group version kind used to attach owner references
	SchemaGroupVersionKind = schema.GroupVersionKind{Group: apis.Group, Version: "v1alpha1", Kind: apis.Kind}

	// 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 

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

func (*BusConfig) Marshal 

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

func (*BusConfig) MarshalTo 

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

func (*BusConfig) MarshalToSizedBuffer 

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

func (*BusConfig) ProtoMessage 

func (*BusConfig) ProtoMessage()

func (*BusConfig) Reset 

func (m *BusConfig) Reset()

func (*BusConfig) Size 

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

func (*BusConfig) String 

func (this *BusConfig) String() string

func (*BusConfig) Unmarshal 

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

func (*BusConfig) XXX_DiscardUnknown 

func (m *BusConfig) XXX_DiscardUnknown()

func (*BusConfig) XXX_Marshal 

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

func (*BusConfig) XXX_Merge 

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

func (*BusConfig) XXX_Size 

func (m *BusConfig) XXX_Size() int

func (*BusConfig) XXX_Unmarshal 

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

type Condition 

type Condition struct {
	// Condition type.
	// +required
	Type ConditionType `json:"type" protobuf:"bytes,1,opt,name=type"`
	// Condition status, True, False or Unknown.
	// +required
	Status corev1.ConditionStatus `json:"status" protobuf:"bytes,2,opt,name=status,casttype=k8s.io/api/core/v1.ConditionStatus"`
	// Last time the condition transitioned from one status to another.
	// +optional
	LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty" protobuf:"bytes,3,opt,name=lastTransitionTime"`
	// Unique, this should be a short, machine understandable string that gives the reason
	// for condition's last transition. For example, "ImageNotFound"
	// +optional
	Reason string `json:"reason,omitempty" protobuf:"bytes,4,opt,name=reason"`
	// Human-readable message indicating details about last transition.
	// +optional
	Message string `json:"message,omitempty" protobuf:"bytes,5,opt,name=message"`
}

Condition contains details about resource state

func (*Condition) DeepCopy 

func (in *Condition) DeepCopy() *Condition

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

func (*Condition) DeepCopyInto 

func (in *Condition) DeepCopyInto(out *Condition)

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

func (*Condition) Descriptor 

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

func (*Condition) GetMessage 

func (c *Condition) GetMessage() string

GetMessage returns a Message

func (*Condition) GetReason 

func (c *Condition) GetReason() string

GetReason returns as Reason

func (*Condition) IsFalse 

func (c *Condition) IsFalse() bool

IsFalse tells if the condition is False

func (*Condition) IsTrue 

func (c *Condition) IsTrue() bool

IsTrue tells if the condition is True

func (*Condition) IsUnknown 

func (c *Condition) IsUnknown() bool

IsUnknown tells if the condition is Unknown

func (*Condition) Marshal 

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

func (*Condition) MarshalTo 

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

func (*Condition) MarshalToSizedBuffer 

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

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) Reset 

func (m *Condition) Reset()

func (*Condition) Size 

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

func (*Condition) String 

func (this *Condition) String() string

func (*Condition) Unmarshal 

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

func (*Condition) XXX_DiscardUnknown 

func (m *Condition) XXX_DiscardUnknown()

func (*Condition) XXX_Marshal 

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

func (*Condition) XXX_Merge 

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

func (*Condition) XXX_Size 

func (m *Condition) XXX_Size() int

func (*Condition) XXX_Unmarshal 

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

type ConditionType 

type ConditionType string

ConditionType is a valid value of Condition.Type 

const (
	// EventBusConditionDeployed has the status True when the EventBus
	// has its RestfulSet/Deployment ans service created.
	EventBusConditionDeployed ConditionType = "Deployed"
	// EventBusConditionConfigured has the status True when the EventBus
	// has its configuration ready.
	EventBusConditionConfigured ConditionType = "Configured"
)
const (
	// ConditionReady indicates the resource is ready.
	ConditionReady ConditionType = "Ready"
)

type ContainerTemplate 

type ContainerTemplate struct {
	Resources corev1.ResourceRequirements `json:"resources,omitempty" protobuf:"bytes,1,opt,name=resources"`
}

ContainerTemplate defines customized spec for a container

func (*ContainerTemplate) DeepCopy 

func (in *ContainerTemplate) DeepCopy() *ContainerTemplate

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

func (*ContainerTemplate) DeepCopyInto 

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 

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

func (*ContainerTemplate) Marshal 

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

func (*ContainerTemplate) MarshalTo 

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

func (*ContainerTemplate) MarshalToSizedBuffer 

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

func (*ContainerTemplate) ProtoMessage 

func (*ContainerTemplate) ProtoMessage()

func (*ContainerTemplate) Reset 

func (m *ContainerTemplate) Reset()

func (*ContainerTemplate) Size 

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

func (*ContainerTemplate) String 

func (this *ContainerTemplate) String() string

func (*ContainerTemplate) Unmarshal 

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

func (*ContainerTemplate) XXX_DiscardUnknown 

func (m *ContainerTemplate) XXX_DiscardUnknown()

func (*ContainerTemplate) XXX_Marshal 

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

func (*ContainerTemplate) XXX_Merge 

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

func (*ContainerTemplate) XXX_Size 

func (m *ContainerTemplate) XXX_Size() int

func (*ContainerTemplate) XXX_Unmarshal 

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 

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

func (*EventBus) Marshal 

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

func (*EventBus) MarshalTo 

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

func (*EventBus) MarshalToSizedBuffer 

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

func (*EventBus) ProtoMessage 

func (*EventBus) ProtoMessage()

func (*EventBus) Reset 

func (m *EventBus) Reset()

func (*EventBus) Size 

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

func (*EventBus) String 

func (this *EventBus) String() string

func (*EventBus) Unmarshal 

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

func (*EventBus) XXX_DiscardUnknown 

func (m *EventBus) XXX_DiscardUnknown()

func (*EventBus) XXX_Marshal 

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

func (*EventBus) XXX_Merge 

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

func (*EventBus) XXX_Size 

func (m *EventBus) XXX_Size() int

func (*EventBus) XXX_Unmarshal 

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 

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

func (*EventBusList) Marshal 

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

func (*EventBusList) MarshalTo 

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

func (*EventBusList) MarshalToSizedBuffer 

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

func (*EventBusList) ProtoMessage 

func (*EventBusList) ProtoMessage()

func (*EventBusList) Reset 

func (m *EventBusList) Reset()

func (*EventBusList) Size 

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

func (*EventBusList) String 

func (this *EventBusList) String() string

func (*EventBusList) Unmarshal 

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

func (*EventBusList) XXX_DiscardUnknown 

func (m *EventBusList) XXX_DiscardUnknown()

func (*EventBusList) XXX_Marshal 

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

func (*EventBusList) XXX_Merge 

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

func (*EventBusList) XXX_Size 

func (m *EventBusList) XXX_Size() int

func (*EventBusList) XXX_Unmarshal 

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 

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

func (*EventBusSpec) Marshal 

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

func (*EventBusSpec) MarshalTo 

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

func (*EventBusSpec) MarshalToSizedBuffer 

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

func (*EventBusSpec) ProtoMessage 

func (*EventBusSpec) ProtoMessage()

func (*EventBusSpec) Reset 

func (m *EventBusSpec) Reset()

func (*EventBusSpec) Size 

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

func (*EventBusSpec) String 

func (this *EventBusSpec) String() string

func (*EventBusSpec) Unmarshal 

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

func (*EventBusSpec) XXX_DiscardUnknown 

func (m *EventBusSpec) XXX_DiscardUnknown()

func (*EventBusSpec) XXX_Marshal 

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

func (*EventBusSpec) XXX_Merge 

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

func (*EventBusSpec) XXX_Size 

func (m *EventBusSpec) XXX_Size() int

func (*EventBusSpec) XXX_Unmarshal 

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

type EventBusStatus 

type EventBusStatus struct {
	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 

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 

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

func (*EventBusStatus) MarshalTo 

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

func (*EventBusStatus) MarshalToSizedBuffer 

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

func (*EventBusStatus) ProtoMessage 

func (*EventBusStatus) ProtoMessage()

func (*EventBusStatus) Reset 

func (m *EventBusStatus) Reset()

func (*EventBusStatus) Size 

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

func (*EventBusStatus) String 

func (this *EventBusStatus) String() string

func (*EventBusStatus) Unmarshal 

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

func (*EventBusStatus) XXX_DiscardUnknown 

func (m *EventBusStatus) XXX_DiscardUnknown()

func (*EventBusStatus) XXX_Marshal 

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

func (*EventBusStatus) XXX_Merge 

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

func (*EventBusStatus) XXX_Size 

func (m *EventBusStatus) XXX_Size() int

func (*EventBusStatus) XXX_Unmarshal 

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

type Metadata 

type Metadata struct {
	Annotations map[string]string `json:"annotations,omitempty" protobuf:"bytes,1,rep,name=annotations"`
	Labels      map[string]string `json:"labels,omitempty" protobuf:"bytes,2,rep,name=labels"`
}

Metadata holds the annotations and labels of an event source pod

func (*Metadata) DeepCopy 

func (in *Metadata) DeepCopy() *Metadata

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

func (*Metadata) DeepCopyInto 

func (in *Metadata) DeepCopyInto(out *Metadata)

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

func (*Metadata) Descriptor 

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

func (*Metadata) Marshal 

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

func (*Metadata) MarshalTo 

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

func (*Metadata) MarshalToSizedBuffer 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (this *Metadata) String() string

func (*Metadata) Unmarshal 

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

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

func (m *Metadata) 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 

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

func (*NATSBus) Marshal 

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

func (*NATSBus) MarshalTo 

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

func (*NATSBus) MarshalToSizedBuffer 

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

func (*NATSBus) ProtoMessage 

func (*NATSBus) ProtoMessage()

func (*NATSBus) Reset 

func (m *NATSBus) Reset()

func (*NATSBus) Size 

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

func (*NATSBus) String 

func (this *NATSBus) String() string

func (*NATSBus) Unmarshal 

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

func (*NATSBus) XXX_DiscardUnknown 

func (m *NATSBus) XXX_DiscardUnknown()

func (*NATSBus) XXX_Marshal 

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

func (*NATSBus) XXX_Merge 

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

func (*NATSBus) XXX_Size 

func (m *NATSBus) XXX_Size() int

func (*NATSBus) XXX_Unmarshal 

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 

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

func (*NATSConfig) Marshal 

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

func (*NATSConfig) MarshalTo 

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

func (*NATSConfig) MarshalToSizedBuffer 

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

func (*NATSConfig) ProtoMessage 

func (*NATSConfig) ProtoMessage()

func (*NATSConfig) Reset 

func (m *NATSConfig) Reset()

func (*NATSConfig) Size 

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

func (*NATSConfig) String 

func (this *NATSConfig) String() string

func (*NATSConfig) Unmarshal 

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

func (*NATSConfig) XXX_DiscardUnknown 

func (m *NATSConfig) XXX_DiscardUnknown()

func (*NATSConfig) XXX_Marshal 

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

func (*NATSConfig) XXX_Merge 

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

func (*NATSConfig) XXX_Size 

func (m *NATSConfig) XXX_Size() int

func (*NATSConfig) XXX_Unmarshal 

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"`
	// Deprecated, use Affinity instead, will be removed in v1.5
	DeprecatedAntiAffinity bool `json:"antiAffinity,omitempty" protobuf:"varint,3,opt,name=antiAffinity"`
	// +optional
	Persistence *PersistenceStrategy `json:"persistence,omitempty" protobuf:"bytes,4,opt,name=persistence"`
	// ContainerTemplate contains customized spec for NATS container
	// +optional
	ContainerTemplate *ContainerTemplate `json:"containerTemplate,omitempty" protobuf:"bytes,5,opt,name=containerTemplate"`
	// MetricsContainerTemplate contains customized spec for metrics container
	// +optional
	MetricsContainerTemplate *ContainerTemplate `json:"metricsContainerTemplate,omitempty" protobuf:"bytes,6,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,7,rep,name=nodeSelector"`
	// If specified, the pod's tolerations.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,8,rep,name=tolerations"`
	// Metadata sets the pods's metadata, i.e. annotations and labels
	Metadata *Metadata `json:"metadata,omitempty" protobuf:"bytes,9,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,10,opt,name=securityContext"`
	// Max Age of existing messages, i.e. "72h", “4h35m”
	// +optional
	MaxAge *string `json:"maxAge,omitempty" protobuf:"bytes,11,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,12,rep,name=imagePullSecrets"`
	// ServiceAccountName to apply to NATS StatefulSet
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,13,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,14,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,15,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,16,opt,name=affinity"`
	// Maximum number of messages per channel, 0 means unlimited. Defaults to 1000000
	MaxMsgs *uint64 `json:"maxMsgs,omitempty" protobuf:"bytes,17,opt,name=maxMsgs"`
	// Total size of messages per channel, 0 means unlimited. Defaults to 1GB
	MaxBytes *string `json:"maxBytes,omitempty" protobuf:"bytes,18,opt,name=maxBytes"`
}

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 

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

func (*NativeStrategy) GetReplicas 

func (in *NativeStrategy) GetReplicas() int

GetReplicas return the replicas of statefulset

func (*NativeStrategy) Marshal 

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

func (*NativeStrategy) MarshalTo 

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

func (*NativeStrategy) MarshalToSizedBuffer 

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

func (*NativeStrategy) ProtoMessage 

func (*NativeStrategy) ProtoMessage()

func (*NativeStrategy) Reset 

func (m *NativeStrategy) Reset()

func (*NativeStrategy) Size 

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

func (*NativeStrategy) String 

func (this *NativeStrategy) String() string

func (*NativeStrategy) Unmarshal 

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

func (*NativeStrategy) XXX_DiscardUnknown 

func (m *NativeStrategy) XXX_DiscardUnknown()

func (*NativeStrategy) XXX_Marshal 

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

func (*NativeStrategy) XXX_Merge 

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

func (*NativeStrategy) XXX_Size 

func (m *NativeStrategy) XXX_Size() int

func (*NativeStrategy) XXX_Unmarshal 

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 

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

func (*PersistenceStrategy) Marshal 

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

func (*PersistenceStrategy) MarshalTo 

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

func (*PersistenceStrategy) MarshalToSizedBuffer 

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

func (*PersistenceStrategy) ProtoMessage 

func (*PersistenceStrategy) ProtoMessage()

func (*PersistenceStrategy) Reset 

func (m *PersistenceStrategy) Reset()

func (*PersistenceStrategy) Size 

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

func (*PersistenceStrategy) String 

func (this *PersistenceStrategy) String() string

func (*PersistenceStrategy) Unmarshal 

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

func (*PersistenceStrategy) XXX_DiscardUnknown 

func (m *PersistenceStrategy) XXX_DiscardUnknown()

func (*PersistenceStrategy) XXX_Marshal 

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

func (*PersistenceStrategy) XXX_Merge 

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

func (*PersistenceStrategy) XXX_Size 

func (m *PersistenceStrategy) XXX_Size() int

func (*PersistenceStrategy) XXX_Unmarshal 

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

type Status 

type Status struct {
	// Conditions are the latest available observations of a resource's current state.
	// +optional
	// +patchMergeKey=type
	// +patchStrategy=merge
	Conditions []Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}

Status is a common structure which can be used for Status field.

func (*Status) DeepCopy 

func (in *Status) DeepCopy() *Status

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

func (*Status) DeepCopyInto 

func (in *Status) DeepCopyInto(out *Status)

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

func (*Status) Descriptor 

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

func (*Status) GetCondition 

func (s *Status) GetCondition(t ConditionType) *Condition

GetCondition returns the condition of a condtion type

func (*Status) InitializeConditions 

func (s *Status) InitializeConditions(conditionTypes ...ConditionType)

InitializeConditions initializes the contions to Unknown

func (*Status) IsReady 

func (s *Status) IsReady() bool

IsReady returns true when all the conditions are true

func (*Status) MarkFalse 

func (s *Status) MarkFalse(t ConditionType, reason, message string)

MarkFalse sets the status of t to fasle

func (*Status) MarkTrue 

func (s *Status) MarkTrue(t ConditionType)

MarkTrue sets the status of t to true

func (*Status) MarkTrueWithReason 

func (s *Status) MarkTrueWithReason(t ConditionType, reason, message string)

MarkTrueWithReason sets the status of t to true with reason

func (*Status) MarkUnknown 

func (s *Status) MarkUnknown(t ConditionType, reason, message string)

MarkUnknown sets the status of t to unknown

func (*Status) Marshal 

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

func (*Status) MarshalTo 

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

func (*Status) MarshalToSizedBuffer 

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

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) SetCondition 

func (s *Status) SetCondition(condition Condition)

SetCondition sets a condition

func (*Status) Size 

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

func (*Status) String 

func (this *Status) String() string

func (*Status) Unmarshal 

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

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

func (m *Status) 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.