sql

Documentation

Index

• type Persister
  • func NewPersister(dsn string, l *logrusx.Logger, namespaces namespace.Manager) (*Persister, error)
  • func (p *Persister) DeleteRelationTuples(ctx context.Context, rs ...*relationtuple.InternalRelationTuple) error
  • func (p *Persister) GetRelationTuples(ctx context.Context, query *relationtuple.RelationQuery, ...) ([]*relationtuple.InternalRelationTuple, string, error)
  • func (p *Persister) MigrationBox(ctx context.Context) (*popx.MigrationBox, error)
  • func (p *Persister) NamespaceFromName(ctx context.Context, name string) (*namespace.Namespace, error)
  • func (p *Persister) NamespaceMigrationBox(_ context.Context, n *namespace.Namespace) (*popx.MigrationBox, error)
  • func (p *Persister) TransactRelationTuples(ctx context.Context, ins []*relationtuple.InternalRelationTuple, ...) error
  • func (p *Persister) WriteRelationTuples(ctx context.Context, rs ...*relationtuple.InternalRelationTuple) error

Types

type Persister

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

func NewPersister

func NewPersister(dsn string, l *logrusx.Logger, namespaces namespace.Manager) (*Persister, error)

func (*Persister) DeleteRelationTuples

func (p *Persister) DeleteRelationTuples(ctx context.Context, rs ...*relationtuple.InternalRelationTuple) error

func (*Persister) GetRelationTuples

func (p *Persister) GetRelationTuples(ctx context.Context, query *relationtuple.RelationQuery, options ...x.PaginationOptionSetter) ([]*relationtuple.InternalRelationTuple, string, error)

func (*Persister) MigrationBox

func (p *Persister) MigrationBox(ctx context.Context) (*popx.MigrationBox, error)

func (*Persister) NamespaceFromName

func (p *Persister) NamespaceFromName(ctx context.Context, name string) (*namespace.Namespace, error)

func (*Persister) NamespaceMigrationBox

func (p *Persister) NamespaceMigrationBox(_ context.Context, n *namespace.Namespace) (*popx.MigrationBox, error)

func (*Persister) TransactRelationTuples

func (p *Persister) TransactRelationTuples(ctx context.Context, ins []*relationtuple.InternalRelationTuple, del []*relationtuple.InternalRelationTuple) error

func (*Persister) WriteRelationTuples

func (p *Persister) WriteRelationTuples(ctx context.Context, rs ...*relationtuple.InternalRelationTuple) error