tokenstorage

Documentation

Index

• type NotifyingTokenStorage
  • func (n NotifyingTokenStorage) Delete(ctx context.Context, owner *api.SPIAccessToken) error
  • func (n NotifyingTokenStorage) Get(ctx context.Context, owner *api.SPIAccessToken) (*api.Token, error)
  • func (n NotifyingTokenStorage) Store(ctx context.Context, owner *api.SPIAccessToken, token *api.Token) error
• type TestTokenStorage
  • func (t TestTokenStorage) Delete(ctx context.Context, owner *api.SPIAccessToken) error
  • func (t TestTokenStorage) Get(ctx context.Context, owner *api.SPIAccessToken) (*api.Token, error)
  • func (t TestTokenStorage) Store(ctx context.Context, owner *api.SPIAccessToken, token *api.Token) error
• type TokenStorage
  • func CreateTestVaultTokenStorage(t vtesting.T) (*vault.TestCluster, TokenStorage)
  • func NewSecretsStorage(cl client.Client) (TokenStorage, error)
  • func NewVaultStorage(role string, vaultHost string, serviceAccountToken string) (TokenStorage, error)

Types

type NotifyingTokenStorage

type NotifyingTokenStorage struct {
	// Client is the kubernetes client to use to create the v1beta1.SPIAccessTokenDataUpdate objects.
	Client client.Client

	// TokenStorage is the token storage to delegate the actual storage operations to.
	TokenStorage TokenStorage
}

NotifyingTokenStorage is a wrapper around TokenStorage that also automatically creates the v1beta1.SPIAccessTokenDataUpdate objects.

func (NotifyingTokenStorage) Delete

func (n NotifyingTokenStorage) Delete(ctx context.Context, owner *api.SPIAccessToken) error

func (NotifyingTokenStorage) Get

func (n NotifyingTokenStorage) Get(ctx context.Context, owner *api.SPIAccessToken) (*api.Token, error)

func (NotifyingTokenStorage) Store

func (n NotifyingTokenStorage) Store(ctx context.Context, owner *api.SPIAccessToken, token *api.Token) error

type TestTokenStorage

type TestTokenStorage struct {
	StoreImpl  func(context.Context, *api.SPIAccessToken, *api.Token) error
	GetImpl    func(ctx context.Context, token *api.SPIAccessToken) (*api.Token, error)
	DeleteImpl func(context.Context, *api.SPIAccessToken) error
}

func (TestTokenStorage) Delete

func (t TestTokenStorage) Delete(ctx context.Context, owner *api.SPIAccessToken) error

func (TestTokenStorage) Get

func (t TestTokenStorage) Get(ctx context.Context, owner *api.SPIAccessToken) (*api.Token, error)

func (TestTokenStorage) Store

func (t TestTokenStorage) Store(ctx context.Context, owner *api.SPIAccessToken, token *api.Token) error

type TokenStorage

type TokenStorage interface {
	Store(ctx context.Context, owner *api.SPIAccessToken, token *api.Token) error
	Get(ctx context.Context, owner *api.SPIAccessToken) (*api.Token, error)
	Delete(ctx context.Context, owner *api.SPIAccessToken) error
}

TokenStorage is a simple interface on top of Kubernetes client to perform CRUD operations on the tokens. This is done so that we can provide either secret-based or Vault-based implementation.

func CreateTestVaultTokenStorage

func CreateTestVaultTokenStorage(t vtesting.T) (*vault.TestCluster, TokenStorage)

func NewSecretsStorage

func NewSecretsStorage(cl client.Client) (TokenStorage, error)

NewSecretsStorage creates a new `TokenStorage` instance using the provided Kubernetes client.

func NewVaultStorage

func NewVaultStorage(role string, vaultHost string, serviceAccountToken string) (TokenStorage, error)

NewVaultStorage creates a new `TokenStorage` instance using the provided Vault instance.