v3

package

v0.32.1 Latest Latest Go to latest Published: Jul 13, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aserto-dev/go-edge-ds

Links

Open Source Insights

Documentation ¶

Index ¶

type Exporter
- func NewExporter(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Exporter
- func (s *Exporter) Export(req *dse3.ExportRequest, stream dse3.Exporter_ExportServer) error
- func (s *Exporter) Validate(msg proto.Message) error
type Importer
- func NewImporter(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Importer
- func (s *Importer) Import(stream dsi3.Importer_ImportServer) error
- func (s *Importer) Validate(msg proto.Message) error
type Model
- func NewModel(logger *zerolog.Logger, store *bdb.BoltDB) *Model
type Reader
- func NewReader(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Reader
type Writer
- func NewWriter(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Writer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Exporter ¶

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

func NewExporter ¶

func NewExporter(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Exporter

func (*Exporter) Export ¶

func (s *Exporter) Export(req *dse3.ExportRequest, stream dse3.Exporter_ExportServer) error

func (*Exporter) Validate ¶ added in v0.31.4

func (s *Exporter) Validate(msg proto.Message) error

type Importer ¶

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

func NewImporter ¶

func NewImporter(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Importer

func (*Importer) Import ¶

func (s *Importer) Import(stream dsi3.Importer_ImportServer) error

func (*Importer) Validate ¶ added in v0.31.4

func (s *Importer) Validate(msg proto.Message) error

type Model ¶

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

func NewModel ¶

func NewModel(logger *zerolog.Logger, store *bdb.BoltDB) *Model

func (*Model) DeleteManifest ¶

func (s *Model) DeleteManifest(ctx context.Context, req *dsm3.DeleteManifestRequest) (*dsm3.DeleteManifestResponse, error)

func (*Model) GetManifest ¶

func (s *Model) GetManifest(req *dsm3.GetManifestRequest, stream dsm3.Model_GetManifestServer) error

func (*Model) SetManifest ¶

func (s *Model) SetManifest(stream dsm3.Model_SetManifestServer) error

type Reader ¶

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

func NewReader ¶

func NewReader(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Reader

func (*Reader) Check ¶

func (s *Reader) Check(ctx context.Context, req *dsr3.CheckRequest) (*dsr3.CheckResponse, error)

Check, if subject is permitted to access resource (object).

func (*Reader) CheckPermission ¶

func (s *Reader) CheckPermission(ctx context.Context, req *dsr3.CheckPermissionRequest) (*dsr3.CheckPermissionResponse, error)

CheckPermission, check if subject is permitted to access resource (object).

func (*Reader) CheckRelation ¶

func (s *Reader) CheckRelation(ctx context.Context, req *dsr3.CheckRelationRequest) (*dsr3.CheckRelationResponse, error)

CheckRelation, check if subject has the specified relation to a resource (object).

func (*Reader) GetGraph ¶

func (s *Reader) GetGraph(ctx context.Context, req *dsr3.GetGraphRequest) (*dsr3.GetGraphResponse, error)

GetGraph, return graph of connected objects and relations for requested anchor subject/object.

func (*Reader) GetObject ¶

func (s *Reader) GetObject(ctx context.Context, req *dsr3.GetObjectRequest) (*dsr3.GetObjectResponse, error)

GetObject, get single object instance.

func (*Reader) GetObjectMany ¶

func (s *Reader) GetObjectMany(ctx context.Context, req *dsr3.GetObjectManyRequest) (*dsr3.GetObjectManyResponse, error)

GetObjectMany, get multiple object instances by type+id, in a single request.

func (*Reader) GetObjects ¶

func (s *Reader) GetObjects(ctx context.Context, req *dsr3.GetObjectsRequest) (*dsr3.GetObjectsResponse, error)

GetObjects, gets (all) object instances, optionally filtered by object type, as a paginated array of objects.

func (*Reader) GetRelation ¶

func (s *Reader) GetRelation(ctx context.Context, req *dsr3.GetRelationRequest) (*dsr3.GetRelationResponse, error)

GetRelation, get a single relation instance based on subject, relation, object filter.

func (*Reader) GetRelations ¶

func (s *Reader) GetRelations(ctx context.Context, req *dsr3.GetRelationsRequest) (*dsr3.GetRelationsResponse, error)

GetRelations, gets paginated set of relation instances based on subject, relation, object filter.

func (*Reader) Validate ¶ added in v0.31.4

func (s *Reader) Validate(msg proto.Message) error

type Writer ¶

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

func NewWriter ¶

func NewWriter(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Writer

func (*Writer) DeleteObject ¶

func (s *Writer) DeleteObject(ctx context.Context, req *dsw3.DeleteObjectRequest) (*dsw3.DeleteObjectResponse, error)

func (*Writer) DeleteRelation ¶

func (s *Writer) DeleteRelation(ctx context.Context, req *dsw3.DeleteRelationRequest) (*dsw3.DeleteRelationResponse, error)

func (*Writer) SetObject ¶

func (s *Writer) SetObject(ctx context.Context, req *dsw3.SetObjectRequest) (*dsw3.SetObjectResponse, error)

object methods.

func (*Writer) SetRelation ¶

func (s *Writer) SetRelation(ctx context.Context, req *dsw3.SetRelationRequest) (*dsw3.SetRelationResponse, error)

relation methods.

func (*Writer) Validate ¶ added in v0.31.4

func (s *Writer) Validate(msg proto.Message) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL