v3

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
  • func (s *Model) DeleteManifest(ctx context.Context, req *dsm3.DeleteManifestRequest) (*dsm3.DeleteManifestResponse, error)
  • func (s *Model) GetManifest(req *dsm3.GetManifestRequest, stream dsm3.Model_GetManifestServer) error
  • func (s *Model) SetManifest(stream dsm3.Model_SetManifestServer) error
• type Reader
  • func NewReader(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Reader
  • func (s *Reader) Check(ctx context.Context, req *dsr3.CheckRequest) (*dsr3.CheckResponse, error)
  • func (s *Reader) CheckPermission(ctx context.Context, req *dsr3.CheckPermissionRequest) (*dsr3.CheckPermissionResponse, error)
  • func (s *Reader) CheckRelation(ctx context.Context, req *dsr3.CheckRelationRequest) (*dsr3.CheckRelationResponse, error)
  • func (s *Reader) GetGraph(ctx context.Context, req *dsr3.GetGraphRequest) (*dsr3.GetGraphResponse, error)
  • func (s *Reader) GetObject(ctx context.Context, req *dsr3.GetObjectRequest) (*dsr3.GetObjectResponse, error)
  • func (s *Reader) GetObjectMany(ctx context.Context, req *dsr3.GetObjectManyRequest) (*dsr3.GetObjectManyResponse, error)
  • func (s *Reader) GetObjects(ctx context.Context, req *dsr3.GetObjectsRequest) (*dsr3.GetObjectsResponse, error)
  • func (s *Reader) GetRelation(ctx context.Context, req *dsr3.GetRelationRequest) (*dsr3.GetRelationResponse, error)
  • func (s *Reader) GetRelations(ctx context.Context, req *dsr3.GetRelationsRequest) (*dsr3.GetRelationsResponse, error)
  • func (s *Reader) Validate(msg proto.Message) error
• type Writer
  • func NewWriter(logger *zerolog.Logger, store *bdb.BoltDB, validator *protovalidate.Validator) *Writer
  • func (s *Writer) DeleteObject(ctx context.Context, req *dsw3.DeleteObjectRequest) (*dsw3.DeleteObjectResponse, error)
  • func (s *Writer) DeleteRelation(ctx context.Context, req *dsw3.DeleteRelationRequest) (*dsw3.DeleteRelationResponse, error)
  • func (s *Writer) SetObject(ctx context.Context, req *dsw3.SetObjectRequest) (*dsw3.SetObjectResponse, error)
  • func (s *Writer) SetRelation(ctx context.Context, req *dsw3.SetRelationRequest) (*dsw3.SetRelationResponse, error)
  • func (s *Writer) Validate(msg proto.Message) error

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

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

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

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

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