k8s

Documentation

Index

• Constants
• Variables
• type AccountClient
  • func NewAccountClient(client client.Client) *AccountClient
  • func (a *AccountClient) Get(ctx context.Context, accountRef domain.NamespacedName) (account *v1alpha1.Account, err error)
• type NatsClusterClient
  • func NewNatsClusterClient(reader client.Reader) *NatsClusterClient
  • func (c *NatsClusterClient) Get(ctx context.Context, clusterRef domain.NamespacedName) (*v1alpha1.NatsCluster, error)

Constants

const (
	LabelAccountID                    = "account.nauth.io/id"
	LabelAccountName                  = "account.nauth.io/name"
	LabelAccountSignedBy              = "account.nauth.io/signed-by"
	LabelUserID                       = "user.nauth.io/id"
	LabelUserAccountID                = "user.nauth.io/account-id"
	LabelUserSignedBy                 = "user.nauth.io/signed-by"
	LabelSecretType                   = "nauth.io/secret-type"
	LabelManaged                      = "nauth.io/managed"
	LabelManagedValue                 = "true"
	LabelManagementPolicy             = "nauth.io/management-policy"
	LabelManagementPolicyObserveValue = "observe"
)

const (
	DeprecatedSecretNameAccountRootTemplate = "%s-ac-root"
	DeprecatedSecretNameAccountSignTemplate = "%s-ac-sign"
)

const (
	SecretTypeAccountRoot            = "account-root"
	SecretTypeAccountSign            = "account-sign"
	SecretTypeOperatorSign           = "operator-sign"
	SecretTypeSystemAccountUserCreds = "system-account-user-creds"
	SecretTypeUserCredentials        = "user-creds"
	DefaultSecretKeyName             = "default"
	UserCredentialSecretKeyName      = "user.creds"
)

Variables

var (
	ErrNoAccountFound  = errors.New("no account found")
	ErrAccountNotReady = errors.New("account is not ready")
	ErrNotFound        = errors.New("not found")
)

Types

type AccountClient

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

func NewAccountClient

func NewAccountClient(client client.Client) *AccountClient

func (*AccountClient) Get

func (a *AccountClient) Get(ctx context.Context, accountRef domain.NamespacedName) (account *v1alpha1.Account, err error)

Get the referenced Account Requires the account to be reconciled and ready

type NatsClusterClient

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

func NewNatsClusterClient

func NewNatsClusterClient(reader client.Reader) *NatsClusterClient

func (*NatsClusterClient) Get

func (c *NatsClusterClient) Get(ctx context.Context, clusterRef domain.NamespacedName) (*v1alpha1.NatsCluster, error)