services

package
v0.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 7, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.3.0 

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 added in v0.3.0 

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

TenancyService -

func NewTenancyService added in v0.3.0 

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

NewTenancyService -

func (*TenancyService) CreateTenant added in v0.3.0 

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

CreateTenant -

func (*TenancyService) DeleteTenant added in v0.3.0 

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

DeleteTenant -

func (*TenancyService) ListTenants added in v0.3.0 

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

ListTenants -

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.