func NewSecretInCluster()

in pkg/k8s/secret.go [26:43]


func NewSecretInCluster(stateConfig *config.StateConfig) (Secret, error) {
	config, err := rest.InClusterConfig()
	if err != nil {
		return nil, err
	}
	k8sClient, err := kubernetes.NewForConfig(config)
	if err != nil {
		return nil, err
	}
	podIndexProvider := NewPodIndexProvider()
	podIndex, err := podIndexProvider.Get()
	if err != nil {
		return nil, err
	}
	secretName := fmt.Sprintf("%s-%s", stateConfig.SecretNamePrefix, podIndex)

	return NewSecret(secretName, stateConfig.SecretNamespace, k8sClient), nil
}