schema

Documentation

Index

• type SchemaLayer
  • func NewSchemaLayer(ruleID, streamName string, schema map[string]*ast.JsonStreamField, ...) *SchemaLayer
  • func (s *SchemaLayer) DetachSchema(ruleID string) error
  • func (s *SchemaLayer) GetSchema() map[string]*ast.JsonStreamField
  • func (s *SchemaLayer) MergeSchema(ruleID, dataSource string, newSchema map[string]*ast.JsonStreamField, ...) error

Types

type SchemaLayer

type SchemaLayer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSchemaLayer

func NewSchemaLayer(ruleID, streamName string, schema map[string]*ast.JsonStreamField, isWildcard bool) *SchemaLayer

func (*SchemaLayer) DetachSchema

func (s *SchemaLayer) DetachSchema(ruleID string) error

func (*SchemaLayer) GetSchema

func (s *SchemaLayer) GetSchema() map[string]*ast.JsonStreamField

func (*SchemaLayer) MergeSchema

func (s *SchemaLayer) MergeSchema(ruleID, dataSource string, newSchema map[string]*ast.JsonStreamField, isWildcard bool) error