Documentation
      ¶
    
    
  
    
  
    Index ¶
- type CheckCombiner
 - type CheckCommand
 - type CheckFunction
 - type CheckOption
 - type CheckResponse
 - type ExpandCombiner
 - type ExpandCommand
 - type ExpandFunction
 - type ExpandResponse
 - type ICheckCommand
 - type IExpandCommand
 - type ILookupEntityCommand
 - type ILookupSchemaCommand
 - type LookupEntityCommand
 - type LookupSchemaCommand
 - type SchemaLookupCombiner
 - type SchemaLookupDecision
 - type SchemaLookupFunction
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckCombiner ¶
type CheckCombiner func(ctx context.Context, functions []CheckFunction, limit int) (*base.PermissionCheckResponse, error)
CheckCombiner .
type CheckCommand ¶
type CheckCommand struct {
	// contains filtered or unexported fields
}
    CheckCommand -
func NewCheckCommand ¶
func NewCheckCommand(km keys.CommandKeyManager, sr repositories.SchemaReader, rr repositories.RelationshipReader, m metric.Meter, opts ...CheckOption) (*CheckCommand, error)
NewCheckCommand -
func (*CheckCommand) Execute ¶
func (command *CheckCommand) Execute(ctx context.Context, request *base.PermissionCheckRequest) (response *base.PermissionCheckResponse, err error)
Execute - there are two option for request's permission field. - relation - action
type CheckFunction ¶
type CheckFunction func(ctx context.Context) (*base.PermissionCheckResponse, error)
CheckFunction -
type CheckOption ¶
type CheckOption func(*CheckCommand)
CheckOption - Option type
func ConcurrencyLimit ¶
func ConcurrencyLimit(limit int) CheckOption
ConcurrencyLimit - Defines concurrency limit
type CheckResponse ¶
type CheckResponse struct {
	// contains filtered or unexported fields
}
    CheckResponse -
type ExpandCombiner ¶
type ExpandCombiner func(ctx context.Context, functions []ExpandFunction) ExpandResponse
ExpandCombiner .
type ExpandCommand ¶
type ExpandCommand struct {
	// contains filtered or unexported fields
}
    ExpandCommand -
func NewExpandCommand ¶
func NewExpandCommand(sr repositories.SchemaReader, rr repositories.RelationshipReader) *ExpandCommand
NewExpandCommand -
func (*ExpandCommand) Execute ¶
func (command *ExpandCommand) Execute(ctx context.Context, request *base.PermissionExpandRequest) (response *base.PermissionExpandResponse, err error)
Execute -
type ExpandFunction ¶
type ExpandFunction func(ctx context.Context, expandChain chan<- ExpandResponse)
ExpandFunction -
type ExpandResponse ¶
type ExpandResponse struct {
	Response *base.PermissionExpandResponse
	Err      error
}
    ExpandResponse -
type ICheckCommand ¶
type ICheckCommand interface {
	Execute(ctx context.Context, request *base.PermissionCheckRequest) (response *base.PermissionCheckResponse, err error)
}
    ICheckCommand -
type IExpandCommand ¶
type IExpandCommand interface {
	Execute(ctx context.Context, request *base.PermissionExpandRequest) (response *base.PermissionExpandResponse, err error)
}
    IExpandCommand -
type ILookupEntityCommand ¶
type ILookupEntityCommand interface {
	Execute(ctx context.Context, request *base.PermissionLookupEntityRequest) (response *base.PermissionLookupEntityResponse, err error)
	Stream(ctx context.Context, request *base.PermissionLookupEntityRequest, server base.Permission_LookupEntityStreamServer) (err error)
}
    ILookupEntityCommand -
type ILookupSchemaCommand ¶
type ILookupSchemaCommand interface {
	Execute(ctx context.Context, request *base.PermissionLookupSchemaRequest) (response *base.PermissionLookupSchemaResponse, err error)
}
    ILookupSchemaCommand -
type LookupEntityCommand ¶
type LookupEntityCommand struct {
	// contains filtered or unexported fields
}
    LookupEntityCommand -
func NewLookupEntityCommand ¶
func NewLookupEntityCommand(ck ICheckCommand, sr repositories.SchemaReader, rr repositories.RelationshipReader) *LookupEntityCommand
NewLookupEntityCommand -
func (*LookupEntityCommand) Execute ¶
func (command *LookupEntityCommand) Execute(ctx context.Context, request *base.PermissionLookupEntityRequest) (response *base.PermissionLookupEntityResponse, err error)
Execute -
func (*LookupEntityCommand) Stream ¶
func (command *LookupEntityCommand) Stream(ctx context.Context, request *base.PermissionLookupEntityRequest, server base.Permission_LookupEntityStreamServer) (err error)
Stream -
type LookupSchemaCommand ¶
type LookupSchemaCommand struct {
	// contains filtered or unexported fields
}
    LookupSchemaCommand -
func NewLookupSchemaCommand ¶
func NewLookupSchemaCommand(schemaReader repositories.SchemaReader) *LookupSchemaCommand
NewLookupSchemaCommand -
func (*LookupSchemaCommand) Execute ¶
func (command *LookupSchemaCommand) Execute(ctx context.Context, request *base.PermissionLookupSchemaRequest) (*base.PermissionLookupSchemaResponse, error)
Execute -
type SchemaLookupCombiner ¶
type SchemaLookupCombiner func(ctx context.Context, functions []SchemaLookupFunction) SchemaLookupDecision
SchemaLookupCombiner .
type SchemaLookupDecision ¶
SchemaLookupDecision -
type SchemaLookupFunction ¶
type SchemaLookupFunction func(ctx context.Context, lookupChan chan<- SchemaLookupDecision)
SchemaLookupFunction -
 Click to show internal directories. 
   Click to hide internal directories.