v1alpha1

package
v0.14.0-beta.1 Latest Latest
Warning

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

 Go to latest Published: Jul 9, 2020 License: Apache-2.0 Imports: 16 Imported by: 6

Documentation

Overview

+groupName=config.kubedb.com

Index

Constants

View Source 
const (
	// GarbdListenPort is the port at which Galera Arbitrator Daemon (garbd) listen
	GarbdListenPort = 4444

	// GarbdXtrabackupSSTMethod is the name of the method or script that is
	// used during a State Snapshot Transfer to Galera Arbitrator Daemon (garbd).
	GarbdXtrabackupSSTMethod = "xtrabackup-v2"

	// GarbdXtrabackupSSTRequestSuffix denotes the suffix of sst request string for xtrabackup
	// used by Galera Arbitrator Daemon (garbd)
	GarbdXtrabackupSSTRequestSuffix = "/xtrabackup_sst//1"
	// GarbdLogFile is the name log file at which Galera Arbitrator Daemon (garbd) puts logs
	GarbdLogFile = "/tmp/garb.log"

	// SOCAT is needed after completing sst by Galera Arbitrator Daemon (garbd)
	// SOCATOptionReUseAddr is the SOCAT reuseaddr option
	SOCATOptionReUseAddr = "reuseaddr"
	// SOCATOptionRetry is the default retry value for `socat` binary
	SOCATOptionRetry = 30
)
View Source 
const (
	// Resource Kind for GaleraArbitratorConfiguration
	ResourceKindGaleraArbitratorConfiguration = "GaleraArbitratorConfiguration"
)
View Source 
const (
	ResourceKindMongoConfiguration = "MongoConfiguration"
)

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 (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: config.GroupName, Version: "v1alpha1"}

Functions

func GetOpenAPIDefinitions 

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

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

func SOCATOption 

func SOCATOption(retry int32) string

SOCATOption returns the option string used for `SOCAT` in the percona xtradb backup process

Types

type GaleraArbitratorConfiguration 

type GaleraArbitratorConfiguration struct {
	metav1.TypeMeta `json:",inline,omitempty"`

	// Address denotes the logical name of the galera cluster. It is
	// used as the value of the variable named "wsrep_cluster_name"
	// in the replication configuration for galera
	// Ref: https://galeracluster.com/library/documentation/mysql-wsrep-options.html#wsrep-cluster-name
	Address string `json:"address,omitempty" protobuf:"bytes,1,opt,name=address"`

	// Group denotes the collection of cluster members by IP address
	// or resolvable domain name. This address is used as the value of the
	// variable named "wsrep_cluster_address" in the replication configuration
	// for galera. It must be in galera format.
	// Ref: https://galeracluster.com/library/documentation/mysql-wsrep-options.html#wsrep-cluster-address
	Group string `json:"group,omitempty" protobuf:"bytes,2,opt,name=group"`

	// SSTMethod denotes the method or script the node uses during a State Snapshot Transfer.
	// This method is needed to form the SST request string that contains SST request to
	// trigger state snapshot dump (state backup) on one of the other nodes.
	// Ref: https://galeracluster.com/library/documentation/mysql-wsrep-options.html#wsrep-sst-method
	SSTMethod string `json:"sstMethod,omitempty" protobuf:"bytes,3,opt,name=sstMethod"`
}

GaleraArbitratorConfiguration defines Galera ARBitrator Daemon (garbd) configuration. Ref: https://galeracluster.com/library/documentation/arbitrator.html 

https://galeracluster.com/library/documentation/backup-cluster.html

func (*GaleraArbitratorConfiguration) ClusterAddressWithListenOption 

func (g *GaleraArbitratorConfiguration) ClusterAddressWithListenOption() string

ClusterAddressWithListenOption method returns the galera cluster address with the listening option (address at which Galera Cluster listens to connections from other nodes) for `--address` option in `garbd` Here, ‘?gmcast.listen_addr=tcp://0.0.0.0:4444‘ is an arbitrary listen socket address that Galera Arbitrator opens to communicate with the cluster. https://galeracluster.com/library/documentation/backup-cluster.html

func (*GaleraArbitratorConfiguration) DeepCopy 

func (in *GaleraArbitratorConfiguration) DeepCopy() *GaleraArbitratorConfiguration

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

