v1alpha1

package
v0.0.0-...-704bf29 Latest Latest
Warning

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

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

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the agent v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=agent.atomix.io

Package v1alpha1 contains API Schema definitions for the agent v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=agent.atomix.io

Index

Constants

This section is empty.

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "agent.atomix.io", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)

Functions

func SetDefaults_Benchmark 

func SetDefaults_Benchmark(benchmark *AtomixBenchmark)

func SetDefaults_Cluster 

func SetDefaults_Cluster(cluster *AtomixCluster)

func SetDefaults_Compaction 

func SetDefaults_Compaction(compaction *Compaction)

func SetDefaults_LogPartitionGroup 

func SetDefaults_LogPartitionGroup(group *LogPartitionGroup)

Sets default options on the log partition group

func SetDefaults_PartitionGroup 

func SetDefaults_PartitionGroup(group *PartitionGroup)

func SetDefaults_PrimaryBackupPartitionGroup 

func SetDefaults_PrimaryBackupPartitionGroup(group *PrimaryBackupPartitionGroup)

Sets default options on the primary-backup partition group

func SetDefaults_RaftPartitionGroup 

func SetDefaults_RaftPartitionGroup(group *RaftPartitionGroup)

Sets default options on the Raft partition group

func SetDefaults_Storage 

func SetDefaults_Storage(storage *Storage)

Types

type AtomixBenchmark 

type AtomixBenchmark struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              AtomixBenchmarkSpec   `json:"spec,omitempty"`
	Status            AtomixBenchmarkStatus `json:"status,omitempty"`
}

AtomixBenchmark is the Schema for the AtomixBenchmarks API +k8s:openapi-gen=true

func (*AtomixBenchmark) DeepCopy 

func (in *AtomixBenchmark) DeepCopy() *AtomixBenchmark

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

func (*AtomixBenchmark) DeepCopyInto 

func (in *AtomixBenchmark) DeepCopyInto(out *AtomixBenchmark)

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

func (*AtomixBenchmark) DeepCopyObject 

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

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

type AtomixBenchmarkList 

type AtomixBenchmarkList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AtomixBenchmark `json:"items"`
}

AtomixBenchmarkList contains a list of BenchmarkController

func (*AtomixBenchmarkList) DeepCopy 

func (in *AtomixBenchmarkList) DeepCopy() *AtomixBenchmarkList

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

func (*AtomixBenchmarkList) DeepCopyInto 

func (in *AtomixBenchmarkList) DeepCopyInto(out *AtomixBenchmarkList)

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

func (*AtomixBenchmarkList) DeepCopyObject 

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

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

type AtomixBenchmarkSpec 

type AtomixBenchmarkSpec struct {
	Cluster   string                      `json:"cluster,omitempty"`
	Version   string                      `json:"version,omitempty"`
	Workers   int32                       `json:"workers,omitempty"`
	Env       []corev1.EnvVar             `json:"env,omitempty"`
	Resources corev1.ResourceRequirements `json:"resources,omitempty"`
}

AtomixBenchmarkSpec

func (*AtomixBenchmarkSpec) DeepCopy 

func (in *AtomixBenchmarkSpec) DeepCopy() *AtomixBenchmarkSpec

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

func (*AtomixBenchmarkSpec) DeepCopyInto 

func (in *AtomixBenchmarkSpec) DeepCopyInto(out *AtomixBenchmarkSpec)

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

type AtomixBenchmarkStatus 

type AtomixBenchmarkStatus struct {
	// ServiceName is the name of the headless service used to access controller nodes.
	ServiceName string `json:"serviceName,omitempty"`
}

AtomixBenchmarkStatus defines the observed state of AtomixCluster

func (*AtomixBenchmarkStatus) DeepCopy 

func (in *AtomixBenchmarkStatus) DeepCopy() *AtomixBenchmarkStatus

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

func (*AtomixBenchmarkStatus) DeepCopyInto 

func (in *AtomixBenchmarkStatus) DeepCopyInto(out *AtomixBenchmarkStatus)

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

type AtomixCluster 

type AtomixCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ClusterSpec   `json:"spec,omitempty"`
	Status            ClusterStatus `json:"status,omitempty"`
}

AtomixCluster is the Schema for the atomixclusters API +k8s:openapi-gen=true

func (*AtomixCluster) DeepCopy 

