service

Documentation

Index

• func WithNamespace(namespace string) func(*AccountManager)
• type AccountManager
  • func NewAccountManager(accounts ports.AccountGetter, natsClient ports.NATSClient, ...) *AccountManager
  • func (a *AccountManager) CreateAccount(ctx context.Context, state *natsv1alpha1.Account) error
  • func (a *AccountManager) DeleteAccount(ctx context.Context, state *natsv1alpha1.Account) error
  • func (a *AccountManager) ImportAccount(ctx context.Context, state *natsv1alpha1.Account) error
  • func (a *AccountManager) UpdateAccount(ctx context.Context, state *natsv1alpha1.Account) error
• type UserManager
  • func NewUserManager(accounts ports.AccountGetter, secretStorer ports.SecretStorer) *UserManager
  • func (u *UserManager) CreateOrUpdateUser(ctx context.Context, state *v1alpha1.User) error
  • func (u *UserManager) DeleteUser(ctx context.Context, state *v1alpha1.User) error

Functions

func WithNamespace

func WithNamespace(namespace string) func(*AccountManager)

Types

type AccountManager

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

func NewAccountManager

func NewAccountManager(accounts ports.AccountGetter, natsClient ports.NATSClient, secretStorer ports.SecretStorer, opts ...func(*AccountManager)) *AccountManager

func (*AccountManager) CreateAccount

func (a *AccountManager) CreateAccount(ctx context.Context, state *natsv1alpha1.Account) error

func (*AccountManager) DeleteAccount

func (a *AccountManager) DeleteAccount(ctx context.Context, state *natsv1alpha1.Account) error

func (*AccountManager) ImportAccount

func (a *AccountManager) ImportAccount(ctx context.Context, state *natsv1alpha1.Account) error

func (*AccountManager) UpdateAccount

func (a *AccountManager) UpdateAccount(ctx context.Context, state *natsv1alpha1.Account) error

type UserManager

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

func NewUserManager

func NewUserManager(accounts ports.AccountGetter, secretStorer ports.SecretStorer) *UserManager

func (*UserManager) CreateOrUpdateUser

func (u *UserManager) CreateOrUpdateUser(ctx context.Context, state *v1alpha1.User) error

func (*UserManager) DeleteUser

func (u *UserManager) DeleteUser(ctx context.Context, state *v1alpha1.User) error