schema

type BSONType string

type ClusterSchema struct {
	MongosEndpoint       string              `json:"mongosEndpoint"`
	Annotations          map[string]string   `json:"annotations,omitempty"`
	Databases            map[string]Database `json:"dbs"`
	DenyUnknownDatabases bool                `json:"denyUnknownDatabases,omitempty"`
}

type Collection struct {
	Annotations map[string]string `json:"annotations,omitempty"`
	// All the columns in this table
	Fields map[string]CollectionField `json:"fields"`
	// Whether we should strictly enforce fields or allow others
	DenyUnknownFields bool `json:"denyUnknownFields,omitempty"`
	// Whether we should enforce schema check for this collection
	EnforceSchema bool `json:"enforceSchema,omitempty"`
	// Whether we should enforce schema check logonly for this collection
	EnforceSchemaByCollectionLogOnly bool `json:"enforceSchemaByCollectionLogOnly,omitempty"`
}

type CollectionField struct {
	Name string   `json:"alias,omitempty"`
	Type BSONType `json:"type"`

	Annotations map[string]string `json:"annotations,omitempty"`

	// Various configuration options
	Required bool `json:"required,omitempty"`

	// Field is a array type
	IsArray bool

	// Optional subfields
	SubFields map[string]CollectionField `json:"subfields,omitempty"`
	// contains filtered or unexported fields
}

type Database struct {
	Annotations            map[string]string     `json:"annotations,omitempty"`
	Collections            map[string]Collection `json:"collections"`
	DenyUnknownCollections bool                  `json:"denyUnknownCollections,omitempty"`
}

type SchemaLoader interface {
	// Load returns a bool (whether something was loaded) + error
	Load(ctx context.Context, glob string) error
	// Querier returns a querier of the current loaded config. The
	// returned querier must provide a consistent view over the data
	// (this way we get consistent schema enforcement throughout
	// all calls in a single request)
	Querier() SchemaQuerier
}

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

type SchemaPluginConfig struct {
	// SchemaPath is the path on disk to the schema file to load + watch for changes
	SchemaPath string `bson:"schemaPath"`
	// Log EnforceSchema errors
	EnforceSchemaLogOnly bool `bson:"enforceSchemaLogOnly"`
}

type SchemaQuerier interface {
	SchemaValidator
}

type SchemaValidator interface {
	// ValidateInsert will validate the schema of the passed in object.
	ValidateInsert(ctx context.Context, database, collection string, obj bson.D) error
	// ValidateUpdate will validate the schema of the passed in object.
	ValidateUpdate(ctx context.Context, database, collection string, obj bson.D) error
}

type WalkCollectionFieldsFunc func(string, *CollectionField) error