database

package

Go to main page

Versions in this module

v0

v0.10.1

Oct 29, 2025

v0.10.0

Oct 20, 2025

Changes in this version

+ const ObjectImage

+ const ObjectUserGroup

type Database

+ func (d *Database) EnrichUserWithGroupConfig(ctx context.Context, user *typesv2.User)

+ func (d *Database) LabelSave(ctx context.Context, l *typesv2.Label) error

+ func (d *Database) MergeUserConfigWithGroups(ctx context.Context, user *typesv2.User, groups []*typesv2.UserGroup) *typesv2.UserConfig

+ func (d *Database) SubscribeUserGroup(ctx context.Context, ch chan UserGroupSubscriptionEvent)

+ func (d *Database) UnsubscribeUserGroup(ctx context.Context, ch chan UserGroupSubscriptionEvent)

+ func (d *Database) UserGroupCreate(ctx context.Context, g *typesv2.UserGroup) error

+ func (d *Database) UserGroupDelete(ctx context.Context, name string) error

+ func (d *Database) UserGroupGet(ctx context.Context, name string) (*typesv2.UserGroup, error)

+ func (d *Database) UserGroupList(ctx context.Context) ([]typesv2.UserGroup, error)

+ func (d *Database) UserGroupListByUser(ctx context.Context, userName string) ([]*typesv2.UserGroup, error)

+ func (d *Database) UserGroupSave(ctx context.Context, g *typesv2.UserGroup) error

+ type UserGroupSubscriptionEvent = SubscriptionEvent[*typesv2.UserGroup]

v0.9.1

Aug 19, 2025

Changes in this version

type Database

+ func (d *Database) GateProxySSHAccessUseKey(username string, key string) (*typesv2.GateProxySSHAccess, error)

+ func (d *Database) GateProxySSHAccessUsePasswordHash(username string, hash string) (*typesv2.GateProxySSHAccess, error)

v0.9.0

Aug 18, 2025

Changes in this version

+ const ObjectApplication

+ const ObjectApplicationResource

+ const ObjectApplicationState

+ const ObjectApplicationTask

+ const ObjectAuthentication

+ const ObjectCpuInfo

+ const ObjectDiskUsage

+ const ObjectFieldUiConfig

+ const ObjectGateProxySSHAccess

+ const ObjectHostInfo

+ const ObjectJWTToken

+ const ObjectLabel

+ const ObjectLabelDefinition

+ const ObjectMemoryInfo

+ const ObjectNetworkInterface

+ const ObjectNode

+ const ObjectNodeDefinition

+ const ObjectPermission

+ const ObjectResources

+ const ObjectResourcesDisk

+ const ObjectRole

+ const ObjectRoleBasedAccessControl

+ const ObjectStreamCreated

+ const ObjectStreamError

+ const ObjectSubscribeConfig

+ const ObjectUiConfig

+ const ObjectUser

+ const ObjectUserConfig

+ const ObjectUserSession

+ const ObjectVote

+ type ApplicationResourceSubscriptionEvent = SubscriptionEvent[*typesv2.ApplicationResource]

+ type ApplicationStateSubscriptionEvent = SubscriptionEvent[*typesv2.ApplicationState]

+ type ApplicationSubscriptionEvent = SubscriptionEvent[*typesv2.Application]

+ type ApplicationTaskSubscriptionEvent = SubscriptionEvent[*typesv2.ApplicationTask]

type Database

+ func (d *Database) GateProxySSHAccessCreate(ra *typesv2.GateProxySSHAccess) error

+ func (d *Database) GateProxySSHAccessDelete(uid typesv2.GateProxySSHAccessUID) error

+ func (d *Database) GateProxySSHAccessDeleteByResource(appresUID typesv2.ApplicationResourceUID) error

+ func (d *Database) GateProxySSHAccessList() (ra []typesv2.GateProxySSHAccess, err error)

+ func (d *Database) GateProxySSHAccessSingleUseKey(username string, key string) (*typesv2.GateProxySSHAccess, error)

+ func (d *Database) GateProxySSHAccessSingleUsePasswordHash(username string, hash string) (*typesv2.GateProxySSHAccess, error)

+ func (d *Database) GetNodeAddress() string

+ func (d *Database) RoleCreate(ctx context.Context, r *typesv2.Role) error

+ func (d *Database) RoleDelete(ctx context.Context, name string) error

+ func (d *Database) RoleGet(ctx context.Context, name string) (*typesv2.Role, error)

+ func (d *Database) RoleList(ctx context.Context) ([]typesv2.Role, error)

+ func (d *Database) RoleSave(ctx context.Context, r *typesv2.Role) error

+ func (d *Database) SubscribeApplication(ctx context.Context, ch chan ApplicationSubscriptionEvent)

+ func (d *Database) SubscribeApplicationResource(ctx context.Context, ch chan ApplicationResourceSubscriptionEvent)

