services

Documentation

Index

• type IPermissionService
• type IRelationshipService
• type ISchemaService
• type ITenancyService
• 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, tenantID string, filter *base.TupleFilter) (token.EncodedSnapToken, error)
  • func (service *RelationshipService) ReadRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, snap string, ...) (tuples *database.TupleCollection, ct database.EncodedContinuousToken, ...)
  • func (service *RelationshipService) WriteRelationships(ctx context.Context, tenantID string, 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, tenantID, version string) (response *base.SchemaDefinition, err error)
  • func (service *SchemaService) WriteSchema(ctx context.Context, tenantID, schema string) (response string, err error)
• type TenancyService
  • func NewTenancyService(tw repositories.TenantWriter, tr repositories.TenantReader) *TenancyService
  • func (s *TenancyService) CreateTenant(ctx context.Context, id, name string) (tenant *base.Tenant, err error)
  • func (s *TenancyService) DeleteTenant(ctx context.Context, tenantID string) (tenant *base.Tenant, err error)
  • func (s *TenancyService) ListTenants(ctx context.Context, size uint32, ct string) (tenants []*base.Tenant, continuousToken database.EncodedContinuousToken, ...)

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, tenantID string, filter *base.TupleFilter, snap string, size uint32, continuousToken string) (*database.TupleCollection, database.EncodedContinuousToken, error)
	WriteRelationships(ctx context.Context, tenantID string, tuples []*base.Tuple, version string) (token.EncodedSnapToken, error)
	DeleteRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter) (token.EncodedSnapToken, error)
}

IRelationshipService -

type ISchemaService

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

ISchemaService -

type ITenancyService

type ITenancyService interface {
	CreateTenant(ctx context.Context, id, name string) (tenant *base.Tenant, err error)
	DeleteTenant(ctx context.Context, tenantID string) (tenant *base.Tenant, err error)
	ListTenants(ctx context.Context, size uint32, ct string) (tenants []*base.Tenant, continuousToken database.EncodedContinuousToken, err error)
}

ITenancyService -

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, tenantID string, filter *base.TupleFilter) (token.EncodedSnapToken, error)

DeleteRelationships -

func (*RelationshipService) ReadRelationships

func (service *RelationshipService) ReadRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, snap string, size uint32, continuousToken string) (tuples *database.TupleCollection, ct database.EncodedContinuousToken, err error)

ReadRelationships -

func (*RelationshipService) WriteRelationships

func (service *RelationshipService) WriteRelationships(ctx context.Context, tenantID string, 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, tenantID, version string) (response *base.SchemaDefinition, err error)

ReadSchema -

func (*SchemaService) WriteSchema

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

WriteSchema -

type TenancyService

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

TenancyService -

func NewTenancyService

func NewTenancyService(tw repositories.TenantWriter, tr repositories.TenantReader) *TenancyService

NewTenancyService -

func (*TenancyService) CreateTenant

func (s *TenancyService) CreateTenant(ctx context.Context, id, name string) (tenant *base.Tenant, err error)

CreateTenant -

func (*TenancyService) DeleteTenant

func (s *TenancyService) DeleteTenant(ctx context.Context, tenantID string) (tenant *base.Tenant, err error)

DeleteTenant -

func (*TenancyService) ListTenants

func (s *TenancyService) ListTenants(ctx context.Context, size uint32, ct string) (tenants []*base.Tenant, continuousToken database.EncodedContinuousToken, err error)

ListTenants -