cni

Documentation

Index

• func BuildClientSet() (*kubernetes.Clientset, error)
• func CNIServiceAccountName() string
• func NamespaceOfUsedServiceAccount() string
• func Run()
• type TokenRefresher
  • func NewTokenRefresher(clientset *kubernetes.Clientset, namespace string, serviceAccountName string) *TokenRefresher
  • func NewTokenRefresherWithCustomTiming(clientset *kubernetes.Clientset, namespace string, serviceAccountName string, ...) *TokenRefresher
  • func (t *TokenRefresher) Run()
  • func (t *TokenRefresher) Stop()
  • func (t *TokenRefresher) TokenChan() <-chan TokenUpdate
  • func (t *TokenRefresher) UpdateToken() (TokenUpdate, error)
• type TokenUpdate

Functions

func BuildClientSet

func BuildClientSet() (*kubernetes.Clientset, error)

func CNIServiceAccountName

func CNIServiceAccountName() string

CNIServiceAccountName returns the name of the serviceaccount to use for the CNI plugin token request. This can be set via the CALICO_CNI_SERVICE_ACCOUNT environment variable, and defaults to "calico-cni-plugin" otherwise.

func NamespaceOfUsedServiceAccount

func NamespaceOfUsedServiceAccount() string

func Run

func Run()

Types

type TokenRefresher

type TokenRefresher struct {
	// contains filtered or unexported fields
}

func NewTokenRefresher

func NewTokenRefresher(clientset *kubernetes.Clientset, namespace string, serviceAccountName string) *TokenRefresher

func NewTokenRefresherWithCustomTiming

func NewTokenRefresherWithCustomTiming(clientset *kubernetes.Clientset, namespace string, serviceAccountName string, tokenValiditySeconds int64, minTokenRetryDuration time.Duration, defaultRefreshFraction time.Duration) *TokenRefresher

func (*TokenRefresher) Run

func (t *TokenRefresher) Run()

func (*TokenRefresher) Stop

func (t *TokenRefresher) Stop()

func (*TokenRefresher) TokenChan

func (t *TokenRefresher) TokenChan() <-chan TokenUpdate

func (*TokenRefresher) UpdateToken

func (t *TokenRefresher) UpdateToken() (TokenUpdate, error)

type TokenUpdate

type TokenUpdate struct {
	Token          string
	ExpirationTime time.Time
}