Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

v1alpha1

package

Go to main page

Versions in this module

v0

v0.1.2

Jul 1, 2021

Changes in this version

type NativeStrategy

+ MaxBytes *string

+ MaxMsgs *uint64

v0.1.1

May 26, 2021

v0.1.0

May 20, 2021

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ 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")

+ var SchemaGroupVersionKind = schema.GroupVersionKind

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ 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 (*BusConfig) Descriptor() ([]byte, []int)

+ func (*BusConfig) ProtoMessage()

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

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

+ 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 Condition struct

+ LastTransitionTime metav1.Time

+ Message string

+ Reason string

+ Status corev1.ConditionStatus

+ Type ConditionType

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

+ func (*Condition) ProtoMessage()

+ func (c *Condition) GetMessage() string

+ func (c *Condition) GetReason() string

+ func (c *Condition) IsFalse() bool

+ func (c *Condition) IsTrue() bool

+ func (c *Condition) IsUnknown() bool

+ func (in *Condition) DeepCopy() *Condition

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

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

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

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

+ func (m *Condition) Reset()

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

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

+ func (m *Condition) XXX_DiscardUnknown()

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

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

+ func (m *Condition) XXX_Size() int

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

+ func (this *Condition) String() string

+ type ConditionType string

+ const ConditionReady

+ const EventBusConditionConfigured

+ const EventBusConditionDeployed

+ 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 struct

+ Spec EventBusSpec

+ Status EventBusStatus

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

+ func (*EventBus) ProtoMessage()

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

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

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

+ 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 struct

+ Items []EventBus

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

+ func (*EventBusList) ProtoMessage()

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

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

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

+ 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 struct

+ NATS *NATSBus

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

+ func (*EventBusSpec) ProtoMessage()

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

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

+ 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 struct

+ Config BusConfig

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

+ func (*EventBusStatus) ProtoMessage()

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

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

+ 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 (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)

+ func (this *EventBusStatus) String() string

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

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

+ func (*Metadata) ProtoMessage()

+ func (in *Metadata) DeepCopy() *Metadata

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

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

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

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

+ func (m *Metadata) Reset()

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

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

+ func (m *Metadata) XXX_DiscardUnknown()

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

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

+ func (m *Metadata) XXX_Size() int

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

+ func (this *Metadata) String() string

+ type NATSBus struct

+ Exotic *NATSConfig

+ Native *NativeStrategy

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

+ func (*NATSBus) ProtoMessage()

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

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

+ 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 struct

+ AccessSecret *corev1.SecretKeySelector

+ Auth *AuthStrategy

+ ClusterID *string

+ URL string

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

+ func (*NATSConfig) ProtoMessage()

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

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

+ 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 struct

+ Affinity *corev1.Affinity

+ Auth *AuthStrategy

+ ContainerTemplate *ContainerTemplate

+ DeprecatedAntiAffinity bool

+ ImagePullSecrets []corev1.LocalObjectReference

+ MaxAge *string

+ Metadata *Metadata

+ MetricsContainerTemplate *ContainerTemplate

+ NodeSelector map[string]string

+ Persistence *PersistenceStrategy

+ Priority *int32

+ PriorityClassName string

+ Replicas int32

+ SecurityContext *corev1.PodSecurityContext

+ ServiceAccountName string

+ Tolerations []corev1.Toleration

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

+ func (*NativeStrategy) ProtoMessage()

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

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

+ 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) Size() (n int)

+ 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 struct

+ AccessMode *corev1.PersistentVolumeAccessMode

+ StorageClassName *string

+ VolumeSize *apiresource.Quantity

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

+ func (*PersistenceStrategy) ProtoMessage()

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

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

+ 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) Size() (n int)

+ 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

+ type Status struct

+ Conditions []Condition

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

+ func (*Status) ProtoMessage()

+ func (in *Status) DeepCopy() *Status

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

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

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

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

+ func (m *Status) Reset()

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

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

+ func (m *Status) XXX_DiscardUnknown()

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

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

+ func (m *Status) XXX_Size() int

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

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

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

+ func (s *Status) IsReady() bool

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

+ func (s *Status) MarkTrue(t ConditionType)

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

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

+ func (s *Status) SetCondition(condition Condition)

+ func (this *Status) String() string