decorators

Documentation

Index

• type RelationshipReaderWithCircuitBreaker
  • func NewRelationshipReaderWithCircuitBreaker(delegate repositories.RelationshipReader) *RelationshipReaderWithCircuitBreaker
  • func (r *RelationshipReaderWithCircuitBreaker) GetUniqueEntityIDsByEntityType(ctx context.Context, typ, token string) (array []string, err error)
  • func (r *RelationshipReaderWithCircuitBreaker) HeadSnapshot(ctx context.Context) (token.SnapToken, error)
  • func (r *RelationshipReaderWithCircuitBreaker) QueryRelationships(ctx context.Context, filter *base.TupleFilter, token string) (database.ITupleCollection, error)
• type RelationshipWriterWithCircuitBreaker
  • func NewRelationshipWriterWithCircuitBreaker(delegate repositories.RelationshipWriter) *RelationshipWriterWithCircuitBreaker
  • func (r *RelationshipWriterWithCircuitBreaker) DeleteRelationships(ctx context.Context, filter *base.TupleFilter) (token.EncodedSnapToken, error)
  • func (r *RelationshipWriterWithCircuitBreaker) WriteRelationships(ctx context.Context, collection database.ITupleCollection) (token.EncodedSnapToken, error)
• type SchemaReaderWithCache
  • func NewSchemaReaderWithCache(delegate repositories.SchemaReader, cache cache.Cache) *SchemaReaderWithCache
  • func (r *SchemaReaderWithCache) HeadVersion(ctx context.Context) (version string, err error)
  • func (r *SchemaReaderWithCache) ReadSchema(ctx context.Context, version string) (schema *base.IndexedSchema, err error)
  • func (r *SchemaReaderWithCache) ReadSchemaDefinition(ctx context.Context, entityType, version string) (definition *base.EntityDefinition, v string, err error)
• type SchemaReaderWithCircuitBreaker
  • func NewSchemaReaderWithCircuitBreaker(delegate repositories.SchemaReader) *SchemaReaderWithCircuitBreaker
  • func (r *SchemaReaderWithCircuitBreaker) HeadVersion(ctx context.Context) (version string, err error)
  • func (r *SchemaReaderWithCircuitBreaker) ReadSchema(ctx context.Context, version string) (*base.IndexedSchema, error)
  • func (r *SchemaReaderWithCircuitBreaker) ReadSchemaDefinition(ctx context.Context, entityType, version string) (*base.EntityDefinition, string, error)
• type SchemaWriterWithCircuitBreaker
  • func NewSchemaWriterWithCircuitBreaker(delegate repositories.SchemaWriter) *SchemaWriterWithCircuitBreaker
  • func (r *SchemaWriterWithCircuitBreaker) WriteSchema(ctx context.Context, definitions []repositories.SchemaDefinition) (string, error)

Types

type RelationshipReaderWithCircuitBreaker

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

RelationshipReaderWithCircuitBreaker - Add circuit breaker behaviour to relationship reader

func NewRelationshipReaderWithCircuitBreaker

func NewRelationshipReaderWithCircuitBreaker(delegate repositories.RelationshipReader) *RelationshipReaderWithCircuitBreaker

NewRelationshipReaderWithCircuitBreaker - Add circuit breaker behaviour to new relationship reader

func (*RelationshipReaderWithCircuitBreaker) GetUniqueEntityIDsByEntityType

func (r *RelationshipReaderWithCircuitBreaker) GetUniqueEntityIDsByEntityType(ctx context.Context, typ, token string) (array []string, err error)

GetUniqueEntityIDsByEntityType - Reads relation tuples from the repository

func (*RelationshipReaderWithCircuitBreaker) HeadSnapshot

func (r *RelationshipReaderWithCircuitBreaker) HeadSnapshot(ctx context.Context) (token.SnapToken, error)

HeadSnapshot - Reads the latest version of the snapshot from the repository.

func (*RelationshipReaderWithCircuitBreaker) QueryRelationships

func (r *RelationshipReaderWithCircuitBreaker) QueryRelationships(ctx context.Context, filter *base.TupleFilter, token string) (database.ITupleCollection, error)

