ports

type AccountReader interface {
	Get(ctx context.Context, accountRef domain.NamespacedName) (account *v1alpha1.Account, err error)
}

type ConfigMapReader interface {
	Get(ctx context.Context, configMapRef domain.NamespacedName) (map[string]string, error)
}

type NatsClient interface {
	Connect(natsURL string, userCreds NatsUserCreds) (NatsConnection, error)
}

type NatsClusterReader interface {
	Get(ctx context.Context, clusterRef domain.NamespacedName) (*v1alpha1.NatsCluster, error)
}

type NatsConnection interface {
	Disconnect()
	EnsureConnected() error
	LookupAccountJWT(accountID string) (string, error)
	UploadAccountJWT(jwt string) error
	DeleteAccountJWT(jwt string) error
}

type NatsOperatorSigningKey nkeys.KeyPair

type NatsUserCreds struct {
	Creds     []byte
	AccountID string
}

type SecretClient interface {
	SecretReader
	Apply(ctx context.Context, owner metav1.Object, meta metav1.ObjectMeta, valueMap map[string]string) error
	Delete(ctx context.Context, secretRef domain.NamespacedName) error
	DeleteByLabels(ctx context.Context, namespace domain.Namespace, labels map[string]string) error
	Label(ctx context.Context, secretRef domain.NamespacedName, labels map[string]string) error
}

type SecretReader interface {
	Get(ctx context.Context, secretRef domain.NamespacedName) (map[string]string, error)
	GetByLabels(ctx context.Context, namespace domain.Namespace, labels map[string]string) (*v1.SecretList, error)
}