Versions in this module Expand all Collapse all v0 v0.1.0 Dec 9, 2019 Changes in this version + func NewExecutableSchema(cfg Config) graphql.ExecutableSchema + type ComplexityRoot struct + Query struct{ ... } + Record struct{ ... } + Subscription struct{ ... } + Topic struct{ ... } + type Config struct + Complexity ComplexityRoot + Directives DirectiveRoot + Resolvers ResolverRoot + type DirectiveRoot struct + type QueryResolver interface + GetTopics func(ctx context.Context) ([]*models.Topic, error) + type ResolverRoot interface + Query func() QueryResolver + Subscription func() SubscriptionResolver + type Run struct + func NewServer(client *kafka.Service) *Run + func (r *Run) Start(ctx context.Context, route string, port int) func() error + type SubscriptionResolver interface + RecordAdded func(ctx context.Context, topic string, key string) (<-chan *models.Record, error)
Go to main page