func (in *AtomixCluster) DeepCopy() *AtomixCluster

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

func (*AtomixCluster) DeepCopyInto 

func (in *AtomixCluster) DeepCopyInto(out *AtomixCluster)

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

func (*AtomixCluster) DeepCopyObject 

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

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

type AtomixClusterList 

type AtomixClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AtomixCluster `json:"items"`
}

AtomixClusterList contains a list of AtomixCluster

func (*AtomixClusterList) DeepCopy 

func (in *AtomixClusterList) DeepCopy() *AtomixClusterList

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

func (*AtomixClusterList) DeepCopyInto 

func (in *AtomixClusterList) DeepCopyInto(out *AtomixClusterList)

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

func (*AtomixClusterList) DeepCopyObject 

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

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

type ClusterSpec 

type ClusterSpec struct {
	Version   string                  `json:"version,omitempty"`
	Size      int32                   `json:"size,omitempty"`
	Env       []v1.EnvVar             `json:"env,omitempty"`
	Resources v1.ResourceRequirements `json:"resources,omitempty"`
	Storage   Storage                 `json:"storage,omitempty"`
}

ClusterSpec defines the desired state of AtomixCluster

func (*ClusterSpec) DeepCopy 

func (in *ClusterSpec) DeepCopy() *ClusterSpec

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

func (*ClusterSpec) DeepCopyInto 

func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)

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

type ClusterStatus 

type ClusterStatus struct {
	// ServiceName is the name of the headless service used to access controller nodes.
	ServiceName string `json:"serviceName,omitempty"`
}

ClusterStatus defines the observed state of AtomixCluster

func (*ClusterStatus) DeepCopy 

func (in *ClusterStatus) DeepCopy() *ClusterStatus

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

func (*ClusterStatus) DeepCopyInto 

func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)

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

type Compaction 

type Compaction struct {
	Dynamic          bool    `json:"dynamic,omitempty"`
	FreeDiskBuffer   float32 `json:"freeDiskBuffer,omitempty"`
	FreeMemoryBuffer float32 `json:"freeMemoryBuffer,omitempty"`
}

func (*Compaction) DeepCopy 

func (in *Compaction) DeepCopy() *Compaction

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

func (*Compaction) DeepCopyInto 

func (in *Compaction) DeepCopyInto(out *Compaction)

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

type LogPartitionGroup 

type LogPartitionGroup struct {
	PersistentPartitionGroup `json:",inline"`
	MemberGroupStrategy      MemberGroupStrategy `json:"memberGroupStrategy,omitempty"`
}

func (*LogPartitionGroup) DeepCopy 

func (in *LogPartitionGroup) DeepCopy() *LogPartitionGroup

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

func (*LogPartitionGroup) DeepCopyInto 

func (in *LogPartitionGroup) DeepCopyInto(out *LogPartitionGroup)

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

type MemberGroupStrategy 

type MemberGroupStrategy string

MemberGroupStrategy describes the way partition members are balanced among member groups. 

const (
	NodeAwareMemberGroupStrategy MemberGroupStrategy = "node_aware"
	RackAwareMemberGroupStrategy MemberGroupStrategy = "rack_aware"
	ZoneAwareMemberGroupStrategy MemberGroupStrategy = "zone_aware"
)

type PartitionGroup 

type PartitionGroup struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              PartitionGroupSpec   `json:"spec,omitempty"`
	Status            PartitionGroupStatus `json:"status,omitempty"`
}

PartitionGroup is the Schema for the partitiongroups API +k8s:openapi-gen=true

func (*PartitionGroup) DeepCopy 

func (in *PartitionGroup) DeepCopy() *PartitionGroup

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

func (*PartitionGroup) DeepCopyInto 

func (in *PartitionGroup) DeepCopyInto(out *PartitionGroup)

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

func (*PartitionGroup) DeepCopyObject 

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

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

type PartitionGroupList 

type PartitionGroupList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []PartitionGroup `json:"items"`
}

PartitionGroupList contains a list of PartitionGroup

func (*PartitionGroupList) DeepCopy 

func (in *PartitionGroupList) DeepCopy() *PartitionGroupList

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

func (*PartitionGroupList) DeepCopyInto 

func (in *PartitionGroupList) DeepCopyInto(out *PartitionGroupList)

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

func (*PartitionGroupList) DeepCopyObject 

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

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

type PartitionGroupSpec 

