cache

Documentation

Index

• type CacheResponse
• type ComposeRoleArn
• type FakeServiceAccountCache
  • func NewFakeServiceAccountCache(accounts ...*v1.ServiceAccount) *FakeServiceAccountCache
  • func (f *FakeServiceAccountCache) Add(name, namespace, role, aud string, regionalSTS bool, tokenExpiration int64)
  • func (f *FakeServiceAccountCache) Get(name, namespace string) (role, aud string, useRegionalSTS bool, tokenExpiration int64)
  • func (f *FakeServiceAccountCache) GetCommonConfigurations(name, namespace string) (useRegionalSTS bool, tokenExpiration int64)
  • func (f *FakeServiceAccountCache) Pop(name, namespace string)
  • func (f *FakeServiceAccountCache) Start(chan struct{})
  • func (f *FakeServiceAccountCache) ToJSON() string
• type ServiceAccountCache
  • func New(defaultAudience, prefix string, defaultRegionalSTS bool, ...) ServiceAccountCache

Types

type CacheResponse

type CacheResponse struct {
	RoleARN         string
	Audience        string
	UseRegionalSTS  bool
	TokenExpiration int64
}

type ComposeRoleArn

type ComposeRoleArn struct {
	Enabled bool

	AccountID string
	Partition string
	Region    string
}

type FakeServiceAccountCache

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

FakeServiceAccountCache is a goroutine safe cache for testing

func NewFakeServiceAccountCache

func NewFakeServiceAccountCache(accounts ...*v1.ServiceAccount) *FakeServiceAccountCache

func (*FakeServiceAccountCache) Add

func (f *FakeServiceAccountCache) Add(name, namespace, role, aud string, regionalSTS bool, tokenExpiration int64)

Add adds a cache entry

func (*FakeServiceAccountCache) Get

func (f *FakeServiceAccountCache) Get(name, namespace string) (role, aud string, useRegionalSTS bool, tokenExpiration int64)

Get gets a service account from the cache

func (*FakeServiceAccountCache) GetCommonConfigurations

func (f *FakeServiceAccountCache) GetCommonConfigurations(name, namespace string) (useRegionalSTS bool, tokenExpiration int64)

func (*FakeServiceAccountCache) Pop

func (f *FakeServiceAccountCache) Pop(name, namespace string)

Pop deletes a cache entry

func (*FakeServiceAccountCache) Start

func (f *FakeServiceAccountCache) Start(chan struct{})

Start does nothing

func (*FakeServiceAccountCache) ToJSON

func (f *FakeServiceAccountCache) ToJSON() string

type ServiceAccountCache

type ServiceAccountCache interface {
	Start(stop chan struct{})
	Get(name, namespace string) (role, aud string, useRegionalSTS bool, tokenExpiration int64)
	GetCommonConfigurations(name, namespace string) (useRegionalSTS bool, tokenExpiration int64)
	// ToJSON returns cache contents as JSON string
	ToJSON() string
}

func New

func New(defaultAudience, prefix string, defaultRegionalSTS bool, defaultTokenExpiration int64, saInformer coreinformers.ServiceAccountInformer, cmInformer coreinformers.ConfigMapInformer, composeRoleArn ComposeRoleArn) ServiceAccountCache