repo

type AttrsOrig map[string][]string

type CacheAttrsNorm map[string][]interface{}

type CacheAttrsOrig map[string][]string

type CacheEntry struct {
	ID          int64   `reindex:"id,,pk" json:"id"`
	Version     int64   `reindex:"rev" json:"rev"`
	ParentID    int64   `reindex:"parentId" json:"parentId"`
	Path        []int64 `reindex:"path,tree" json:"path"`
	IsContainer bool    `reindex:"isContainer" json:"isContainer"`
	RDNNorm     string  `reindex:"rdnNorm" json:"rdnNorm"`
	RDNOrig     string  `reindex:"-" json:"rdnOrig"`
	AttrsNorm   struct {
	} `reindex:"attrsNorm" json:"attrsNorm"`
	AttrsOrig CacheAttrsOrig `reindex:"-" json:"attrsOrig"`
	Dummy     string         `reindex:"dummy" json:"-"`
}

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

type DBAttrsNorm = map[string][]string

type DBEntry struct {
	ID           int64               `db:"id"`
	Version      int64               `db:"rev"`
	ParentID     int64               `db:"parent_id"`
	Path         pq.Int64Array       `db:"path"`
	IsContainer  bool                `db:"is_container"`
	RDNNorm      string              `db:"rdn_norm"`
	RDNOrig      string              `db:"rdn_orig"`
	AttrsOrig    types.JSONText      `db:"attrs_orig"`
	AttrsOrigMap map[string][]string `db:"-"` // for cache

}

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

type DBRepositoryConfig struct {
	DBHostName     string
	DBPort         int
	DBUser         string
	DBPassword     string
	DBSchema       string
	DBName         string
	DBMaxOpenConns int
	DBMaxIdleConns int
	ServerID       string
	LogLevel       string
}

type DefaultRepository struct {
	*DBRepository
}

type FetchedCredential struct {
	ID int64
	// Credential
	Credential []string
	// DN of the MemberOf
	MemberOf []*schema.DN
	// PPolicy related to this entry
	PPolicy              *schema.PPolicy
	PwdAccountLockedTime *time.Time
	LastPwdFailureTime   *time.Time
	PwdFailureCount      int
}

type FetchedDNOrig struct {
	ID     int64  `db:"id"`
	DNOrig string `db:"dn_orig"`
}

type FilterContext struct {
	context.Context
	// contains filtered or unexported fields
}

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

type ModOperation struct {
	Add     []string
	Replace []string
	Delete  []string
}

type NotifyMessage struct {
	Issuer      string   `json:"iss"`
	ID          int64    `json:"id"`
	Op          NotifyOp `json:"op"`
	Rev         int64    `json:"rev"`
	Association bool     `json:"asc"`
	Dependant   []int64  `json:"dep"`
	Sub         bool     `json:"sub"`
}

type NotifyOp string

type RDNCache struct {
	ID       int64  `json:"id"`
	ParentID int64  `json:"parentId"`
	RDNOrig  string `json:"rdnOrig"`
}

type Repository interface {
	// Init is called when initializing repository implementation.
	Init() error

	// Bind fetches the current bind entry by specified DN. Then execute callback with the entry.
	// The callback is expected checking the credential, account lock status and so on.
	// This is used for BIND operation.
	Bind(ctx context.Context, dn *schema.DN, callback func(current *FetchedCredential) error) error

	// FindPPolicyByDN returns the password policy entry by specified DN.
	// This is used for password policy process.
	FindPPolicyByDN(ctx context.Context, dn *schema.DN) (*schema.PPolicy, error)

	// Search handles search request by filter.
	// This is used for SEARCH operation.
	Search(ctx context.Context, baseDN *schema.DN, option *SearchOption, handler func(entry *SearchEntry) error) (int32, int32, error)

	// Update modifies the entry by specified change data.
	// This is used for MOD operation.
	Update(ctx context.Context, dn *schema.DN, callback func(attrsOrig AttrsOrig) (*Changelog, error)) error

	// Association resolves the association related attributes in the attributes.
	// This is used for MOD operation.
	Association(ctx context.Context, sv *schema.SchemaValue) (*schema.SchemaValue, error)

	// UpdateRDN modifies the entry DN by specified change data.
	// This is used for MODRDN operation.
	UpdateDN(ctx context.Context, oldDN, newDN *schema.DN, oldRDN *schema.RelativeDN, callback func(attrsOrig AttrsOrig) (*Changelog, error)) error

	// Insert creates the entry by specified entry data.
	Insert(ctx context.Context, entry *Changelog) (int64, error)

	// DeleteByDN deletes the entry by specified DN.
	DeleteByDN(ctx context.Context, dn *schema.DN) error

	OnUpdate(ctx context.Context, m *NotifyMessage) error
}

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

type SearchOption struct {
	Scope                      int
	Filter                     message.Filter
	PageSize                   int32
	Offset                     int32
	RequestedAssocation        []string
	IsMemberOfRequested        bool
	IsHasSubordinatesRequested bool
}

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