internal

Documentation

Index

• Constants
• func GetDeployment(hdb *hapi.HStreamDB, comp *hapi.Component, podSpec *corev1.PodTemplateSpec, ...) appsv1.Deployment
• func GetHeadlessService(hdb *hapi.HStreamDB, compType hapi.ComponentType, ports ...corev1.ServicePort) corev1.Service
• func GetObjectHash(obj interface{}) string
• func GetObjectMetadata(hdb *hapi.HStreamDB, base *metav1.ObjectMeta, compType hapi.ComponentType) metav1.ObjectMeta
• func GetPvc(hdb *hapi.HStreamDB, template *corev1.PersistentVolumeClaimTemplate, ...) (pvc corev1.PersistentVolumeClaim)
• func GetPvcName(hdb *hapi.HStreamDB, pvc *corev1.PersistentVolumeClaimTemplate) string
• func GetResNameOnPanic(hdb *hapi.HStreamDB, shortName string) string
• func GetResNameWithDefault(hdb *hapi.HStreamDB, shortName, defaultName string) string
• func GetService(hdb *hapi.HStreamDB, compType hapi.ComponentType, ports ...corev1.ServicePort) corev1.Service
• func GetStatefulSet(hdb *hapi.HStreamDB, comp *hapi.Component, podSpec *corev1.PodTemplateSpec, ...) appsv1.StatefulSet
• type FlagSet
  • func (f *FlagSet) Flags() map[string]string
  • func (f *FlagSet) Parse(arguments []string) error
  • func (f *FlagSet) Visit(fn func(flag, value string))

Constants

const (
	HStoreDataPath   = "/data/logdevice"
	HStoreConfigPath = "/etc/logdevice"
	HMetaDataPath    = "/rqlite/file"
)

Functions

func GetDeployment

func GetDeployment(hdb *hapi.HStreamDB, comp *hapi.Component, podSpec *corev1.PodTemplateSpec,
	compType hapi.ComponentType) appsv1.Deployment

func GetHeadlessService

func GetHeadlessService(hdb *hapi.HStreamDB, compType hapi.ComponentType, ports ...corev1.ServicePort) corev1.Service

GetHeadlessService builds a headless service for a cluster.

func GetObjectHash

func GetObjectHash(obj interface{}) string

func GetObjectMetadata

func GetObjectMetadata(hdb *hapi.HStreamDB, base *metav1.ObjectMeta, compType hapi.ComponentType) metav1.ObjectMeta

GetObjectMetadata returns the ObjectMetadata for a component

func GetPvc

func GetPvc(hdb *hapi.HStreamDB, template *corev1.PersistentVolumeClaimTemplate, compType hapi.ComponentType) (pvc corev1.PersistentVolumeClaim)

func GetPvcName

func GetPvcName(hdb *hapi.HStreamDB, pvc *corev1.PersistentVolumeClaimTemplate) string

func GetResNameOnPanic

func GetResNameOnPanic(hdb *hapi.HStreamDB, shortName string) string

func GetResNameWithDefault

func GetResNameWithDefault(hdb *hapi.HStreamDB, shortName, defaultName string) string

GetResNameWithDefault get resource name with short name, it will use default name if short name is empty

func GetService

func GetService(hdb *hapi.HStreamDB, compType hapi.ComponentType, ports ...corev1.ServicePort) corev1.Service

GetService builds a service for a cluster.

func GetStatefulSet

func GetStatefulSet(hdb *hapi.HStreamDB, comp *hapi.Component, podSpec *corev1.PodTemplateSpec,
	compType hapi.ComponentType) appsv1.StatefulSet

Types

type FlagSet

type FlagSet struct {
	// contains filtered or unexported fields
}

func (*FlagSet) Flags

func (f *FlagSet) Flags() map[string]string

Flags returns parsed flags

func (*FlagSet) Parse

func (f *FlagSet) Parse(arguments []string) error

Parse parses flag definitions from the argument list, which should not include the command name. Must be called after all flags in the FlagSet are defined and before flags are accessed by the program. The return value will be ErrHelp if -help or -h were set but not defined.

func (*FlagSet) Visit

func (f *FlagSet) Visit(fn func(flag, value string))

Visit visits the flags in lexicographical order, calling fn for each.