+ func (d *Database) SubscribeLabel(ctx context.Context, ch chan LabelSubscriptionEvent)

+ func (d *Database) SubscribeNode(ctx context.Context, ch chan NodeSubscriptionEvent)

+ func (d *Database) SubscribeRole(ctx context.Context, ch chan RoleSubscriptionEvent)

+ func (d *Database) SubscribeUser(ctx context.Context, ch chan UserSubscriptionEvent)

+ func (d *Database) UnsubscribeApplication(ctx context.Context, ch chan ApplicationSubscriptionEvent)

+ func (d *Database) UnsubscribeApplicationResource(ctx context.Context, ch chan ApplicationResourceSubscriptionEvent)

+ func (d *Database) UnsubscribeApplicationState(ctx context.Context, ch chan ApplicationStateSubscriptionEvent)

+ func (d *Database) UnsubscribeApplicationTask(ctx context.Context, ch chan ApplicationTaskSubscriptionEvent)

+ func (d *Database) UnsubscribeLabel(ctx context.Context, ch chan LabelSubscriptionEvent)

+ func (d *Database) UnsubscribeNode(ctx context.Context, ch chan NodeSubscriptionEvent)

+ func (d *Database) UnsubscribeRole(ctx context.Context, ch chan RoleSubscriptionEvent)

+ func (d *Database) UnsubscribeUser(ctx context.Context, ch chan UserSubscriptionEvent)

+ type LabelListParams struct

+ Name *string

+ Version *string

+ type LabelSubscriptionEvent = SubscriptionEvent[*typesv2.Label]

+ type NodeSubscriptionEvent = SubscriptionEvent[*typesv2.Node]

+ type RoleSubscriptionEvent = SubscriptionEvent[*typesv2.Role]

+ type SubscriptionEvent struct

+ ChangeType aquariumv2.ChangeType

+ Object T

+ func NewCreateEvent[T any](obj T) SubscriptionEvent[T]

+ func NewRemoveEvent[T any](obj T) SubscriptionEvent[T]

+ func NewUpdateEvent[T any](obj T) SubscriptionEvent[T]

+ type UserSubscriptionEvent = SubscriptionEvent[*typesv2.User]

v0.8.5

Aug 19, 2025

v0.8.4

Jun 21, 2025

v0.8.3

Jun 20, 2025

Changes in this version

type Database

+ func (*Database) ApplicationStateIsDead(status types.ApplicationStatus) bool

+ func (d *Database) ApplicationResourceAccessKey(username string, key string) (*types.ApplicationResourceAccess, error)

+ func (d *Database) ApplicationResourceAccessPasswordHash(username string, hash string) (*types.ApplicationResourceAccess, error)

+ func (d *Database) ApplicationStateListNewElected() (ass []types.ApplicationState, err error)

+ func (d *Database) ApplicationStateNewCount(appUID types.ApplicationUID) (count uint)

+ func (d *Database) SubscribeApplicationState(ch chan *types.ApplicationState)

+ func (d *Database) SubscribeApplicationTask(ch chan *types.ApplicationTask)

v0.8.2

Apr 29, 2025

Changes in this version

+ var ErrObjectNotFound = bitcask.ErrObjectNotFound

+ type Database struct

+ func New(path string) (*Database, error)

+ func (*Database) ApplicationStateIsActive(status types.ApplicationStatus) bool

+ func (d *Database) ApplicationCreate(a *types.Application) error

+ func (d *Database) ApplicationDeallocate(appUID types.ApplicationUID, requestor string) (*types.ApplicationState, error)

+ func (d *Database) ApplicationDelete(uid types.ApplicationUID) (err error)

+ func (d *Database) ApplicationGet(uid types.ApplicationUID) (a *types.Application, err error)

+ func (d *Database) ApplicationIsAllocated(appUID types.ApplicationUID) (err error)

+ func (d *Database) ApplicationList() (as []types.Application, err error)

+ func (d *Database) ApplicationListGetStatusNew() (as []types.Application, err error)

+ func (d *Database) ApplicationResourceAccessCreate(ra *types.ApplicationResourceAccess) error

+ func (d *Database) ApplicationResourceAccessDelete(uid types.ApplicationResourceAccessUID) error

+ func (d *Database) ApplicationResourceAccessDeleteByResource(appresUID types.ApplicationResourceUID) error

+ func (d *Database) ApplicationResourceAccessList() (ra []types.ApplicationResourceAccess, err error)

+ func (d *Database) ApplicationResourceAccessSingleUseKey(username string, key string) (*types.ApplicationResourceAccess, error)

+ func (d *Database) ApplicationResourceAccessSingleUsePasswordHash(username string, hash string) (*types.ApplicationResourceAccess, error)

+ func (d *Database) ApplicationResourceCreate(r *types.ApplicationResource) error

+ func (d *Database) ApplicationResourceDelete(uid types.ApplicationResourceUID) error

