decorators

Documentation

Index

• type EntityConfigWithCircuitBreaker
  • func NewEntityConfigWithCircuitBreaker(entityConfigRepository repositories.IEntityConfigRepository) *EntityConfigWithCircuitBreaker
  • func (r *EntityConfigWithCircuitBreaker) All(ctx context.Context, version string) (configs []repositories.EntityConfig, err error)
  • func (r *EntityConfigWithCircuitBreaker) Migrate() (err error)
  • func (r *EntityConfigWithCircuitBreaker) Read(ctx context.Context, name string, version string) (config repositories.EntityConfig, err error)
  • func (r *EntityConfigWithCircuitBreaker) Write(ctx context.Context, configs []repositories.EntityConfig, version string) (err error)
• type RelationTupleWithCircuitBreaker
  • func NewRelationTupleWithCircuitBreaker(relationTupleRepository repositories.IRelationTupleRepository) *RelationTupleWithCircuitBreaker
  • func (r *RelationTupleWithCircuitBreaker) Delete(ctx context.Context, iterator tuple.ITupleIterator) (err error)
  • func (r *RelationTupleWithCircuitBreaker) Migrate() (err error)
  • func (r *RelationTupleWithCircuitBreaker) QueryTuples(ctx context.Context, entity string, objectID string, relation string) (Iterator tuple.ITupleIterator, err error)
  • func (r *RelationTupleWithCircuitBreaker) Read(ctx context.Context, filter *base.TupleFilter) (collection tuple.ITupleCollection, err error)
  • func (r *RelationTupleWithCircuitBreaker) ReverseQueryTuples(ctx context.Context, entity string, relation string, subjectEntity string, ...) (Iterator tuple.ITupleIterator, err error)
  • func (r *RelationTupleWithCircuitBreaker) Write(ctx context.Context, iterator tuple.ITupleIterator) (err error)

Types

type EntityConfigWithCircuitBreaker

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

EntityConfigWithCircuitBreaker -

func NewEntityConfigWithCircuitBreaker

func NewEntityConfigWithCircuitBreaker(entityConfigRepository repositories.IEntityConfigRepository) *EntityConfigWithCircuitBreaker

NewEntityConfigWithCircuitBreaker -.

func (*EntityConfigWithCircuitBreaker) All

func (r *EntityConfigWithCircuitBreaker) All(ctx context.Context, version string) (configs []repositories.EntityConfig, err error)

All -

func (*EntityConfigWithCircuitBreaker) Migrate

func (r *EntityConfigWithCircuitBreaker) Migrate() (err error)

Migrate -

func (*EntityConfigWithCircuitBreaker) Read

func (r *EntityConfigWithCircuitBreaker) Read(ctx context.Context, name string, version string) (config repositories.EntityConfig, err error)

Read -

func (*EntityConfigWithCircuitBreaker) Write

func (r *EntityConfigWithCircuitBreaker) Write(ctx context.Context, configs []repositories.EntityConfig, version string) (err error)

Write -

type RelationTupleWithCircuitBreaker

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

RelationTupleWithCircuitBreaker -

func NewRelationTupleWithCircuitBreaker

func NewRelationTupleWithCircuitBreaker(relationTupleRepository repositories.IRelationTupleRepository) *RelationTupleWithCircuitBreaker

NewRelationTupleWithCircuitBreaker -.

func (*RelationTupleWithCircuitBreaker) Delete

func (r *RelationTupleWithCircuitBreaker) Delete(ctx context.Context, iterator tuple.ITupleIterator) (err error)

Delete -

func (*RelationTupleWithCircuitBreaker) Migrate

func (r *RelationTupleWithCircuitBreaker) Migrate() (err error)

Migrate -

func (*RelationTupleWithCircuitBreaker) QueryTuples

func (r *RelationTupleWithCircuitBreaker) QueryTuples(ctx context.Context, entity string, objectID string, relation string) (Iterator tuple.ITupleIterator, err error)

QueryTuples -

func (*RelationTupleWithCircuitBreaker) Read

func (r *RelationTupleWithCircuitBreaker) Read(ctx context.Context, filter *base.TupleFilter) (collection tuple.ITupleCollection, err error)

Read -

func (*RelationTupleWithCircuitBreaker) ReverseQueryTuples

func (r *RelationTupleWithCircuitBreaker) ReverseQueryTuples(ctx context.Context, entity string, relation string, subjectEntity string, subjectIDs []string, subjectRelation string) (Iterator tuple.ITupleIterator, err error)

ReverseQueryTuples -

func (*RelationTupleWithCircuitBreaker) Write

func (r *RelationTupleWithCircuitBreaker) Write(ctx context.Context, iterator tuple.ITupleIterator) (err error)

Write -