generated

type ComplexityRoot struct {
	Component struct {
		DependsOn   func(childComplexity int) int
		Description func(childComplexity int) int
		ID          func(childComplexity int) int
		Name        func(childComplexity int) int
		Processors  func(childComplexity int) int
		Service     func(childComplexity int) int
		Sinks       func(childComplexity int) int
		Sources     func(childComplexity int) int
		ViewSinks   func(childComplexity int) int
		ViewSources func(childComplexity int) int
		Views       func(childComplexity int) int
	}

	GetState struct {
		Message func(childComplexity int) int
		Topic   func(childComplexity int) int
		Value   func(childComplexity int) int
	}

	Input struct {
		Message func(childComplexity int) int
		Topic   func(childComplexity int) int
		Value   func(childComplexity int) int
	}

	Join struct {
		Message func(childComplexity int) int
		Topic   func(childComplexity int) int
		Value   func(childComplexity int) int
	}

	Lookup struct {
		Key     func(childComplexity int) int
		Message func(childComplexity int) int
		Topic   func(childComplexity int) int
		Value   func(childComplexity int) int
	}

	Operation struct {
		Actions   func(childComplexity int) int
		EndTime   func(childComplexity int) int
		Input     func(childComplexity int) int
		StartTime func(childComplexity int) int
	}

	Output struct {
		Key     func(childComplexity int) int
		Message func(childComplexity int) int
		Topic   func(childComplexity int) int
		Value   func(childComplexity int) int
	}

	Pod struct {
		ID          func(childComplexity int) int
		Name        func(childComplexity int) int
		Processors  func(childComplexity int) int
		Sinks       func(childComplexity int) int
		Sources     func(childComplexity int) int
		ViewSinks   func(childComplexity int) int
		ViewSources func(childComplexity int) int
		Views       func(childComplexity int) int
	}

	Processor struct {
		Component   func(childComplexity int) int
		Description func(childComplexity int) int
		GroupName   func(childComplexity int) int
		ID          func(childComplexity int) int
		Inputs      func(childComplexity int) int
		Joins       func(childComplexity int) int
		Lookups     func(childComplexity int) int
		Name        func(childComplexity int) int
		Outputs     func(childComplexity int) int
		Persistence func(childComplexity int) int
		Pods        func(childComplexity int) int
	}

	ProcessorInput struct {
		ID        func(childComplexity int) int
		Processor func(childComplexity int) int
		Topic     func(childComplexity int) int
	}

	ProcessorJoin struct {
		ID        func(childComplexity int) int
		Processor func(childComplexity int) int
		Topic     func(childComplexity int) int
	}

	ProcessorLookup struct {
		ID        func(childComplexity int) int
		Processor func(childComplexity int) int
		Topic     func(childComplexity int) int
	}

	ProcessorOutput struct {
		ID        func(childComplexity int) int
		Processor func(childComplexity int) int
		Topic     func(childComplexity int) int
	}

	Query struct {
		ComponentByID func(childComplexity int, id int) int
		Pods          func(childComplexity int) int
		ServiceByID   func(childComplexity int, id int) int
		Services      func(childComplexity int) int
		Topics        func(childComplexity int) int
	}

	Service struct {
		Components  func(childComplexity int) int
		DependsOn   func(childComplexity int) int
		Description func(childComplexity int) int
		ID          func(childComplexity int) int
		Name        func(childComplexity int) int
	}

	SetState struct {
		Message func(childComplexity int) int
		Topic   func(childComplexity int) int
		Value   func(childComplexity int) int
	}

	Sink struct {
		Component   func(childComplexity int) int
		Description func(childComplexity int) int
		ID          func(childComplexity int) int
		Name        func(childComplexity int) int
		Pods        func(childComplexity int) int
		Topic       func(childComplexity int) int
	}

	Source struct {
		Component func(childComplexity int) int
		ID        func(childComplexity int) int
		Pods      func(childComplexity int) int
		Topic     func(childComplexity int) int
	}

	Subscription struct {
		WatchProcessor func(childComplexity int, options *model.WatchProcessorInput) int
	}

	Topic struct {
		ID                    func(childComplexity int) int
		Message               func(childComplexity int) int
		Name                  func(childComplexity int) int
		ProcessorInputs       func(childComplexity int) int
		ProcessorJoins        func(childComplexity int) int
		ProcessorLookups      func(childComplexity int) int
		ProcessorOutputs      func(childComplexity int) int
		ProcessorPersistences func(childComplexity int) int
		Sinks                 func(childComplexity int) int
		Sources               func(childComplexity int) int
		ViewSinks             func(childComplexity int) int
		ViewSources           func(childComplexity int) int
		Views                 func(childComplexity int) int
	}

	View struct {
		Component func(childComplexity int) int
		ID        func(childComplexity int) int
		Pods      func(childComplexity int) int
		Topic     func(childComplexity int) int
	}

	ViewSink struct {
		Component   func(childComplexity int) int
		Description func(childComplexity int) int
		ID          func(childComplexity int) int
		Name        func(childComplexity int) int
		Pods        func(childComplexity int) int
		Topic       func(childComplexity int) int
	}

	ViewSource struct {
		Component   func(childComplexity int) int
		Description func(childComplexity int) int
		ID          func(childComplexity int) int
		Name        func(childComplexity int) int
		Pods        func(childComplexity int) int
		Topic       func(childComplexity int) int
	}
}

