decorators

Documentation

Index

• type EntityConfigWithCircuitBreaker
  • func NewEntityConfigWithCircuitBreaker(entityConfigRepository repositories.IEntityConfigRepository) *EntityConfigWithCircuitBreaker
  • func (r *EntityConfigWithCircuitBreaker) All(ctx context.Context, version string) (configs entities.EntityConfigs, err errors.Error)
  • func (r *EntityConfigWithCircuitBreaker) Migrate() (err errors.Error)
  • func (r *EntityConfigWithCircuitBreaker) Read(ctx context.Context, name string, version string) (config entities.EntityConfig, err errors.Error)
  • func (r *EntityConfigWithCircuitBreaker) Write(ctx context.Context, configs entities.EntityConfigs, version string) (err errors.Error)
• type RelationTupleWithCircuitBreaker
  • func NewRelationTupleWithCircuitBreaker(relationTupleRepository repositories.IRelationTupleRepository) *RelationTupleWithCircuitBreaker
  • func (r *RelationTupleWithCircuitBreaker) Delete(ctx context.Context, tuples entities.RelationTuples) (err errors.Error)
  • func (r *RelationTupleWithCircuitBreaker) Migrate() (err errors.Error)
  • func (r *RelationTupleWithCircuitBreaker) QueryTuples(ctx context.Context, entity string, objectID string, relation string) (tuples entities.RelationTuples, err errors.Error)
  • func (r *RelationTupleWithCircuitBreaker) Read(ctx context.Context, filter filters.RelationTupleFilter) (tuples entities.RelationTuples, err errors.Error)
  • func (r *RelationTupleWithCircuitBreaker) ReverseQueryTuples(ctx context.Context, entity string, relation string, subjectEntity string, ...) (tuples entities.RelationTuples, err errors.Error)
  • func (r *RelationTupleWithCircuitBreaker) Write(ctx context.Context, tuples entities.RelationTuples) (err errors.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 entities.EntityConfigs, err errors.Error)

All -

func (*EntityConfigWithCircuitBreaker) Migrate

func (r *EntityConfigWithCircuitBreaker) Migrate() (err errors.Error)

Migrate -

func (*EntityConfigWithCircuitBreaker) Read

func (r *EntityConfigWithCircuitBreaker) Read(ctx context.Context, name string, version string) (config entities.EntityConfig, err errors.Error)

Read -

func (*EntityConfigWithCircuitBreaker) Write

func (r *EntityConfigWithCircuitBreaker) Write(ctx context.Context, configs entities.EntityConfigs, version string) (err errors.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, tuples entities.RelationTuples) (err errors.Error)

Delete -

func (*RelationTupleWithCircuitBreaker) Migrate

func (r *RelationTupleWithCircuitBreaker) Migrate() (err errors.Error)

Migrate -

func (*RelationTupleWithCircuitBreaker) QueryTuples

func (r *RelationTupleWithCircuitBreaker) QueryTuples(ctx context.Context, entity string, objectID string, relation string) (tuples entities.RelationTuples, err errors.Error)

QueryTuples -

func (*RelationTupleWithCircuitBreaker) Read

func (r *RelationTupleWithCircuitBreaker) Read(ctx context.Context, filter filters.RelationTupleFilter) (tuples entities.RelationTuples, err errors.Error)

Read -

func (*RelationTupleWithCircuitBreaker) ReverseQueryTuples

func (r *RelationTupleWithCircuitBreaker) ReverseQueryTuples(ctx context.Context, entity string, relation string, subjectEntity string, subjectIDs []string, subjectRelation string) (tuples entities.RelationTuples, err errors.Error)

ReverseQueryTuples -

func (*RelationTupleWithCircuitBreaker) Write

func (r *RelationTupleWithCircuitBreaker) Write(ctx context.Context, tuples entities.RelationTuples) (err errors.Error)

Write -