mysql

Documentation

Index

• type MySQL
  • func New(uri string, cfg *common.Config) (*MySQL, error)
  • func (m *MySQL) Close()
  • func (m *MySQL) CreateStore(ctx context.Context, store *openfgapb.Store) (*openfgapb.Store, error)
  • func (m *MySQL) DeleteStore(ctx context.Context, id string) error
  • func (m *MySQL) FindLatestAuthorizationModelID(ctx context.Context, store string) (string, error)
  • func (m *MySQL) GetStore(ctx context.Context, id string) (*openfgapb.Store, error)
  • func (m *MySQL) IsReady(ctx context.Context) (bool, error)
  • func (m *MySQL) ListObjectsByType(ctx context.Context, store string, objectType string) (storage.ObjectIterator, error)
  • func (m *MySQL) ListStores(ctx context.Context, opts storage.PaginationOptions) ([]*openfgapb.Store, []byte, error)
  • func (m *MySQL) MaxTuplesPerWrite() int
  • func (m *MySQL) MaxTypesPerAuthorizationModel() int
  • func (m *MySQL) Read(ctx context.Context, store string, tupleKey *openfgapb.TupleKey) (storage.TupleIterator, error)
  • func (m *MySQL) ReadAssertions(ctx context.Context, store, modelID string) ([]*openfgapb.Assertion, error)
  • func (m *MySQL) ReadAuthorizationModel(ctx context.Context, store string, modelID string) (*openfgapb.AuthorizationModel, error)
  • func (m *MySQL) ReadAuthorizationModels(ctx context.Context, store string, opts storage.PaginationOptions) ([]*openfgapb.AuthorizationModel, []byte, error)
  • func (m *MySQL) ReadChanges(ctx context.Context, store, objectTypeFilter string, ...) ([]*openfgapb.TupleChange, []byte, error)
  • func (m *MySQL) ReadPage(ctx context.Context, store string, tupleKey *openfgapb.TupleKey, ...) ([]*openfgapb.Tuple, []byte, error)
  • func (m *MySQL) ReadStartingWithUser(ctx context.Context, store string, opts storage.ReadStartingWithUserFilter) (storage.TupleIterator, error)
  • func (m *MySQL) ReadTypeDefinition(ctx context.Context, store, modelID, objectType string) (*openfgapb.TypeDefinition, error)
  • func (m *MySQL) ReadUserTuple(ctx context.Context, store string, tupleKey *openfgapb.TupleKey) (*openfgapb.Tuple, error)
  • func (m *MySQL) ReadUsersetTuples(ctx context.Context, store string, filter storage.ReadUsersetTuplesFilter) (storage.TupleIterator, error)
  • func (m *MySQL) Write(ctx context.Context, store string, deletes storage.Deletes, ...) error
  • func (m *MySQL) WriteAssertions(ctx context.Context, store, modelID string, assertions []*openfgapb.Assertion) error
  • func (m *MySQL) WriteAuthorizationModel(ctx context.Context, store string, model *openfgapb.AuthorizationModel) error

Types

type MySQL

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

func New

func New(uri string, cfg *common.Config) (*MySQL, error)

func (*MySQL) Close

func (m *MySQL) Close()

Close closes the datastore and cleans up any residual resources.

func (*MySQL) CreateStore

func (m *MySQL) CreateStore(ctx context.Context, store *openfgapb.Store) (*openfgapb.Store, error)

CreateStore is slightly different between Postgres and MySQL

func (*MySQL) DeleteStore

func (m *MySQL) DeleteStore(ctx context.Context, id string) error

func (*MySQL) FindLatestAuthorizationModelID

func (m *MySQL) FindLatestAuthorizationModelID(ctx context.Context, store string) (string, error)

func (*MySQL) GetStore

func (m *MySQL) GetStore(ctx context.Context, id string) (*openfgapb.Store, error)

func (*MySQL) IsReady

func (m *MySQL) IsReady(ctx context.Context) (bool, error)

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

func (*MySQL) ListObjectsByType

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

func (*MySQL) ListStores

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

func (*MySQL) MaxTuplesPerWrite

func (m *MySQL) MaxTuplesPerWrite() int

func (*MySQL) MaxTypesPerAuthorizationModel

func (m *MySQL) MaxTypesPerAuthorizationModel() int

func (*MySQL) Read

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

func (*MySQL) ReadAssertions

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

func (*MySQL) ReadAuthorizationModel

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

func (*MySQL) ReadAuthorizationModels

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

func (*MySQL) ReadChanges

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

func (*MySQL) ReadPage

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

func (*MySQL) ReadStartingWithUser

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

func (*MySQL) ReadTypeDefinition

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

func (*MySQL) ReadUserTuple

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

func (*MySQL) ReadUsersetTuples

func (m *MySQL) ReadUsersetTuples(ctx context.Context, store string, filter storage.ReadUsersetTuplesFilter) (storage.TupleIterator, error)

func (*MySQL) Write

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

func (*MySQL) WriteAssertions

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

WriteAssertions is slightly different between Postgres and MySQL

func (*MySQL) WriteAuthorizationModel

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