type ComponentResolver interface {
	Service(ctx context.Context, obj *model.Component) (*model.Service, error)

	Processors(ctx context.Context, obj *model.Component) ([]*model.Processor, error)
	Sinks(ctx context.Context, obj *model.Component) ([]*model.Sink, error)
	Sources(ctx context.Context, obj *model.Component) ([]*model.Source, error)
	ViewSinks(ctx context.Context, obj *model.Component) ([]*model.ViewSink, error)
	ViewSources(ctx context.Context, obj *model.Component) ([]*model.ViewSource, error)
	Views(ctx context.Context, obj *model.Component) ([]*model.View, error)
	DependsOn(ctx context.Context, obj *model.Component) ([]*model.Component, error)
}

type Config struct {
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type DirectiveRoot struct {
}

type PodResolver interface {
	Processors(ctx context.Context, obj *model.Pod) ([]*model.Processor, error)
	Sinks(ctx context.Context, obj *model.Pod) ([]*model.Sink, error)
	Sources(ctx context.Context, obj *model.Pod) ([]*model.Source, error)
	ViewSinks(ctx context.Context, obj *model.Pod) ([]*model.ViewSink, error)
	ViewSources(ctx context.Context, obj *model.Pod) ([]*model.ViewSource, error)
	Views(ctx context.Context, obj *model.Pod) ([]*model.View, error)
}

type ProcessorInputResolver interface {
	Processor(ctx context.Context, obj *model.ProcessorInput) (*model.Processor, error)
	Topic(ctx context.Context, obj *model.ProcessorInput) (*model.Topic, error)
}

type ProcessorJoinResolver interface {
	Processor(ctx context.Context, obj *model.ProcessorJoin) (*model.Processor, error)
	Topic(ctx context.Context, obj *model.ProcessorJoin) (*model.Topic, error)
}

type ProcessorLookupResolver interface {
	Processor(ctx context.Context, obj *model.ProcessorLookup) (*model.Processor, error)
	Topic(ctx context.Context, obj *model.ProcessorLookup) (*model.Topic, error)
}

type ProcessorOutputResolver interface {
	Processor(ctx context.Context, obj *model.ProcessorOutput) (*model.Processor, error)
	Topic(ctx context.Context, obj *model.ProcessorOutput) (*model.Topic, error)
}

type ProcessorResolver interface {
	Component(ctx context.Context, obj *model.Processor) (*model.Component, error)

	Persistence(ctx context.Context, obj *model.Processor) (*model.Topic, error)
	Pods(ctx context.Context, obj *model.Processor) ([]*model.Pod, error)
	Inputs(ctx context.Context, obj *model.Processor) ([]*model.ProcessorInput, error)
	Joins(ctx context.Context, obj *model.Processor) ([]*model.ProcessorJoin, error)
	Lookups(ctx context.Context, obj *model.Processor) ([]*model.ProcessorLookup, error)
	Outputs(ctx context.Context, obj *model.Processor) ([]*model.ProcessorOutput, error)
}

type QueryResolver interface {
	Services(ctx context.Context) ([]*model.Service, error)
	Pods(ctx context.Context) ([]*model.Pod, error)
	Topics(ctx context.Context) ([]*model.Topic, error)
	ServiceByID(ctx context.Context, id int) (*model.Service, error)
	ComponentByID(ctx context.Context, id int) (*model.Component, error)
}

type ResolverRoot interface {
	Component() ComponentResolver
	Pod() PodResolver
	Processor() ProcessorResolver
	ProcessorInput() ProcessorInputResolver
	ProcessorJoin() ProcessorJoinResolver
	ProcessorLookup() ProcessorLookupResolver
	ProcessorOutput() ProcessorOutputResolver
	Query() QueryResolver
	Service() ServiceResolver
	Sink() SinkResolver
	Source() SourceResolver
	Subscription() SubscriptionResolver
	Topic() TopicResolver
	View() ViewResolver
	ViewSink() ViewSinkResolver
	ViewSource() ViewSourceResolver
}

type ServiceResolver interface {
	Components(ctx context.Context, obj *model.Service) ([]*model.Component, error)
	DependsOn(ctx context.Context, obj *model.Service) ([]*model.Service, error)
}

type SinkResolver interface {
	Component(ctx context.Context, obj *model.Sink) (*model.Component, error)

	Topic(ctx context.Context, obj *model.Sink) (*model.Topic, error)
	Pods(ctx context.Context, obj *model.Sink) ([]*model.Pod, error)
}

type SourceResolver interface {
	Component(ctx context.Context, obj *model.Source) (*model.Component, error)
	Topic(ctx context.Context, obj *model.Source) (*model.Topic, error)
	Pods(ctx context.Context, obj *model.Source) ([]*model.Pod, error)
}

type SubscriptionResolver interface {
	WatchProcessor(ctx context.Context, options *model.WatchProcessorInput) (<-chan *model.Operation, error)
}

type TopicResolver interface {
	ProcessorInputs(ctx context.Context, obj *model.Topic) ([]*model.ProcessorInput, error)
	ProcessorJoins(ctx context.Context, obj *model.Topic) ([]*model.ProcessorJoin, error)
	ProcessorLookups(ctx context.Context, obj *model.Topic) ([]*model.ProcessorLookup, error)
	ProcessorOutputs(ctx context.Context, obj *model.Topic) ([]*model.ProcessorOutput, error)
	ProcessorPersistences(ctx context.Context, obj *model.Topic) ([]*model.Processor, error)
	Sinks(ctx context.Context, obj *model.Topic) ([]*model.Sink, error)
	Sources(ctx context.Context, obj *model.Topic) ([]*model.Source, error)
	ViewSinks(ctx context.Context, obj *model.Topic) ([]*model.ViewSink, error)
	ViewSources(ctx context.Context, obj *model.Topic) ([]*model.ViewSource, error)
	Views(ctx context.Context, obj *model.Topic) ([]*model.View, error)
}

type ViewResolver interface {
	Component(ctx context.Context, obj *model.View) (*model.Component, error)
	Topic(ctx context.Context, obj *model.View) (*model.Topic, error)
	Pods(ctx context.Context, obj *model.View) ([]*model.Pod, error)
}

type ViewSinkResolver interface {
	Component(ctx context.Context, obj *model.ViewSink) (*model.Component, error)

	Topic(ctx context.Context, obj *model.ViewSink) (*model.Topic, error)
	Pods(ctx context.Context, obj *model.ViewSink) ([]*model.Pod, error)
}

type ViewSourceResolver interface {
	Component(ctx context.Context, obj *model.ViewSource) (*model.Component, error)

	Topic(ctx context.Context, obj *model.ViewSource) (*model.Topic, error)
	Pods(ctx context.Context, obj *model.ViewSource) ([]*model.Pod, error)
}