postgres

Documentation

Index

• type EntityConfigRepository
  • func NewEntityConfigRepository(pg *db.Postgres) *EntityConfigRepository
  • func (r *EntityConfigRepository) All(ctx context.Context, version string) ([]repositories.EntityConfig, error)
  • func (r *EntityConfigRepository) Migrate() error
  • func (r *EntityConfigRepository) Read(ctx context.Context, name string, version string) (repositories.EntityConfig, error)
  • func (r *EntityConfigRepository) Write(ctx context.Context, configs []repositories.EntityConfig, version string) error
• type RelationTupleRepository
  • func NewRelationTupleRepository(pg *db.Postgres) *RelationTupleRepository
  • func (r *RelationTupleRepository) Delete(ctx context.Context, tuples tuple.ITupleIterator) error
  • func (r *RelationTupleRepository) Migrate() error
  • func (r *RelationTupleRepository) QueryTuples(ctx context.Context, entity string, entityID string, relation string) (tuple.ITupleIterator, error)
  • func (r *RelationTupleRepository) Read(ctx context.Context, filter *base.TupleFilter) (tuple.ITupleCollection, error)
  • func (r *RelationTupleRepository) ReverseQueryTuples(ctx context.Context, entity string, relation string, subjectEntity string, ...) (tuple.ITupleIterator, error)
  • func (r *RelationTupleRepository) Write(ctx context.Context, tuples tuple.ITupleIterator) error

Types

type EntityConfigRepository

type EntityConfigRepository struct {
	Database *db.Postgres
}

EntityConfigRepository -.

func NewEntityConfigRepository

func NewEntityConfigRepository(pg *db.Postgres) *EntityConfigRepository

NewEntityConfigRepository -.

func (*EntityConfigRepository) All

func (r *EntityConfigRepository) All(ctx context.Context, version string) ([]repositories.EntityConfig, error)

All -

func (*EntityConfigRepository) Migrate

func (r *EntityConfigRepository) Migrate() error

Migrate -

func (*EntityConfigRepository) Read

func (r *EntityConfigRepository) Read(ctx context.Context, name string, version string) (repositories.EntityConfig, error)

Read -

func (*EntityConfigRepository) Write

func (r *EntityConfigRepository) Write(ctx context.Context, configs []repositories.EntityConfig, version string) error

Write -

type RelationTupleRepository

type RelationTupleRepository struct {
	Database *db.Postgres
}

RelationTupleRepository -.

func NewRelationTupleRepository

func NewRelationTupleRepository(pg *db.Postgres) *RelationTupleRepository

NewRelationTupleRepository -.

func (*RelationTupleRepository) Delete

func (r *RelationTupleRepository) Delete(ctx context.Context, tuples tuple.ITupleIterator) error

Delete -.

func (*RelationTupleRepository) Migrate

func (r *RelationTupleRepository) Migrate() error

Migrate -

func (*RelationTupleRepository) QueryTuples

func (r *RelationTupleRepository) QueryTuples(ctx context.Context, entity string, entityID string, relation string) (tuple.ITupleIterator, error)

QueryTuples -

func (*RelationTupleRepository) Read

func (r *RelationTupleRepository) Read(ctx context.Context, filter *base.TupleFilter) (tuple.ITupleCollection, error)

Read -.

func (*RelationTupleRepository) ReverseQueryTuples

func (r *RelationTupleRepository) ReverseQueryTuples(ctx context.Context, entity string, relation string, subjectEntity string, subjectIDs []string, subjectRelation string) (tuple.ITupleIterator, error)

ReverseQueryTuples -

func (*RelationTupleRepository) Write

func (r *RelationTupleRepository) Write(ctx context.Context, tuples tuple.ITupleIterator) error

Write -.