cache

Documentation

Index

• type SchemaReader
  • func NewSchemaReader(delegate storage.SchemaReader, cache cache.Cache) *SchemaReader
  • func (r *SchemaReader) HeadVersion(ctx context.Context, tenantID string) (version string, err error)
  • func (r *SchemaReader) ReadEntityDefinition(ctx context.Context, tenantID, entityName, version string) (definition *base.EntityDefinition, v string, err error)
  • func (r *SchemaReader) ReadRuleDefinition(ctx context.Context, tenantID, ruleName, version string) (definition *base.RuleDefinition, v string, err error)
  • func (r *SchemaReader) ReadSchema(ctx context.Context, tenantID, version string) (schema *base.SchemaDefinition, err error)

Types

type SchemaReader

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

SchemaReader - Add cache behaviour to schema reader

func NewSchemaReader

func NewSchemaReader(delegate storage.SchemaReader, cache cache.Cache) *SchemaReader

NewSchemaReader new instance of SchemaReader

func (*SchemaReader) HeadVersion

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

HeadVersion - Finds the latest version of the schema.

func (*SchemaReader) ReadEntityDefinition

func (r *SchemaReader) ReadEntityDefinition(ctx context.Context, tenantID, entityName, version string) (definition *base.EntityDefinition, v string, err error)

ReadEntityDefinition - Read entity definition from the repository

func (*SchemaReader) ReadRuleDefinition

func (r *SchemaReader) ReadRuleDefinition(ctx context.Context, tenantID, ruleName, version string) (definition *base.RuleDefinition, v string, err error)

ReadRuleDefinition - Read rule definition from the repository

func (*SchemaReader) ReadSchema

func (r *SchemaReader) ReadSchema(ctx context.Context, tenantID, version string) (schema *base.SchemaDefinition, err error)

ReadSchema - Read schema from the repository