func (*GaleraArbitratorConfiguration) DeepCopyInto 

func (in *GaleraArbitratorConfiguration) DeepCopyInto(out *GaleraArbitratorConfiguration)

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

func (*GaleraArbitratorConfiguration) DeepCopyObject 

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

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

func (*GaleraArbitratorConfiguration) Descriptor 

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

func (*GaleraArbitratorConfiguration) Marshal 

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

func (*GaleraArbitratorConfiguration) MarshalTo 

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

func (*GaleraArbitratorConfiguration) MarshalToSizedBuffer 

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

func (*GaleraArbitratorConfiguration) ProtoMessage 

func (*GaleraArbitratorConfiguration) ProtoMessage()

func (*GaleraArbitratorConfiguration) Reset 

func (m *GaleraArbitratorConfiguration) Reset()

func (*GaleraArbitratorConfiguration) SSTRequestString 

func (g *GaleraArbitratorConfiguration) SSTRequestString(host string) string

SSTRequestString method form the sst request string for `--sst` option in `garbd`

func (*GaleraArbitratorConfiguration) Size 

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

func (*GaleraArbitratorConfiguration) String 

func (this *GaleraArbitratorConfiguration) String() string

func (*GaleraArbitratorConfiguration) Unmarshal 

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

func (*GaleraArbitratorConfiguration) XXX_DiscardUnknown 

func (m *GaleraArbitratorConfiguration) XXX_DiscardUnknown()

func (*GaleraArbitratorConfiguration) XXX_Marshal 

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

func (*GaleraArbitratorConfiguration) XXX_Merge 

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

func (*GaleraArbitratorConfiguration) XXX_Size 

func (m *GaleraArbitratorConfiguration) XXX_Size() int

func (*GaleraArbitratorConfiguration) XXX_Unmarshal 

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

type MongoDBConfiguration 

type MongoDBConfiguration struct {
	metav1.TypeMeta `json:",inline,omitempty"`

	// ConfigServer is the dsn of config server of mongodb sharding. The dsn includes the port no too.
	ConfigServer string `json:"configServer,omitempty" protobuf:"bytes,1,opt,name=configServer"`

	// ReplicaSets contains the dsn of each replicaset of sharding. The DSNs are in key-value pair, where
	// the keys are host-0, host-1 etc, and the values are DSN of each replicaset. If there is no sharding
	// but only one replicaset, then ReplicaSets field contains only one key-value pair where the key is
	// host-0 and the value is dsn of that replicaset.
	ReplicaSets map[string]string `json:"replicaSets,omitempty" protobuf:"bytes,2,rep,name=replicaSets"`
}

MongoDBConfiguration defines a MongoDB app configuration. https://www.vaultproject.io/api/secret/databases/index.html https://www.vaultproject.io/api/secret/databases/mongodb.html#configure-connection

func (*MongoDBConfiguration) DeepCopy 

func (in *MongoDBConfiguration) DeepCopy() *MongoDBConfiguration

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

func (*MongoDBConfiguration) DeepCopyInto 

func (in *MongoDBConfiguration) DeepCopyInto(out *MongoDBConfiguration)

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

func (*MongoDBConfiguration) DeepCopyObject 

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

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

func (*MongoDBConfiguration) Descriptor 

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

func (*MongoDBConfiguration) Marshal 

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

func (*MongoDBConfiguration) MarshalTo 

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

func (*MongoDBConfiguration) MarshalToSizedBuffer 

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

func (*MongoDBConfiguration) ProtoMessage 

func (*MongoDBConfiguration) ProtoMessage()

func (*MongoDBConfiguration) Reset 

func (m *MongoDBConfiguration) Reset()

func (*MongoDBConfiguration) Size 

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

func (*MongoDBConfiguration) String 

func (this *MongoDBConfiguration) String() string

func (*MongoDBConfiguration) Unmarshal 

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

func (*MongoDBConfiguration) XXX_DiscardUnknown 

func (m *MongoDBConfiguration) XXX_DiscardUnknown()

func (*MongoDBConfiguration) XXX_Marshal 

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

func (*MongoDBConfiguration) XXX_Merge 

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

func (*MongoDBConfiguration) XXX_Size 

func (m *MongoDBConfiguration) XXX_Size() int

func (*MongoDBConfiguration) XXX_Unmarshal 

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