dbuser

Documentation

Index

• Variables
• func DiffSpecs(a, b *User) string
• func EqualSpecs(spec, atlas *User) bool
• type AtlasUsers
  • func NewAtlasDatabaseUsersService(ctx context.Context, provider atlas.Provider, secretRef *types.NamespacedName, ...) (*AtlasUsers, error)
  • func NewAtlasUsers(api admin.DatabaseUsersApi) *AtlasUsers
  • func (dus *AtlasUsers) Create(ctx context.Context, au *User) error
  • func (dus *AtlasUsers) Delete(ctx context.Context, db, projectID, username string) error
  • func (dus *AtlasUsers) Get(ctx context.Context, db, projectID, username string) (*User, error)
  • func (dus *AtlasUsers) Update(ctx context.Context, au *User) error
• type AtlasUsersService
• type User
  • func NewUser(spec *akov2.AtlasDatabaseUserSpec, projectID, password string) (*User, error)

Variables

var (
	// ErrorNotFound is returned when an database user was not found
	ErrorNotFound = errors.New("database user not found")
)

Functions

func DiffSpecs

func DiffSpecs(a, b *User) string

func EqualSpecs

func EqualSpecs(spec, atlas *User) bool

EqualSpecs returns true if the given users have the same specs

Types

type AtlasUsers

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

func NewAtlasDatabaseUsersService

func NewAtlasDatabaseUsersService(ctx context.Context, provider atlas.Provider, secretRef *types.NamespacedName, log *zap.SugaredLogger) (*AtlasUsers, error)

func NewAtlasUsers

func NewAtlasUsers(api admin.DatabaseUsersApi) *AtlasUsers

func (*AtlasUsers) Create

func (dus *AtlasUsers) Create(ctx context.Context, au *User) error

func (*AtlasUsers) Delete

func (dus *AtlasUsers) Delete(ctx context.Context, db, projectID, username string) error

func (*AtlasUsers) Get

func (dus *AtlasUsers) Get(ctx context.Context, db, projectID, username string) (*User, error)

func (*AtlasUsers) Update

func (dus *AtlasUsers) Update(ctx context.Context, au *User) error

type AtlasUsersService

type AtlasUsersService interface {
	Get(ctx context.Context, db, projectID, username string) (*User, error)
	Delete(ctx context.Context, db, projectID, username string) error
	Create(ctx context.Context, au *User) error
	Update(ctx context.Context, au *User) error
}

type User

type User struct {
	*akov2.AtlasDatabaseUserSpec
	Password  string
	ProjectID string
}

func NewUser

func NewUser(spec *akov2.AtlasDatabaseUserSpec, projectID, password string) (*User, error)

NewUser wraps and normalizes a Kubernetes Atlas User Spec pointer augmenting it with projectID and password.