+ func (d *Database) ApplicationResourceGet(uid types.ApplicationResourceUID) (res *types.ApplicationResource, err error)

+ func (d *Database) ApplicationResourceGetByApplication(appUID types.ApplicationUID) (res *types.ApplicationResource, err error)

+ func (d *Database) ApplicationResourceGetByIP(ip string) (res *types.ApplicationResource, err error)

+ func (d *Database) ApplicationResourceList() (rs []types.ApplicationResource, err error)

+ func (d *Database) ApplicationResourceListNode(nodeUID types.NodeUID) (rs []types.ApplicationResource, err error)

+ func (d *Database) ApplicationResourceSave(res *types.ApplicationResource) error

+ func (d *Database) ApplicationStateCreate(as *types.ApplicationState) error

+ func (d *Database) ApplicationStateDelete(uid types.ApplicationStateUID) (err error)

+ func (d *Database) ApplicationStateGet(uid types.ApplicationStateUID) (as *types.ApplicationState, err error)

+ func (d *Database) ApplicationStateGetByApplication(appUID types.ApplicationUID) (state *types.ApplicationState, err error)

+ func (d *Database) ApplicationStateList() (ass []types.ApplicationState, err error)

+ func (d *Database) ApplicationStateListByApplication(appUID types.ApplicationUID) (states []types.ApplicationState, err error)

+ func (d *Database) ApplicationStateListLatest() (out []types.ApplicationState, err error)

+ func (d *Database) ApplicationTaskCreate(at *types.ApplicationTask) error

+ func (d *Database) ApplicationTaskDelete(uid types.ApplicationTaskUID) (err error)

+ func (d *Database) ApplicationTaskGet(uid types.ApplicationTaskUID) (at *types.ApplicationTask, err error)

+ func (d *Database) ApplicationTaskList() (at []types.ApplicationTask, err error)

+ func (d *Database) ApplicationTaskListByApplication(uid types.ApplicationUID) (at []types.ApplicationTask, err error)

+ func (d *Database) ApplicationTaskListByApplicationAndWhen(appUID types.ApplicationUID, when types.ApplicationStatus) (at []types.ApplicationTask, err error)

+ func (d *Database) ApplicationTaskSave(at *types.ApplicationTask) error

+ func (d *Database) CompactDB() error

+ func (d *Database) Del(prefix, key string) error

+ func (d *Database) Get(prefix, key string, obj any) error

+ func (d *Database) GetNode() *types.Node

+ func (d *Database) GetNodeLocation() string

+ func (d *Database) GetNodeName() string

+ func (d *Database) GetNodeUID() types.NodeUID

+ func (d *Database) Has(prefix, key string) (bool, error)

+ func (d *Database) LabelCreate(l *types.Label) error

+ func (d *Database) LabelDelete(uid types.LabelUID) error

+ func (d *Database) LabelGet(uid types.LabelUID) (label *types.Label, err error)

+ func (d *Database) LabelList(filters types.LabelListGetParams) (labels []types.Label, err error)

+ func (d *Database) LabelListName(name string) (labels []types.Label, err error)

+ func (d *Database) NewUID() uuid.UUID

+ func (d *Database) NodeActiveList() (ns []types.Node, err error)

+ func (d *Database) NodeCreate(n *types.Node) error

+ func (d *Database) NodeGet(name string) (node *types.Node, err error)

+ func (d *Database) NodeList() (ns []types.Node, err error)

+ func (d *Database) NodePing(node *types.Node) error

+ func (d *Database) NodeSave(node *types.Node) error

+ func (d *Database) Scan(prefix string, f func(string) error) error

+ func (d *Database) ServiceMappingByApplicationAndDest(appUID types.ApplicationUID, dest string) string

+ func (d *Database) ServiceMappingCreate(sm *types.ServiceMapping) error

+ func (d *Database) ServiceMappingDelete(uid types.ServiceMappingUID) error

+ func (d *Database) ServiceMappingGet(uid types.ServiceMappingUID) (sm *types.ServiceMapping, err error)

+ func (d *Database) ServiceMappingList() (sms []types.ServiceMapping, err error)

+ func (d *Database) ServiceMappingListByApplication(appUID types.ApplicationUID) (sms []types.ServiceMapping, err error)

+ func (d *Database) ServiceMappingSave(sm *types.ServiceMapping) error

+ func (d *Database) Set(prefix, key string, obj any) error

+ func (d *Database) SetNode(node types.Node)

+ func (d *Database) Shutdown() error

+ func (d *Database) UserAuth(name string, password string) *types.User

+ func (d *Database) UserCreate(u *types.User) error

+ func (d *Database) UserDelete(name string) error

+ func (d *Database) UserGet(name string) (u *types.User, err error)

+ func (d *Database) UserList() (us []types.User, err error)

+ func (d *Database) UserNew(name string, password string) (string, *types.User, error)

+ func (d *Database) UserSave(u *types.User) error

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