commands

Documentation

Index

• type CheckCombiner
• type CheckCommand
  • func NewCheckCommand(km keys.CommandKeyManager, sr repositories.SchemaReader, ...) (*CheckCommand, error)
  • func (command *CheckCommand) Execute(ctx context.Context, request *base.PermissionCheckRequest) (response *base.PermissionCheckResponse, err error)
• type CheckFunction
• type CheckOption
  • func ConcurrencyLimit(limit int) CheckOption
• type CheckResponse
• type ExpandCombiner
• type ExpandCommand
  • func NewExpandCommand(sr repositories.SchemaReader, rr repositories.RelationshipReader) *ExpandCommand
  • func (command *ExpandCommand) Execute(ctx context.Context, request *base.PermissionExpandRequest) (response *base.PermissionExpandResponse, err error)
• type ExpandFunction
• type ExpandResponse
• type ICheckCommand
• type IExpandCommand
• type ILookupEntityCommand
• type ILookupSchemaCommand
• type LookupEntityCommand
  • func NewLookupEntityCommand(ck ICheckCommand, sr repositories.SchemaReader, ...) *LookupEntityCommand
  • func (command *LookupEntityCommand) Execute(ctx context.Context, request *base.PermissionLookupEntityRequest) (response *base.PermissionLookupEntityResponse, err error)
  • func (command *LookupEntityCommand) Stream(ctx context.Context, request *base.PermissionLookupEntityRequest, ...) (err error)
• type LookupSchemaCommand
  • func NewLookupSchemaCommand(schemaReader repositories.SchemaReader) *LookupSchemaCommand
  • func (command *LookupSchemaCommand) Execute(ctx context.Context, request *base.PermissionLookupSchemaRequest) (*base.PermissionLookupSchemaResponse, error)
• type SchemaLookupCombiner
• type SchemaLookupDecision
• type SchemaLookupFunction

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

type SchemaLookupDecision struct {
	Can bool
	Err error
}

SchemaLookupDecision -

type SchemaLookupFunction

type SchemaLookupFunction func(ctx context.Context, lookupChan chan<- SchemaLookupDecision)

SchemaLookupFunction -