persistence

Feb 9, 2021

Changes in this version

+ var ErrCreateRevisionNotAllowed = errors.New(...)

+ var ErrSetResourceMappingNotAllowed = errors.New(...)

type MappingsReader

+ func (mr MappingsReader) ListTenants(ctx context.Context) ([]string, error)

+ type MappingsWriter struct

+ func NewMappingWriter(log restql.Logger, env domain.EnvSource, local map[string]string, ...) MappingsWriter

+ func (mw *MappingsWriter) Write(ctx context.Context, tenant string, resource string, url string) error

type QueryReader

+ func (qr QueryReader) ListNamespaces(ctx context.Context) ([]string, error)

+ func (qr QueryReader) ListQueriesForNamespace(ctx context.Context, namespace string) (map[string][]restql.SavedQuery, error)

+ func (qr QueryReader) ListQueryRevisions(ctx context.Context, namespace string, queryName string) ([]restql.SavedQuery, error)

+ type QueryWriter struct

+ func NewQueryWriter(log restql.Logger, local map[string]map[string][]string, db Database) QueryWriter

+ func (qw QueryWriter) Write(ctx context.Context, namespace, name, content string) error

Sep 21, 2020

Changes in this version

+ type Database interface

+ FindMappingsForTenant func(ctx context.Context, tenantID string) ([]restql.Mapping, error)

+ FindQuery func(ctx context.Context, namespace string, name string, revision int) (restql.SavedQuery, error)

+ func NewDatabase(log restql.Logger) (Database, error)

+ type MappingsReader struct

+ func NewMappingReader(log restql.Logger, env domain.EnvSource, local map[string]string, db Database) MappingsReader

+ func (mr MappingsReader) FromTenant(ctx context.Context, tenant string) (map[string]restql.Mapping, error)

+ type QueryReader struct

+ func NewQueryReader(log restql.Logger, local map[string]map[string][]string, db Database) QueryReader

+ func (qr QueryReader) Get(ctx context.Context, namespace, id string, revision int) (restql.SavedQuery, error)