stores

type ClientInjector ¶

type ClientInjector interface {
	InjectClient(client.Client)
}

type EncryptedToken ¶ added in v0.3.0

type EncryptedToken struct {
	Secrets []EncryptedTokenSecret `json:"secrets"`
}

EncryptedToken is the JSON structure of an encrypted token.

type EncryptedTokenSecret ¶ added in v0.3.0

type EncryptedTokenSecret struct {
	Data string `json:"data"`
}

EncryptedTokenSecret is the JSON structure of an encrypted token secret.

type LogStore ¶

type LogStore struct {
	LogStoreSpec emcv1beta1.LogStoreSpec
	Client       client.Client
}

LogStore is a store that logs the token but does not store it anywhere Retreiving the token is thus not implemented

func NewLogStore(sts emcv1beta1.LogStoreSpec) *LogStore

func (ss *LogStore) StoreToken(ctx context.Context, ea emcv1beta1.EmergencyAccount, token string) (string, error)

type MinioClient ¶ added in v0.3.0

type MinioClient interface {
	PutObject(ctx context.Context, bucketName string, objectName string, reader io.Reader, objectSize int64, opts minio.PutObjectOptions) (info minio.UploadInfo, err error)
}

MinioClient partially implements the minio.Client interface.

func DefaultClientFactory(spec emcv1beta1.S3StoreSpec) (MinioClient, error)

type S3Store ¶ added in v0.3.0

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

func NewS3Store(spec emcv1beta1.S3StoreSpec) *S3Store

func NewS3StoreWithClientFactory(spec emcv1beta1.S3StoreSpec, minioClientFactory func(emcv1beta1.S3StoreSpec) (MinioClient, error)) *S3Store

func (ss *S3Store) StoreToken(ctx context.Context, ea emcv1beta1.EmergencyAccount, token string) (string, error)

type SecretStore ¶

type SecretStore struct {
	SecretStoreSpec emcv1beta1.SecretStoreSpec
	Client          client.Client
}

func NewSecretStore(sts emcv1beta1.SecretStoreSpec) *SecretStore

func (ss *SecretStore) InjectClient(c client.Client)

func (ss *SecretStore) RetrieveToken(ctx context.Context, ea emcv1beta1.EmergencyAccount, ref string) (string, error)

func (ss *SecretStore) StoreToken(ctx context.Context, ea emcv1beta1.EmergencyAccount, token string) (string, error)

type TokenRetriever ¶

type TokenRetriever interface {
	RetrieveToken(ctx context.Context, ea emcv1beta1.EmergencyAccount, ref string) (token string, err error)
}

type TokenStorer ¶

type TokenStorer interface {
	StoreToken(ctx context.Context, ea emcv1beta1.EmergencyAccount, token string) (ref string, err error)
}

func FromSpec(sts emcv1beta1.TokenStoreSpec) (TokenStorer, error)