oauthtoken

type CacheAlert ¶

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

CacheAlert is a tokenLoadStorer that detects when a token's subject for a different cluster is changing, and produces a warning over an appropriate communication channel.

func (a *CacheAlert) Load(ctx context.Context, cluster string) (*oauth2.Token, error)

func (a *CacheAlert) Store(ctx context.Context, cluster string, token *oauth2.Token) error

type DebugPrint ¶

type DebugPrint struct{}

func (d *DebugPrint) Load(ctx context.Context, cluster string) (*oauth2.Token, error)

func (d *DebugPrint) Store(ctx context.Context, cluster string, token *oauth2.Token) error

type File ¶

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

func NewFile(path string) (*File, error)

func (f *File) Load(ctx context.Context, cluster string) (*oauth2.Token, error)

func (f *File) Store(ctx context.Context, cluster string, token *oauth2.Token) error

type FileContents ¶

type FileContents struct {
	Tokens map[string]*oauth2.Token `json:"tokens"`
}

type Keyring ¶

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

Keyring stores a JWT token on the user's keyring via the OS-specific keyring mechanism of the current platform.

func (f *Keyring) Load(ctx context.Context, cluster string) (*oauth2.Token, error)

func (f *Keyring) Store(ctx context.Context, cluster string, token *oauth2.Token) error

type LoadStorer ¶

type LoadStorer interface {
	Load(context.Context, string) (*oauth2.Token, error)
	Store(context.Context, string, *oauth2.Token) error
}

func NewCacheAlert(impl LoadStorer, stderr io.Writer) LoadStorer

func NewKeyring() (LoadStorer, error)