app

Apr 16, 2026

Changes in this version

+ func InitAppScheme() error

+ func InitKubernetesClient(ctx context.Context, cfg K8sConfig, scheme *runtime.Scheme) (client.WithWatch, *rest.Config, error)

+ type App struct

+ Name string

+ Setup func(ctx context.Context, sc *SetupContext) error

+ Short string

+ func (a *App) Command() *cobra.Command

+ func (a *App) Run() error

+ type K8sConfig struct

+ Burst int

+ KubeConfig string

+ Namespace string

+ QPS int

+ Timeout string

+ type ReadyCheckFunc func(r *http.Request) error

+ type ServerError interface

+ Code func() codes.Code

+ Error func() string

+ WithDetails func(details proto.Message) (ServerError, error)

+ func NewServerError(code codes.Code, message string) ServerError

+ func NewServerErrorFromStatus(status *status.Status) ServerError

+ func NewServerErrorf(code codes.Code, format string, a ...interface{}) ServerError

+ type SetupContext struct

+ BaseURL string

+ DB *sqlx.DB

+ DataStore *storage.DataStore

+ Host string

+ K8sCache cache.Cache

+ K8sClient client.WithWatch

+ K8sConfig *rest.Config

+ Middleware func(http.Handler) http.Handler

+ Mux *http.ServeMux

+ Namespace string

+ Port int

+ Scope promutils.Scope

+ func (sc *SetupContext) AddReadyCheck(fn ReadyCheckFunc)

+ func (sc *SetupContext) AddWorker(name string, fn WorkerFunc)

+ type WorkerFunc func(ctx context.Context) error