type PartitionGroupSpec struct {
	Cluster       string                       `json:"cluster,omitempty"`
	Version       string                       `json:"version,omitempty"`
	Size          int32                        `json:"size,omitempty"`
	Partitions    int                          `json:"partitions,omitempty"`
	Env           []corev1.EnvVar              `json:"env,omitempty"`
	Resources     corev1.ResourceRequirements  `json:"resources,omitempty"`
	Raft          *RaftPartitionGroup          `json:"raft,omitempty"`
	PrimaryBackup *PrimaryBackupPartitionGroup `json:"primaryBackup,omitempty"`
	Log           *LogPartitionGroup           `json:"log:omitempty"`
}

func (*PartitionGroupSpec) DeepCopy 

func (in *PartitionGroupSpec) DeepCopy() *PartitionGroupSpec

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

func (*PartitionGroupSpec) DeepCopyInto 

func (in *PartitionGroupSpec) DeepCopyInto(out *PartitionGroupSpec)

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

type PartitionGroupStatus 

type PartitionGroupStatus struct {
	// ServiceName is the name of the headless service used to access controller nodes.
	ServiceName string `json:"serviceName,omitempty"`
}

PartitionGroupStatus defines the observed state of AtomixCluster

func (*PartitionGroupStatus) DeepCopy 

func (in *PartitionGroupStatus) DeepCopy() *PartitionGroupStatus

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

func (*PartitionGroupStatus) DeepCopyInto 

func (in *PartitionGroupStatus) DeepCopyInto(out *PartitionGroupStatus)

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

type PartitionGroupType 

type PartitionGroupType string
const (
	RaftType          PartitionGroupType = "raft"
	PrimaryBackupType PartitionGroupType = "primary-backup"
	LogType           PartitionGroupType = "log"
)

func GetPartitionGroupType 

func GetPartitionGroupType(group *PartitionGroup) (PartitionGroupType, error)

type PersistentPartitionGroup 

type PersistentPartitionGroup struct {
	Storage    Storage    `json:"storage,omitempty"`
	Compaction Compaction `json:"compaction,omitempty"`
}

func (*PersistentPartitionGroup) DeepCopy 

func (in *PersistentPartitionGroup) DeepCopy() *PersistentPartitionGroup

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

func (*PersistentPartitionGroup) DeepCopyInto 

func (in *PersistentPartitionGroup) DeepCopyInto(out *PersistentPartitionGroup)

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

type PrimaryBackupPartitionGroup 

type PrimaryBackupPartitionGroup struct {
	MemberGroupStrategy MemberGroupStrategy `json:"memberGroupStrategy,omitempty"`
}

func (*PrimaryBackupPartitionGroup) DeepCopy 

func (in *PrimaryBackupPartitionGroup) DeepCopy() *PrimaryBackupPartitionGroup

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

func (*PrimaryBackupPartitionGroup) DeepCopyInto 

func (in *PrimaryBackupPartitionGroup) DeepCopyInto(out *PrimaryBackupPartitionGroup)

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

type RaftPartitionGroup 

type RaftPartitionGroup struct {
	PersistentPartitionGroup `json:",inline"`
	PartitionSize            int `json:"partitionSize,omitempty"`
}

func (*RaftPartitionGroup) DeepCopy 

func (in *RaftPartitionGroup) DeepCopy() *RaftPartitionGroup

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

func (*RaftPartitionGroup) DeepCopyInto 

func (in *RaftPartitionGroup) DeepCopyInto(out *RaftPartitionGroup)

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

type Storage 

type Storage struct {
	Size          string       `json:"size,omitempty"`
	ClassName     *string      `json:"className,omitempty"`
	SegmentSize   string       `json:"segmentSize,omitempty"`
	EntrySize     string       `json:"entrySize,omitempty"`
	Level         StorageLevel `json:"level,omitempty"`
	FlushOnCommit bool         `json:"flushOnCommit,omitempty"`
}

func (*Storage) DeepCopy 

func (in *Storage) DeepCopy() *Storage

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

func (*Storage) DeepCopyInto 

func (in *Storage) DeepCopyInto(out *Storage)

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

type StorageLevel 

type StorageLevel string

StorageLevel describes the storage level of commit logs. 

const (
	DiskStorage   StorageLevel = "disk"
	MappedStorage StorageLevel = "mapped"
)

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.