mongo

Aug 14, 2024

Changes in this version

+ const PermissionsEntrySyncedBson

type Database

+ func (this *Database) ListUnsyncedResources(ctx context.Context) (result []model.Resource, err error)

+ func (this *Database) MarkResourceAsSynced(ctx context.Context, topicId string, id string) error

+ func (this *Database) SetResource(ctx context.Context, r model.Resource, t time.Time, synced bool) (err error)

type PermissionsEntry

+ AdminRoles []string

+ ExecuteRoles []string

+ ReadRoles []string

+ Synced bool

+ WriteRoles []string

Aug 12, 2024

Changes in this version

type Database

+ func (this *Database) AdminListResources(ctx context.Context, topicId string, listOptions model.ListOptions) (result []model.Resource, err error)

Jun 12, 2024

Changes in this version

type Database

+ func (this *Database) AdminListResourceIds(ctx context.Context, topicId string, listOptions model.ListOptions) (result []string, err error)

Jun 11, 2024

Changes in this version

+ const PermissionsEntryTimestampBson

+ var CreateCollections = []func(db *Database) error

+ var PermissionsEntryBson = getBsonFieldObject[PermissionsEntry]()

+ var TopicBson = getBsonFieldObject[model.Topic]()

+ type Database struct

+ func New(conf configuration.Config) (*Database, error)

+ func (this *Database) CheckMultipleResourcePermissions(ctx context.Context, topicId string, ids []string, userId string, ...) (result map[string]bool, err error)

+ func (this *Database) CheckResourcePermissions(ctx context.Context, topicId string, id string, userId string, ...) (bool, error)

+ func (this *Database) CreateId() string

+ func (this *Database) DeleteResource(ctx context.Context, topicId string, id string) error

+ func (this *Database) DeleteTopic(ctx context.Context, id string) error

+ func (this *Database) Disconnect()

+ func (this *Database) GetResource(ctx context.Context, topicId string, id string, options model.GetOptions) (resource model.Resource, err error)

+ func (this *Database) GetTopic(ctx context.Context, id string) (result model.Topic, exists bool, err error)

+ func (this *Database) ListResourceIdsByPermissions(ctx context.Context, topicId string, userId string, groupIds []string, ...) ([]string, error)

+ func (this *Database) ListResourcesByPermissions(ctx context.Context, topicId string, userId string, groupIds []string, ...) (result []model.Resource, err error)

+ func (this *Database) ListTopics(ctx context.Context, listOptions model.ListOptions) (result []model.Topic, err error)

+ func (this *Database) SetPermissions(ctx context.Context, topic string, id string, ...) (err error)

+ func (this *Database) SetResourcePermissions(ctx context.Context, r model.Resource, t time.Time, preventOlderUpdates bool) (updateIgnored bool, err error)

+ func (this *Database) SetTopic(ctx context.Context, topic model.Topic) error

+ type PermissionsEntry struct

+ AdminGroups []string

+ AdminUsers []string

+ ExecuteGroups []string

+ ExecuteUsers []string

+ Id string

+ ReadGroups []string

+ ReadUsers []string

+ Timestamp int64

+ TopicId string

+ WriteGroups []string

+ WriteUsers []string

+ func (this *PermissionsEntry) ToResource() model.Resource