kbagent

package

v1.0.3-beta.11 Latest Latest Go to latest Published: Aug 18, 2026 License: AGPL-3.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apecloud/kubeblocks

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BuildEnv4Server(actions []proto.Action, probes []proto.Probe, streaming []string) ([]corev1.EnvVar, error)
func BuildEnv4Worker(tasks []proto.Task) (*corev1.EnvVar, error)
func InitCommand() []string
func IsContainer(container *corev1.Container) bool
func IsInitCommand(command []string) bool
func IsLegacyInitCommand(command []string) bool
func Launch(logger logr.Logger, config server.Config) (bool, error)
func LegacyInitCommand() []string
func SharedVolumeMount() corev1.VolumeMount
func UpdateEnv4Worker(envVars map[string]string, f func(proto.Task) *proto.Task) (*corev1.EnvVar, error)
func UsesSharedBinary(containers []corev1.Container) bool

Constants ¶

View Source

const (
	BinaryPath       = "/bin/kbagent"
	TiniPath         = "/bin/tini-static"
	SharedMountPath  = "/kubeblocks"
	SharedBinaryPath = SharedMountPath + "/kbagent"
	SharedVolumeName = "kubeblocks"
)

View Source

const (
	ContainerName        = "kbagent"
	ContainerName4Worker = "kbagent-worker"
	InitContainerName    = "init-kbagent"

	DefaultHTTPPortName      = "http"
	DefaultStreamingPortName = "streaming"

	DefaultHTTPPort      = 3501
	DefaultStreamingPort = 3502
)

Variables ¶

This section is empty.

Functions ¶

func BuildEnv4Server ¶

func BuildEnv4Server(actions []proto.Action, probes []proto.Probe, streaming []string) ([]corev1.EnvVar, error)

func BuildEnv4Worker ¶

func BuildEnv4Worker(tasks []proto.Task) (*corev1.EnvVar, error)

func InitCommand ¶

func InitCommand() []string

InitCommand returns the current init-kbagent copy command.

func IsContainer ¶

func IsContainer(container *corev1.Container) bool

IsContainer reports whether container belongs to the kbagent runtime.

func IsInitCommand ¶

func IsInitCommand(command []string) bool

IsInitCommand reports whether command implements the current init-kbagent copy contract.

func IsLegacyInitCommand ¶

func IsLegacyInitCommand(command []string) bool

IsLegacyInitCommand reports whether command implements the legacy init-kbagent copy contract.

func Launch ¶

func Launch(logger logr.Logger, config server.Config) (bool, error)

func LegacyInitCommand ¶

func LegacyInitCommand() []string

LegacyInitCommand returns the init-kbagent copy command used before tini-static became part of the shared kbagent runtime contract.

func SharedVolumeMount ¶

func SharedVolumeMount() corev1.VolumeMount

SharedVolumeMount returns the volume mount used by the shared kbagent binary.

func UpdateEnv4Worker ¶

func UpdateEnv4Worker(envVars map[string]string, f func(proto.Task) *proto.Task) (*corev1.EnvVar, error)

func UsesSharedBinary ¶

func UsesSharedBinary(containers []corev1.Container) bool

UsesSharedBinary reports whether the kbagent server container runs the binary copied to the shared mount.

Types ¶

This section is empty.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
client Package client is a generated GoMock package.	Package client is a generated GoMock package.
proto
server
service
util

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL