services

Documentation

Index

• type IPermissionService
• type IRelationshipService
• type ISchemaService
• type PermissionService
  • func NewPermissionService(cc commands.ICheckCommand, ec commands.IExpandCommand, ...) *PermissionService
  • func (service *PermissionService) CheckPermissions(ctx context.Context, request *base.PermissionCheckRequest) (response *base.PermissionCheckResponse, err error)
  • func (service *PermissionService) ExpandPermissions(ctx context.Context, request *base.PermissionExpandRequest) (response *base.PermissionExpandResponse, err error)
  • func (service *PermissionService) LookupEntity(ctx context.Context, request *base.PermissionLookupEntityRequest) (response *base.PermissionLookupEntityResponse, err error)
  • func (service *PermissionService) LookupEntityStream(ctx context.Context, request *base.PermissionLookupEntityRequest, ...) (err error)
  • func (service *PermissionService) LookupSchema(ctx context.Context, request *base.PermissionLookupSchemaRequest) (response *base.PermissionLookupSchemaResponse, err error)
• type RelationshipService
  • func NewRelationshipService(rr repositories.RelationshipReader, rw repositories.RelationshipWriter, ...) *RelationshipService
  • func (service *RelationshipService) DeleteRelationships(ctx context.Context, filter *base.TupleFilter) (token.EncodedSnapToken, error)
  • func (service *RelationshipService) ReadRelationships(ctx context.Context, filter *base.TupleFilter, token string) (tuples database.ITupleCollection, err error)
  • func (service *RelationshipService) WriteRelationships(ctx context.Context, tuples []*base.Tuple, version string) (token token.EncodedSnapToken, err error)
• type SchemaService
  • func NewSchemaService(sw repositories.SchemaWriter, sr repositories.SchemaReader) *SchemaService
  • func (service *SchemaService) ReadSchema(ctx context.Context, version string) (response *base.IndexedSchema, err error)
  • func (service *SchemaService) WriteSchema(ctx context.Context, schema string) (response string, err error)

Types

type IPermissionService

type IPermissionService interface {
	CheckPermissions(ctx context.Context, request *base.PermissionCheckRequest) (response *base.PermissionCheckResponse, err error)
	ExpandPermissions(ctx context.Context, request *base.PermissionExpandRequest) (response *base.PermissionExpandResponse, err error)
	LookupSchema(ctx context.Context, request *base.PermissionLookupSchemaRequest) (response *base.PermissionLookupSchemaResponse, err error)
	LookupEntity(ctx context.Context, request *base.PermissionLookupEntityRequest) (response *base.PermissionLookupEntityResponse, err error)
	LookupEntityStream(ctx context.Context, request *base.PermissionLookupEntityRequest, server base.Permission_LookupEntityStreamServer) (err error)
}

IPermissionService -

type IRelationshipService

type IRelationshipService interface {
	ReadRelationships(ctx context.Context, filter *base.TupleFilter, token string) (database.ITupleCollection, error)
	WriteRelationships(ctx context.Context, tuples []*base.Tuple, version string) (token.EncodedSnapToken, error)
	DeleteRelationships(ctx context.Context, filter *base.TupleFilter) (token.EncodedSnapToken, error)
}

IRelationshipService -

type ISchemaService

type ISchemaService interface {
	ReadSchema(ctx context.Context, version string) (response *base.IndexedSchema, err error)
	WriteSchema(ctx context.Context, schema string) (version string, err error)
}

ISchemaService -

type PermissionService

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

PermissionService -

func NewPermissionService

func NewPermissionService(cc commands.ICheckCommand, ec commands.IExpandCommand, ls commands.ILookupSchemaCommand, le commands.ILookupEntityCommand) *PermissionService

NewPermissionService -

func (*PermissionService) CheckPermissions

func (service *PermissionService) CheckPermissions(ctx context.Context, request *base.PermissionCheckRequest) (response *base.PermissionCheckResponse, err error)

CheckPermissions -

func (*PermissionService) ExpandPermissions

func (service *PermissionService) ExpandPermissions(ctx context.Context, request *base.PermissionExpandRequest) (response *base.PermissionExpandResponse, err error)

ExpandPermissions -

func (*PermissionService) LookupEntity

func (service *PermissionService) LookupEntity(ctx context.Context, request *base.PermissionLookupEntityRequest) (response *base.PermissionLookupEntityResponse, err error)

LookupEntity -

func (*PermissionService) LookupEntityStream

func (service *PermissionService) LookupEntityStream(ctx context.Context, request *base.PermissionLookupEntityRequest, server base.Permission_LookupEntityStreamServer) (err error)

LookupEntityStream -

func (*PermissionService) LookupSchema

func (service *PermissionService) LookupSchema(ctx context.Context, request *base.PermissionLookupSchemaRequest) (response *base.PermissionLookupSchemaResponse, err error)

LookupSchema -

type RelationshipService

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

RelationshipService -

func NewRelationshipService

func NewRelationshipService(rr repositories.RelationshipReader, rw repositories.RelationshipWriter, sr repositories.SchemaReader) *RelationshipService

NewRelationshipService -

func (*RelationshipService) DeleteRelationships

func (service *RelationshipService) DeleteRelationships(ctx context.Context, filter *base.TupleFilter) (token.EncodedSnapToken, error)

DeleteRelationships -

func (*RelationshipService) ReadRelationships

func (service *RelationshipService) ReadRelationships(ctx context.Context, filter *base.TupleFilter, token string) (tuples database.ITupleCollection, err error)

ReadRelationships -

func (*RelationshipService) WriteRelationships

func (service *RelationshipService) WriteRelationships(ctx context.Context, tuples []*base.Tuple, version string) (token token.EncodedSnapToken, err error)

WriteRelationships -

type SchemaService

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

SchemaService -

func NewSchemaService

func NewSchemaService(sw repositories.SchemaWriter, sr repositories.SchemaReader) *SchemaService

NewSchemaService -

func (*SchemaService) ReadSchema

func (service *SchemaService) ReadSchema(ctx context.Context, version string) (response *base.IndexedSchema, err error)

ReadSchema -

func (*SchemaService) WriteSchema

func (service *SchemaService) WriteSchema(ctx context.Context, schema string) (response string, err error)

WriteSchema -