postgres

package
v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 19, 2022 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPostgresObjectIterator added in v0.3.0 

func NewPostgresObjectIterator(rows *sql.Rows) *objectIterator

NewPostgresObjectIterator returns a tuple iterator for Postgres

func NewPostgresTupleIterator added in v0.3.0 

func NewPostgresTupleIterator(rows *sql.Rows) *tupleIterator

NewPostgresTupleIterator returns a tuple iterator for Postgres

Types

type Postgres 

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

func NewPostgresDatastore 

func NewPostgresDatastore(uri string, opts ...PostgresOption) (*Postgres, error)

func (*Postgres) Close 

func (p *Postgres) Close()

Close closes any open connections and cleans up residual resources used by this storage adapter instance.

func (*Postgres) CreateStore 

func (p *Postgres) CreateStore(ctx context.Context, store *openfgapb.Store) (*openfgapb.Store, error)

func (*Postgres) DeleteStore 

func (p *Postgres) DeleteStore(ctx context.Context, id string) error

func (*Postgres) FindLatestAuthorizationModelID 

func (p *Postgres) FindLatestAuthorizationModelID(ctx context.Context, store string) (string, error)

func (*Postgres) GetStore 

func (p *Postgres) GetStore(ctx context.Context, id string) (*openfgapb.Store, error)

func (*Postgres) IsReady added in v0.1.5 

func (p *Postgres) IsReady(ctx context.Context) (bool, error)

IsReady reports whether this Postgres datastore instance is ready to accept connections.

func (*Postgres) ListObjectsByType added in v0.2.0 

func (p *Postgres) ListObjectsByType(ctx context.Context, store string, objectType string) (storage.ObjectIterator, error)

func (*Postgres) ListStores 

func (p *Postgres) ListStores(ctx context.Context, opts storage.PaginationOptions) ([]*openfgapb.Store, []byte, error)

func (*Postgres) MaxTuplesPerWrite added in v0.3.1 

func (p *Postgres) MaxTuplesPerWrite() int

func (*Postgres) MaxTypesPerAuthorizationModel added in v0.3.1 

func (p *Postgres) MaxTypesPerAuthorizationModel() int

func (*Postgres) Read 

func (p *Postgres) Read(ctx context.Context, store string, tupleKey *openfgapb.TupleKey) (storage.TupleIterator, error)

func (*Postgres) ReadAssertions 

func (p *Postgres) ReadAssertions(ctx context.Context, store, modelID string) ([]*openfgapb.Assertion, error)

func (*Postgres) ReadAuthorizationModel 

func (p *Postgres) ReadAuthorizationModel(ctx context.Context, store string, modelID string) (*openfgapb.AuthorizationModel, error)

func (*Postgres) ReadAuthorizationModels 

func (p *Postgres) ReadAuthorizationModels(ctx context.Context, store string, opts storage.PaginationOptions) ([]*openfgapb.AuthorizationModel, []byte, error)

func (*Postgres) ReadChanges 

func (p *Postgres) ReadChanges(
	ctx context.Context,
	store, objectTypeFilter string,
	opts storage.PaginationOptions,
	horizonOffset time.Duration,
) ([]*openfgapb.TupleChange, []byte, error)

func (*Postgres) ReadPage 

func (p *Postgres) ReadPage(ctx context.Context, store string, tupleKey *openfgapb.TupleKey, opts storage.PaginationOptions) ([]*openfgapb.Tuple, []byte, error)

func (*Postgres) ReadStartingWithUser added in v0.2.3 

func (p *Postgres) ReadStartingWithUser(ctx context.Context, store string, opts storage.ReadStartingWithUserFilter) (storage.TupleIterator, error)

func (*Postgres) ReadTypeDefinition 

func (p *Postgres) ReadTypeDefinition(
	ctx context.Context,
	store, modelID, objectType string,
) (*openfgapb.TypeDefinition, error)

func (*Postgres) ReadUserTuple 

func (p *Postgres) ReadUserTuple(ctx context.Context, store string, tupleKey *openfgapb.TupleKey) (*openfgapb.Tuple, error)

func (*Postgres) ReadUsersetTuples 

func (p *Postgres) ReadUsersetTuples(ctx context.Context, store string, tupleKey *openfgapb.TupleKey) (storage.TupleIterator, error)

func (*Postgres) Write 

func (p *Postgres) Write(ctx context.Context, store string, deletes storage.Deletes, writes storage.Writes) error

func (*Postgres) WriteAssertions 

func (p *Postgres) WriteAssertions(ctx context.Context, store, modelID string, assertions []*openfgapb.Assertion) error

func (*Postgres) WriteAuthorizationModel 

func (p *Postgres) WriteAuthorizationModel(ctx context.Context, store string, model *openfgapb.AuthorizationModel) error

type PostgresOption 

type PostgresOption func(*Postgres)

func WithConnMaxIdleTime added in v0.3.1 

func WithConnMaxIdleTime(d time.Duration) PostgresOption

func WithConnMaxLifetime added in v0.3.1 

func WithConnMaxLifetime(d time.Duration) PostgresOption

func WithLogger 

func WithLogger(l logger.Logger) PostgresOption

func WithMaxIdleConns added in v0.3.1 

func WithMaxIdleConns(c int) PostgresOption

func WithMaxOpenConns added in v0.3.1 

func WithMaxOpenConns(c int) PostgresOption

func WithMaxTuplesPerWrite added in v0.3.1 

func WithMaxTuplesPerWrite(maxTuples int) PostgresOption

func WithMaxTypesPerAuthorizationModel added in v0.3.1 

func WithMaxTypesPerAuthorizationModel(maxTypes int) PostgresOption

func WithTracer 

func WithTracer(t trace.Tracer) PostgresOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.