kubernetes

Mar 6, 2024

Changes in this version

+ type UpgradeOption func(*UpgradeOptions)

+ func WithRetry(maxRetries int, retryInterval time.Duration) UpgradeOption

+ type UpgradeOptions struct

+ MaxRetries int

+ RetryInterval time.Duration

+ WithRetry bool

Oct 12, 2023

Changes in this version

+ func Stop(runFilePath string, config runfileconfig.RunFileConfig) error

type InitConfiguration

+ EnableDev bool

Jun 10, 2023

Changes in this version

+ func IsDashboardIncluded(runtimeVersion string) (bool, error)

type InitConfiguration

+ DashboardVersion string

+ IssuerCertificateFilePath string

+ IssuerPrivateKeyFilePath string

+ RootCertificateFilePath string

type UpgradeConfig

+ DashboardVersion string

Feb 15, 2023

Changes in this version

type RenewCertificateParams

+ ImageVariant string

Oct 13, 2022

Changes in this version

type InitConfiguration

+ ImageVariant string

type UpgradeConfig

+ ImageVariant string

Jul 5, 2022

Changes in this version

+ func GetDaprControlPlaneCurrentConfig() (*v1alpha1.Configuration, error)

+ func GetDaprNamespace() (string, error)

+ func GetImageRegistry() (string, error)

+ type AnnotateOptions struct

+ func NewAnnotateOptions(opts ...AnnoteOption) AnnotateOptions

+ type Annotator interface

+ Annotate func(io.Reader, io.Writer) error

+ type AnnoteOption func(*AnnotateOptions)

+ func WithAPITokenSecret(apiTokenSecret string) AnnoteOption

+ func WithAppID(appID string) AnnoteOption

+ func WithAppMaxConcurrency(maxConcurrency int) AnnoteOption

+ func WithAppPort(port int) AnnoteOption

+ func WithAppProtocol(protocol string) AnnoteOption

+ func WithAppSSL() AnnoteOption

+ func WithAppTokenSecret(appTokenSecret string) AnnoteOption

+ func WithCPULimit(cpuLimit string) AnnoteOption

+ func WithCPURequest(cpuRequest string) AnnoteOption

+ func WithConfig(cfg string) AnnoteOption

+ func WithDaprImage(image string) AnnoteOption

+ func WithDebugEnabled() AnnoteOption

+ func WithDebugPort(debugPort int) AnnoteOption

+ func WithDisableBuiltinK8sSecretStore() AnnoteOption

+ func WithEnableAPILogging() AnnoteOption

+ func WithEnv(env string) AnnoteOption

+ func WithGracefulShutdownSeconds(gracefulShutdownSeconds int) AnnoteOption

+ func WithHTTPStreamRequestBody() AnnoteOption

+ func WithListenAddresses(listenAddresses string) AnnoteOption

+ func WithLivenessProbeDelay(livenessProbeDelay int) AnnoteOption

+ func WithLivenessProbePeriod(livenessProbePeriod int) AnnoteOption

+ func WithLivenessProbeThreshold(livenessProbeThreshold int) AnnoteOption

+ func WithLivenessProbeTimeout(livenessProbeTimeout int) AnnoteOption

+ func WithLogAsJSON() AnnoteOption

+ func WithLogLevel(logLevel string) AnnoteOption

+ func WithMaxRequestBodySize(maxRequestBodySize int) AnnoteOption

+ func WithMemoryLimit(memoryLimit string) AnnoteOption

+ func WithMemoryRequest(memoryRequest string) AnnoteOption

+ func WithMetricsEnabled() AnnoteOption

+ func WithMetricsPort(port int) AnnoteOption

+ func WithPlacementHostAddress(placementHostAddress string) AnnoteOption

+ func WithProfileEnabled() AnnoteOption

+ func WithReadBufferSize(readBufferSize int) AnnoteOption

+ func WithReadinessProbeDelay(readinessProbeDelay int) AnnoteOption

+ func WithReadinessProbePeriod(readinessProbePeriod int) AnnoteOption

+ func WithReadinessProbeThreshold(readinessProbeThreshold int) AnnoteOption

+ func WithReadinessProbeTimeout(readinessProbeTimeout int) AnnoteOption

+ func WithUnixDomainSocketPath(unixDomainSocketPath string) AnnoteOption

+ func WithVolumeMountsReadOnly(volumeMountsReadOnly string) AnnoteOption

+ func WithVolumeMountsReadWrite(volumeMountsReadWrite string) AnnoteOption

type InitConfiguration

+ ImageRegistryURI string

+ type K8sAnnotator struct

+ func NewK8sAnnotator(config K8sAnnotatorConfig) *K8sAnnotator

