Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MergeErrors ¶
MergeErrors merges multiple channels of errors. Based on https://blog.golang.org/pipelines.
func WaitForPipeline ¶
WaitForPipeline waits for results from all error channels. It returns early on the first error.
Types ¶
type GQLManager ¶
type GQLManager struct { sync.Mutex Schema SchemaData UserId string ContextName string // contains filtered or unexported fields }
func NewGQLManager ¶
func NewGQLManager(userid, contextName string, db *deep6.Deep6DB) *GQLManager
func (*GQLManager) BuildSchemaFromJSONChannel ¶
func (gqm *GQLManager) BuildSchemaFromJSONChannel(iterator <-chan []byte) error
connects the schema builder to a channel providing json objects (typically the feed from the crdt manager) received objects will then be translated into gqphql-schema and fed to executor that will handle queries.
func (*GQLManager) Close ¶
func (gqm *GQLManager) Close() error
shut the schema-builder down gracefully, save schema for next restart of service.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.