connection

type Adapter interface {
	Kind() Kind
	ParseConnectionString([]byte) (ParsedConnection, error)
}

type AdapterResolver interface {
	Resolve(Kind) (Adapter, error)
}

type CleanupWarning func(databaseID ID, category string)

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

type Definition struct {
	ID         ID                          `json:"id"`
	Kind       Kind                        `json:"kind"`
	Settings   map[string]string           `json:"settings"`
	SecretRefs map[string]secret.Reference `json:"secretRefs"`
}

type DefinitionRegistrar interface {
	Register(Definition) (RegistrationResult, error)
}

type DefinitionRepository interface {
	Lookup(context.Context, ID) (Definition, error)
	Upsert(context.Context, Definition) error
}

type ID string

type ImportRequest struct {
	ID               ID
	Kind             Kind
	ConnectionString []byte
}

type ImportResult struct {
	ID                 ID
	IsUpdated          bool
	IsConnectionTested bool
}

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

type ImporterDependencies struct {
	Adapters    AdapterResolver
	Secrets     SecretWriter
	Definitions DefinitionRepository
	Registrar   DefinitionRegistrar
	Warn        CleanupWarning
}

type Kind string

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

type ParsedConnection struct {
	Settings map[string]string
	Secrets  map[string][]byte
}

type RegistrationResult struct {
	Previous Definition
	Replaced bool
}

type ResolvedDefinition struct {
	ID       ID
	Kind     Kind
	Settings map[string]string
	Secrets  map[string][]byte
}

type SecretResolver interface {
	Resolve(context.Context, secret.Reference) ([]byte, error)
}

type SecretWriter interface {
	Store(context.Context, []byte) (secret.Reference, error)
	Delete(context.Context, secret.Reference) error
}