QueryRelationships - Reads relation tuples from the repository

type RelationshipWriterWithCircuitBreaker

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

RelationshipWriterWithCircuitBreaker - Add circuit breaker behaviour to relationship writer

func NewRelationshipWriterWithCircuitBreaker

func NewRelationshipWriterWithCircuitBreaker(delegate repositories.RelationshipWriter) *RelationshipWriterWithCircuitBreaker

NewRelationshipWriterWithCircuitBreaker - Add circuit breaker behaviour to new relationship writer

func (*RelationshipWriterWithCircuitBreaker) DeleteRelationships

func (r *RelationshipWriterWithCircuitBreaker) DeleteRelationships(ctx context.Context, filter *base.TupleFilter) (token.EncodedSnapToken, error)

DeleteRelationships - Delete relation tuples from the repository

func (*RelationshipWriterWithCircuitBreaker) WriteRelationships

func (r *RelationshipWriterWithCircuitBreaker) WriteRelationships(ctx context.Context, collection database.ITupleCollection) (token.EncodedSnapToken, error)

WriteRelationships - Write relation tuples from the repository

type SchemaReaderWithCache

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

SchemaReaderWithCache - Add cache behaviour to schema reader

func NewSchemaReaderWithCache

func NewSchemaReaderWithCache(delegate repositories.SchemaReader, cache cache.Cache) *SchemaReaderWithCache

NewSchemaReaderWithCache new instance of SchemaReaderWithCache

func (*SchemaReaderWithCache) HeadVersion

func (r *SchemaReaderWithCache) HeadVersion(ctx context.Context) (version string, err error)

HeadVersion - Finds the latest version of the schema.

func (*SchemaReaderWithCache) ReadSchema

func (r *SchemaReaderWithCache) ReadSchema(ctx context.Context, version string) (schema *base.IndexedSchema, err error)

ReadSchema - Read schema from the repository

func (*SchemaReaderWithCache) ReadSchemaDefinition

func (r *SchemaReaderWithCache) ReadSchemaDefinition(ctx context.Context, entityType, version string) (definition *base.EntityDefinition, v string, err error)

ReadSchemaDefinition - Read schema definition from the repository

type SchemaReaderWithCircuitBreaker

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

SchemaReaderWithCircuitBreaker - Add circuit breaker behaviour to schema reader

func NewSchemaReaderWithCircuitBreaker

func NewSchemaReaderWithCircuitBreaker(delegate repositories.SchemaReader) *SchemaReaderWithCircuitBreaker

NewSchemaReaderWithCircuitBreaker - Add circuit breaker behaviour to new schema reader

func (*SchemaReaderWithCircuitBreaker) HeadVersion

func (r *SchemaReaderWithCircuitBreaker) HeadVersion(ctx context.Context) (version string, err error)

HeadVersion - Finds the latest version of the schema.

func (*SchemaReaderWithCircuitBreaker) ReadSchema

func (r *SchemaReaderWithCircuitBreaker) ReadSchema(ctx context.Context, version string) (*base.IndexedSchema, error)

ReadSchema - Read schema from repository

func (*SchemaReaderWithCircuitBreaker) ReadSchemaDefinition

func (r *SchemaReaderWithCircuitBreaker) ReadSchemaDefinition(ctx context.Context, entityType, version string) (*base.EntityDefinition, string, error)

ReadSchemaDefinition - Read schema definition from repository

type SchemaWriterWithCircuitBreaker

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

SchemaWriterWithCircuitBreaker - Add circuit breaker behaviour to schema writer

func NewSchemaWriterWithCircuitBreaker

func NewSchemaWriterWithCircuitBreaker(delegate repositories.SchemaWriter) *SchemaWriterWithCircuitBreaker

NewSchemaWriterWithCircuitBreaker - Add circuit breaker behaviour to new schema writer

func (*SchemaWriterWithCircuitBreaker) WriteSchema

func (r *SchemaWriterWithCircuitBreaker) WriteSchema(ctx context.Context, definitions []repositories.SchemaDefinition) (string, error)

WriteSchema - Write schema to repository