embedded

package

v0.4.0 Latest Latest Go to latest Published: Aug 13, 2023 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/zebox/registry-admin

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Embedded
- func NewEmbedded(pathToDB string) *Embedded

Constants ¶

This section is empty.

Variables ¶

View Source

var (

	// ErrRequiredFieldInGroupIsEmpty report about group name shouldn't be empty
	ErrRequiredFieldInGroupIsEmpty = errors.New("empty group name not allowed")

	// ErrFailedToCreateGroup report about error when group creating
	ErrFailedToCreateGroup = errors.New("failed to create new group")
)

View Source

var (
	// ErrTableAlreadyExist for indicate table already exist error
	ErrTableAlreadyExist = errors.New("table already exist or has an error")
)

Functions ¶

This section is empty.

Types ¶

type Embedded ¶

type Embedded struct {
	Path string `json:"path"`
	// contains filtered or unexported fields
}

Embedded implement internal data storage for users, access, group and repositories

func NewEmbedded ¶

func NewEmbedded(pathToDB string) *Embedded

NewEmbedded builder for create new instance of embedded storage

func (*Embedded) AccessGarbageCollector ¶

func (e *Embedded) AccessGarbageCollector(ctx context.Context) error

AccessGarbageCollector check outdated repositories in repositories table and delete ones from access list

func (*Embedded) Close ¶

func (e *Embedded) Close(_ context.Context) error

Close exposed closed method for embedded storage instance

func (*Embedded) Connect ¶

func (e *Embedded) Connect(ctx context.Context) (err error)

Connect init connection to embedded storage instance

func (*Embedded) CreateAccess ¶

func (e *Embedded) CreateAccess(ctx context.Context, access *store.Access) (err error)

CreateAccess create a new user access record

func (*Embedded) CreateGroup ¶

func (e *Embedded) CreateGroup(ctx context.Context, group *store.Group) (err error)

CreateGroup create a new group record

func (*Embedded) CreateRepository ¶

func (e *Embedded) CreateRepository(ctx context.Context, entry *store.RegistryEntry) (err error)

CreateRepository create a new repository record

func (*Embedded) CreateUser ¶

func (e *Embedded) CreateUser(ctx context.Context, user *store.User) (err error)

CreateUser create a new user record

func (*Embedded) DeleteAccess ¶

func (e *Embedded) DeleteAccess(ctx context.Context, key string, id interface{}) (err error)

DeleteAccess delete access record by ID

func (*Embedded) DeleteGroup ¶

func (e *Embedded) DeleteGroup(ctx context.Context, id int64) (err error)

DeleteGroup delete users group record by ID

func (*Embedded) DeleteRepository ¶

func (e *Embedded) DeleteRepository(ctx context.Context, repositoryName, digest string) (err error)

DeleteRepository delete repository entry by ID

func (*Embedded) DeleteUser ¶

func (e *Embedded) DeleteUser(ctx context.Context, id int64) (err error)

DeleteUser delete user record by ID

func (*Embedded) FindAccesses ¶

func (e *Embedded) FindAccesses(ctx context.Context, filter engine.QueryFilter) (accesses engine.ListResponse, err error)

FindAccesses get list of existed users access

func (*Embedded) FindGroups ¶

func (e *Embedded) FindGroups(ctx context.Context, filter engine.QueryFilter) (groups engine.ListResponse, err error)

FindGroups fetch list of existed group

func (*Embedded) FindRepositories ¶

func (e *Embedded) FindRepositories(ctx context.Context, filter engine.QueryFilter) (entries engine.ListResponse, err error)

FindRepositories fetch list of existed repositories

func (*Embedded) FindUsers ¶

func (e *Embedded) FindUsers(ctx context.Context, filter engine.QueryFilter, withPassword bool) (users engine.ListResponse, err error)

FindUsers fetch list of user by filter values

func (*Embedded) GetAccess ¶

func (e *Embedded) GetAccess(ctx context.Context, id int64) (access store.Access, err error)

GetAccess get data of access entry by ID

func (*Embedded) GetGroup ¶

func (e *Embedded) GetGroup(ctx context.Context, groupID int64) (group store.Group, err error)

GetGroup get data by group ID

func (*Embedded) GetRepository ¶

func (e *Embedded) GetRepository(ctx context.Context, entryID int64) (entry store.RegistryEntry, err error)

GetRepository get repository data by ID

func (*Embedded) GetUser ¶

func (e *Embedded) GetUser(ctx context.Context, id interface{}) (user store.User, err error)

GetUser get data by user ID

func (*Embedded) RepositoryGarbageCollector ¶

func (e *Embedded) RepositoryGarbageCollector(ctx context.Context, syncDate int64) (err error)

RepositoryGarbageCollector deletes outdated repositories

func (*Embedded) UpdateAccess ¶

func (e *Embedded) UpdateAccess(ctx context.Context, access store.Access) (err error)

UpdateAccess will update access record

func (*Embedded) UpdateGroup ¶

func (e *Embedded) UpdateGroup(ctx context.Context, group store.Group) (err error)

UpdateGroup update group records data

func (*Embedded) UpdateRepository ¶

func (e *Embedded) UpdateRepository(ctx context.Context, conditionClause, data map[string]interface{}) (err error)

UpdateRepository update repository entry data

func (*Embedded) UpdateUser ¶

func (e *Embedded) UpdateUser(ctx context.Context, user store.User) (err error)

UpdateUser update user records data

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL