Documentation ¶
Index ¶
- Constants
- func GetHMetaAddr(hdb *hapi.HStreamDB) (string, error)
- func GetLogDeviceConfig(nodeNum int32, hmetaAddr string, existingConfig []byte) (string, error)
- func GetLogDeviceConfigMapNamespacedName(hdb *hapi.HStreamDB) types.NamespacedName
- func GetLogDeviceConfigVolume(hdb *hapi.HStreamDB) corev1.Volume
- func GetLogDeviceConfigVolumeMount(hdb *hapi.HStreamDB) corev1.VolumeMount
- func GetMinNShards(hdb *hapi.HStreamDB) int
- func GetNShardsConfigMapNamespacedName(hdb *hapi.HStreamDB) types.NamespacedName
- func GetNShardsConfigVolume(hdb *hapi.HStreamDB) corev1.Volume
- func GetNShardsConfigVolumeMount(hdb *hapi.HStreamDB) corev1.VolumeMount
- func GetRecommendedLogReplicaAcross(hdb *hapi.HStreamDB) int
Constants ¶
View Source
const (
LogDeviceConfigKey = "config.json"
)
View Source
const NShardsConfigKey = "NSHARDS"
Variables ¶
This section is empty.
Functions ¶
func GetLogDeviceConfig ¶
func GetLogDeviceConfigMapNamespacedName ¶
func GetLogDeviceConfigMapNamespacedName(hdb *hapi.HStreamDB) types.NamespacedName
func GetLogDeviceConfigVolumeMount ¶
func GetLogDeviceConfigVolumeMount(hdb *hapi.HStreamDB) corev1.VolumeMount
func GetMinNShards ¶
func GetNShardsConfigMapNamespacedName ¶
func GetNShardsConfigMapNamespacedName(hdb *hapi.HStreamDB) types.NamespacedName
func GetNShardsConfigVolumeMount ¶
func GetNShardsConfigVolumeMount(hdb *hapi.HStreamDB) corev1.VolumeMount
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.