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) ListSchemas(ctx context.Context, tenantID string, pagination database.Pagination) (schemas []*base.SchemaList, ct database.EncodedContinuousToken, 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)
  • func (r *SchemaReader) ReadSchemaString(ctx context.Context, tenantID, version string) (definitions []string, 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) ListSchemas

func (r *SchemaReader) ListSchemas(ctx context.Context, tenantID string, pagination database.Pagination) (schemas []*base.SchemaList, ct database.EncodedContinuousToken, err error)

ListSchemas - List all Schemas

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 returns the schema definition for a specific tenant and version as a structured object.

func (*SchemaReader) ReadSchemaString

func (r *SchemaReader) ReadSchemaString(ctx context.Context, tenantID, version string) (definitions []string, err error)

ReadSchemaString returns the schema definition for a specific tenant and version as a string.