mongo

Documentation

Index

• Constants
• Variables
• type Database
  • 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
  • func (this *PermissionsEntry) ToResource() model.Resource

Constants

const PermissionsEntryTimestampBson = "timestamp"

Variables

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

var PermissionsEntryBson = getBsonFieldObject[PermissionsEntry]()

var TopicBson = getBsonFieldObject[model.Topic]()

Types

type Database

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

func New

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

func (*Database) CheckMultipleResourcePermissions

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

func (*Database) CheckResourcePermissions

func (this *Database) CheckResourcePermissions(ctx context.Context, topicId string, id string, userId string, groupIds []string, permissions string) (bool, error)

func (*Database) CreateId

func (this *Database) CreateId() string

func (*Database) DeleteResource

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

func (*Database) DeleteTopic

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

func (*Database) Disconnect

func (this *Database) Disconnect()

func (*Database) GetResource

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

func (*Database) GetTopic

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

func (*Database) ListResourceIdsByPermissions

func (this *Database) ListResourceIdsByPermissions(ctx context.Context, topicId string, userId string, groupIds []string, permissions string, options model.ListOptions) ([]string, error)

func (*Database) ListResourcesByPermissions

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

func (*Database) ListTopics

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

func (*Database) SetPermissions

func (this *Database) SetPermissions(ctx context.Context, topic string, id string, permissions model.ResourcePermissions, t time.Time) (err error)

func (*Database) SetResourcePermissions

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

func (*Database) SetTopic

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

type PermissionsEntry

type PermissionsEntry struct {
	Timestamp     int64    `json:"timestamp"`
	TopicId       string   `json:"topic_id" bson:"topic_id"`
	Id            string   `json:"id" bson:"id"`
	AdminUsers    []string `json:"admin_users" bson:"admin_users"`
	AdminGroups   []string `json:"admin_groups" bson:"admin_groups"`
	ReadUsers     []string `json:"read_users" bson:"read_users"`
	ReadGroups    []string `json:"read_groups" bson:"read_groups"`
	WriteUsers    []string `json:"write_users" bson:"write_users"`
	WriteGroups   []string `json:"write_groups" bson:"write_groups"`
	ExecuteUsers  []string `json:"execute_users" bson:"execute_users"`
	ExecuteGroups []string `json:"execute_groups" bson:"execute_groups"`
}

func (*PermissionsEntry) ToResource

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