Documentation
¶
Index ¶
- type RelationshipReaderWithCircuitBreaker
- func (r *RelationshipReaderWithCircuitBreaker) GetUniqueEntityIDsByEntityType(ctx context.Context, tenantID string, typ, token string) (array []string, err error)
- func (r *RelationshipReaderWithCircuitBreaker) HeadSnapshot(ctx context.Context, tenantID string) (token.SnapToken, error)
- func (r *RelationshipReaderWithCircuitBreaker) QueryRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, token string) (*database.TupleIterator, error)
- func (r *RelationshipReaderWithCircuitBreaker) ReadRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, snap string, ...) (collection *database.TupleCollection, ct database.EncodedContinuousToken, ...)
- type RelationshipWriterWithCircuitBreaker
- func (r *RelationshipWriterWithCircuitBreaker) DeleteRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter) (token.EncodedSnapToken, error)
- func (r *RelationshipWriterWithCircuitBreaker) WriteRelationships(ctx context.Context, tenantID string, collection *database.TupleCollection) (token.EncodedSnapToken, error)
- type SchemaReaderWithCache
- func (r *SchemaReaderWithCache) HeadVersion(ctx context.Context, tenantID string) (version string, err error)
- func (r *SchemaReaderWithCache) ReadSchema(ctx context.Context, tenantID string, version string) (schema *base.SchemaDefinition, err error)
- func (r *SchemaReaderWithCache) ReadSchemaDefinition(ctx context.Context, tenantID, entityType, version string) (definition *base.EntityDefinition, v string, err error)
- type SchemaReaderWithCircuitBreaker
- func (r *SchemaReaderWithCircuitBreaker) HeadVersion(ctx context.Context, tenantID string) (version string, err error)
- func (r *SchemaReaderWithCircuitBreaker) ReadSchema(ctx context.Context, tenantID string, version string) (*base.SchemaDefinition, error)
- func (r *SchemaReaderWithCircuitBreaker) ReadSchemaDefinition(ctx context.Context, tenantID, entityType, version string) (*base.EntityDefinition, string, error)
- type SchemaWriterWithCircuitBreaker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, tenantID string, typ, token string) (array []string, err error)
GetUniqueEntityIDsByEntityType - Reads relation tuples from the repository
func (*RelationshipReaderWithCircuitBreaker) HeadSnapshot ¶
func (r *RelationshipReaderWithCircuitBreaker) HeadSnapshot(ctx context.Context, tenantID string) (token.SnapToken, error)
HeadSnapshot - Reads the latest version of the snapshot from the repository.
func (*RelationshipReaderWithCircuitBreaker) QueryRelationships ¶
func (r *RelationshipReaderWithCircuitBreaker) QueryRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, token string) (*database.TupleIterator, error)
QueryRelationships - Reads relation tuples from the repository
func (*RelationshipReaderWithCircuitBreaker) ReadRelationships ¶
func (r *RelationshipReaderWithCircuitBreaker) ReadRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, snap string, pagination database.Pagination) (collection *database.TupleCollection, ct database.EncodedContinuousToken, err error)
ReadRelationships reads relation tuples from the repository with different options.
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, tenantID string, filter *base.TupleFilter) (token.EncodedSnapToken, error)
DeleteRelationships - Delete relation tuples from the repository
func (*RelationshipWriterWithCircuitBreaker) WriteRelationships ¶
func (r *RelationshipWriterWithCircuitBreaker) WriteRelationships(ctx context.Context, tenantID string, collection *database.TupleCollection) (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, tenantID string) (version string, err error)
HeadVersion - Finds the latest version of the schema.
func (*SchemaReaderWithCache) ReadSchema ¶
func (r *SchemaReaderWithCache) ReadSchema(ctx context.Context, tenantID string, version string) (schema *base.SchemaDefinition, err error)
ReadSchema - Read schema from the repository
func (*SchemaReaderWithCache) ReadSchemaDefinition ¶
func (r *SchemaReaderWithCache) ReadSchemaDefinition(ctx context.Context, tenantID, 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, tenantID string) (version string, err error)
HeadVersion - Finds the latest version of the schema.
func (*SchemaReaderWithCircuitBreaker) ReadSchema ¶
func (r *SchemaReaderWithCircuitBreaker) ReadSchema(ctx context.Context, tenantID string, version string) (*base.SchemaDefinition, error)
ReadSchema - Read schema from repository
func (*SchemaReaderWithCircuitBreaker) ReadSchemaDefinition ¶
func (r *SchemaReaderWithCircuitBreaker) ReadSchemaDefinition(ctx context.Context, tenantID, 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) error
WriteSchema - Write schema to repository
Source Files