kbagent

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 Launch(logger logr.Logger, config server.Config) (bool, error)
• func UpdateEnv4Worker(envVars map[string]string, f func(proto.Task) *proto.Task) (*corev1.EnvVar, error)

Constants

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

	DefaultHTTPPortName      = "http"
	DefaultStreamingPortName = "streaming"

	DefaultHTTPPort      = 3501
	DefaultStreamingPort = 3502
)

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 Launch

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

func UpdateEnv4Worker

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