cache

Documentation

Index

• type ComposeRoleArn
• type Entry
• type FakeServiceAccountCache
  • func NewFakeServiceAccountCache(accounts ...*v1.ServiceAccount) *FakeServiceAccountCache
  • func (f *FakeServiceAccountCache) Add(name, namespace, role, aud string, regionalSTS bool, tokenExpiration int64)
  • func (f *FakeServiceAccountCache) Clear()
  • func (f *FakeServiceAccountCache) Get(req Request) Response
  • 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 Request
  • func (r Request) CacheKey() string
• type Response
• type ServiceAccountCache
  • func New(defaultAudience, prefix string, defaultRegionalSTS bool, ...) ServiceAccountCache

Types

type ComposeRoleArn

type ComposeRoleArn struct {
	Enabled bool

	AccountID string
	Partition string
	Region    string
}

type Entry

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

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) Clear

func (f *FakeServiceAccountCache) Clear()

func (*FakeServiceAccountCache) Get

func (f *FakeServiceAccountCache) Get(req Request) Response

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 Request

type Request struct {
	Name                string
	Namespace           string
	RequestNotification bool
}

func (Request) CacheKey

func (r Request) CacheKey() string

type Response

type Response struct {
	RoleARN         string
	Audience        string
	UseRegionalSTS  bool
	TokenExpiration int64
	FoundInCache    bool
	Notifier        <-chan struct{}
}

type ServiceAccountCache

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

func New

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