+ func (p *K8sAnnotator) Annotate(inputs []io.Reader, out io.Writer, opts AnnotateOptions) error

+ type K8sAnnotatorConfig struct

+ TargetNamespace *string

+ TargetResource *string

+ type NamespacedObject interface

+ GetNamespace func() string

type UpgradeConfig

+ ImageRegistryURI string

Apr 7, 2022

Changes in this version

+ func CheckForCertExpiry()

+ func GenerateNewCertificates(validUntil time.Duration, privateKeyFile string) ([]byte, []byte, []byte, error)

+ func GetDaprHelmChartName(helmConf *helm.Configuration) (string, error)

+ func GetDaprVersion(status []StatusOutput) string

+ func RenewCertificate(conf RenewCertificateParams) error

type ComponentsOutput

+ Namespace string

type ListOutput

+ Namespace string

+ type RenewCertificateParams struct

+ IssuerCertificateFilePath string

+ IssuerPrivateKeyFilePath string

+ RootCertificateFilePath string

+ RootPrivateKeyFilePath string

+ Timeout uint

+ ValidUntil time.Duration

type StatusOutput

+ func GetDaprResourcesStatus() ([]StatusOutput, error)

Mar 22, 2021

Changes in this version

type InitConfiguration

+ Timeout uint

+ Wait bool

type UpgradeConfig

+ Timeout uint

Feb 15, 2021

Changes in this version

+ func PrintComponents(name, outputFormat string) error

+ func PrintConfigurations(name, outputFormat string) error

+ func Upgrade(conf UpgradeConfig) error

type ComponentsOutput

+ Scopes string

+ Version string

type InitConfiguration

+ Args []string

+ type UpgradeConfig struct

+ Args []string

+ RuntimeVersion string

Sep 30, 2020

Changes in this version

+ func ListPodsInterface(client k8s.Interface, labelSelector map[string]string) (*core_v1.PodList, error)

+ type StatusClient struct

+ func NewStatusClient() (*StatusClient, error)

+ func (s *StatusClient) Status() ([]StatusOutput, error)

type StatusOutput

+ Replicas int

Aug 18, 2020

Changes in this version

+ func Expiry() (*time.Time, error)

+ func ExportTrustChain(outputDir string) error

+ type InitConfiguration struct

+ EnableHA bool

+ EnableMTLS bool

+ Namespace string

+ Version string

Jul 14, 2020

Changes in this version

+ func CheckPodExists(client *k8s.Clientset, namespace string, labelSelector map[string]string, ...) (bool, string)

+ func GetKubeConfigClient() (*rest.Config, *k8s.Clientset, error)

+ type PortForward struct

+ Config *rest.Config

+ EmitLogs bool

+ Host string

+ LocalPort int

+ Method string

+ ReadyCh chan struct{}

+ RemotePort int

+ StopCh chan struct{}

+ URL *url.URL

+ func NewPortForward(config *rest.Config, namespace, deployName string, host string, ...) (*PortForward, error)

+ func (pf *PortForward) GetStop() <-chan struct{}

+ func (pf *PortForward) Init() error

+ func (pf *PortForward) Stop()

Apr 25, 2020

Changes in this version

+ func ListPods(client *k8s.Clientset, namespace string, labelSelector map[string]string) (*core_v1.PodList, error)

+ type StatusOutput struct

+ Age string

+ Created string

+ Healthy string

+ Name string

+ Namespace string

+ Status string

+ Version string

+ func Status() ([]StatusOutput, error)

Feb 14, 2020

Changes in this version

+ func GetDefaultConfiguration() v1alpha1.Configuration

Feb 11, 2020

Changes in this version

+ func DaprClient() (scheme.Interface, error)

+ func IsMTLSEnabled() (bool, error)

+ func Logs(appID, podName, namespace string) error

+ type ComponentsOutput struct

+ Age string

+ Created string

+ Name string

+ Type string

+ func Components() ([]ComponentsOutput, error)

+ type ConfigurtionsOutput struct

+ Age string

+ ClockSkew string

+ Created string

+ MTLSEnabled bool

+ Name string

+ TracingEnabled bool

+ WorkloadCertTTL string

+ func Configurations() ([]ConfigurtionsOutput, error)

Oct 16, 2019

Changes in this version

+ func Client() (*k8s.Clientset, error)

+ func Init() error

+ func Uninstall() error

+ type ListOutput struct

+ Age string

+ AppID string

+ AppPort string

+ Created string

+ func List() ([]ListOutput, error)

+ type RunConfig struct

+ AppID string

+ AppPort int

+ Arguments []string

+ CodeDirectory string

+ GRPCPort int

+ HTTPPort int

+ Image string

+ type RunOutput struct

+ Message string

+ func Run(config *RunConfig) (*RunOutput, error)