repositories

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 9, 2021 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AllRepositories 

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

AllRepositories contains all repositories

func All 

func All(db *sql.DB) *AllRepositories

All creates a struct with all repositories

func (*AllRepositories) Component 

func (a *AllRepositories) Component() loaders.ComponentRepository

Component returns the component repository

func (*AllRepositories) Pod 

func (a *AllRepositories) Pod() loaders.PodRepository

Pod returns the pod repository

func (*AllRepositories) Processor 

func (a *AllRepositories) Processor() loaders.ProcessorRepository

Processor returns the processor repository

func (*AllRepositories) ProcessorInput 

func (a *AllRepositories) ProcessorInput() loaders.ProcessorInputRepository

ProcessorInput returns the processor input repository

func (*AllRepositories) ProcessorJoin 

func (a *AllRepositories) ProcessorJoin() loaders.ProcessorJoinRepository

ProcessorJoin returns the processor join repository

func (*AllRepositories) ProcessorLookup 

func (a *AllRepositories) ProcessorLookup() loaders.ProcessorLookupRepository

ProcessorLookup returns the processor lookup repository

func (*AllRepositories) ProcessorOutput 

func (a *AllRepositories) ProcessorOutput() loaders.ProcessorOutputRepository

ProcessorOutput returns the processor output repository

func (*AllRepositories) Query 

func (a *AllRepositories) Query() loaders.QueryRepository

Query returns the query repository

func (*AllRepositories) Service 

func (a *AllRepositories) Service() loaders.ServiceRepository

Service returns the service repository

func (*AllRepositories) Sink 

func (a *AllRepositories) Sink() loaders.SinkRepository

Sink returns the sink repository

func (*AllRepositories) Source 

func (a *AllRepositories) Source() loaders.SourceRepository

Source returns the source repository

func (*AllRepositories) Topic 

func (a *AllRepositories) Topic() loaders.TopicRepository

Topic returns the topic repository

func (*AllRepositories) View 

func (a *AllRepositories) View() loaders.ViewRepository

View returns the view repository

func (*AllRepositories) ViewSink 

func (a *AllRepositories) ViewSink() loaders.ViewSinkRepository

ViewSink returns the view sink repository

func (*AllRepositories) ViewSource 

func (a *AllRepositories) ViewSource() loaders.ViewSourceRepository

ViewSource returns the view source repository

type Component 

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

Component is a repository for components

func (*Component) DependsOn added in v0.12.0 

func (r *Component) DependsOn(ctx context.Context, ids []int) ([][]*model.Component, error)

DependsOn returns components dependent on components

func (*Component) ProcessorsByComponents 

func (r *Component) ProcessorsByComponents(ctx context.Context, components []int) ([][]*model.Processor, error)

ProcessorsByComponents returns the processors for components

func (*Component) ServicesByComponents 

func (r *Component) ServicesByComponents(ctx context.Context, components []int) ([]*model.Service, error)

ServicesByComponents returns the services for components

func (*Component) SinksByComponents 

func (r *Component) SinksByComponents(ctx context.Context, components []int) ([][]*model.Sink, error)

SinksByComponents returns the sinks for components

func (*Component) SourcesByComponents 

func (r *Component) SourcesByComponents(ctx context.Context, components []int) ([][]*model.Source, error)

SourcesByComponents returns the sources for components

func (*Component) ViewSinksByComponents 

func (r *Component) ViewSinksByComponents(ctx context.Context, components []int) ([][]*model.ViewSink, error)

ViewSinksByComponents returns the view sinks for components

func (*Component) ViewSourcesByComponents 

func (r *Component) ViewSourcesByComponents(ctx context.Context, components []int) ([][]*model.ViewSource, error)

ViewSourcesByComponents returns the view sources for components

func (*Component) ViewsByComponents 

func (r *Component) ViewsByComponents(ctx context.Context, components []int) ([][]*model.View, error)

ViewsByComponents returns the views for components

type Pod 

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

Pod is the repository for pods

func (*Pod) ProcessorsByPods 

func (r *Pod) ProcessorsByPods(ctx context.Context, pods []int) ([][]*model.Processor, error)

ProcessorsByPods returns the processors for pods

func (*Pod) SinksByPods 

func (r *Pod) SinksByPods(ctx context.Context, pods []int) ([][]*model.Sink, error)

SinksByPods returns the sinks for pods

func (*Pod) SourcesByPods 

func (r *Pod) SourcesByPods(ctx context.Context, pods []int) ([][]*model.Source, error)

SourcesByPods returns the sources for pods

func (*Pod) ViewSinksByPods 

func (r *Pod) ViewSinksByPods(ctx context.Context, pods []int) ([][]*model.ViewSink, error)

ViewSinksByPods returns the view sinks for pods

func (*Pod) ViewSourcesByPods 

func (r *Pod) ViewSourcesByPods(ctx context.Context, pods []int) ([][]*model.ViewSource, error)

ViewSourcesByPods returns the view sources for pods

func (*Pod) ViewsByPods 

func (r *Pod) ViewsByPods(ctx context.Context, pods []int) ([][]*model.View, error)

ViewsByPods returns the views for pods

type Processor 

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

Processor is the repository for processors

func (*Processor) ByID added in v0.15.0 

func (r *Processor) ByID(ctx context.Context, id int) (*model.Processor, error)

ByID returns a processor with the id given

func (*Processor) ComponentByProcessors 

func (r *Processor) ComponentByProcessors(ctx context.Context, processors []int) ([]*model.Component, error)

ComponentByProcessors returns the components for processors

func (*Processor) InputsByProcessors 

func (r *Processor) InputsByProcessors(ctx context.Context, processors []int) ([][]*model.ProcessorInput, error)

InputsByProcessors returns the inputs for processors

func (*Processor) JoinsByProcessors 

func (r *Processor) JoinsByProcessors(ctx context.Context, processors []int) ([][]*model.ProcessorJoin, error)

JoinsByProcessors returns the joins for processors

func (*Processor) LookupsByProcessors 

func (r *Processor) LookupsByProcessors(ctx context.Context, processors []int) ([][]*model.ProcessorLookup, error)

LookupsByProcessors returns the lookups for processors

func (*Processor) OutputsByProcessors 

func (r *Processor) OutputsByProcessors(ctx context.Context, processors []int) ([][]*model.ProcessorOutput, error)

OutputsByProcessors returns the outputs for processors

func (*Processor) PersistenceByProcessors 

func (r *Processor) PersistenceByProcessors(ctx context.Context, processors []int) ([]*model.Topic, error)

PersistenceByProcessors returns the persistence topics for processors

func (*Processor) PodsByProcessors 

func (r *Processor) PodsByProcessors(ctx context.Context, processors []int) ([][]*model.Pod, error)

PodsByProcessors returns the pods for processors

type ProcessorInput 

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

ProcessorInput is the repository for processor inputs

func (*ProcessorInput) ProcessorByInputs 

func (r *ProcessorInput) ProcessorByInputs(ctx context.Context, inputs []int) ([]*model.Processor, error)

ProcessorByInputs returns processors for inputs

func (*ProcessorInput) TopicByInputs 

func (r *ProcessorInput) TopicByInputs(ctx context.Context, inputs []int) ([]*model.Topic, error)

TopicByInputs returns topics for inputs

type ProcessorJoin 

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

ProcessorJoin is the repository for processor joins

func (*ProcessorJoin) ProcessorByJoins 

func (r *ProcessorJoin) ProcessorByJoins(ctx context.Context, joins []int) ([]*model.Processor, error)

ProcessorByJoins returns processors for joins

func (*ProcessorJoin) TopicByJoins 

func (r *ProcessorJoin) TopicByJoins(ctx context.Context, joins []int) ([]*model.Topic, error)

TopicByJoins returns topics for joins

type ProcessorLookup 

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

ProcessorLookup is the repository for processor lookups

func (*ProcessorLookup) ProcessorByLookups 

func (r *ProcessorLookup) ProcessorByLookups(ctx context.Context, lookups []int) ([]*model.Processor, error)

ProcessorByLookups returns processors for lookups

func (*ProcessorLookup) TopicByLookups 

func (r *ProcessorLookup) TopicByLookups(ctx context.Context, lookups []int) ([]*model.Topic, error)

TopicByLookups returns topics for lookups

type ProcessorOutput 

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

ProcessorOutput is the repository for processor outputs

func (*ProcessorOutput) ProcessorByOutputs 

func (r *ProcessorOutput) ProcessorByOutputs(ctx context.Context, outputs []int) ([]*model.Processor, error)

ProcessorByOutputs returns processors for outputs

func (*ProcessorOutput) TopicByOutputs 

func (r *ProcessorOutput) TopicByOutputs(ctx context.Context, outputs []int) ([]*model.Topic, error)

TopicByOutputs returns topics for outputs

type Query 

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

Query is the repository for root queries

func (*Query) ComponentByID added in v0.13.0 

func (r *Query) ComponentByID(ctx context.Context, id int) (*model.Component, error)

ComponentByID gets a service by id

func (*Query) GetAllPods 

func (r *Query) GetAllPods(ctx context.Context) ([]*model.Pod, error)

GetAllPods returns all pods in the datastore

func (*Query) GetAllServices 

func (r *Query) GetAllServices(ctx context.Context) ([]*model.Service, error)

GetAllServices returns all services in the datastore

func (*Query) GetAllTopics 

func (r *Query) GetAllTopics(ctx context.Context) ([]*model.Topic, error)

GetAllTopics returns all topics in the datastore

func (*Query) ServiceByID added in v0.11.0 

func (r *Query) ServiceByID(ctx context.Context, id int) (*model.Service, error)

ServiceByID gets a service by id

type Service 

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

Service is the repository for services

func (*Service) ComponentsByServices 

func (r *Service) ComponentsByServices(ctx context.Context, services []int) ([][]*model.Component, error)

ComponentsByServices returns components by services

func (*Service) DependsOn added in v0.11.0 

func (r *Service) DependsOn(ctx context.Context, ids []int) ([][]*model.Service, error)

DependsOn gets services that depend on services

type Sink 

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

Sink is the repository for sinks

func (*Sink) ComponentBySinks 

func (r *Sink) ComponentBySinks(ctx context.Context, sinks []int) ([]*model.Component, error)

ComponentBySinks returns the components for sinks

func (*Sink) PodsBySinks 

func (r *Sink) PodsBySinks(ctx context.Context, sinks []int) ([][]*model.Pod, error)

PodsBySinks returns the pods for sinks

func (*Sink) TopicBySinks 

func (r *Sink) TopicBySinks(ctx context.Context, sinks []int) ([]*model.Topic, error)

TopicBySinks returns the topics for sinks

type Source 

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

Source is the repository for sources

func (*Source) ComponentBySources 

func (r *Source) ComponentBySources(ctx context.Context, sources []int) ([]*model.Component, error)

ComponentBySources returns the components for sources

func (*Source) PodsBySources 

func (r *Source) PodsBySources(ctx context.Context, sources []int) ([][]*model.Pod, error)

PodsBySources returns the pods for sources

func (*Source) TopicBySources 

func (r *Source) TopicBySources(ctx context.Context, sources []int) ([]*model.Topic, error)

TopicBySources returns the topics for sources

type Topic 

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

Topic is the repository for topics

func (*Topic) ProcessorInputsByTopics 

func (r *Topic) ProcessorInputsByTopics(ctx context.Context, topics []int) ([][]*model.ProcessorInput, error)

ProcessorInputsByTopics returns the processor inputs for topics

func (*Topic) ProcessorJoinsByTopics 

func (r *Topic) ProcessorJoinsByTopics(ctx context.Context, topics []int) ([][]*model.ProcessorJoin, error)

ProcessorJoinsByTopics returns the processor joins for topics

func (*Topic) ProcessorLookupsByTopics 

func (r *Topic) ProcessorLookupsByTopics(ctx context.Context, topics []int) ([][]*model.ProcessorLookup, error)

ProcessorLookupsByTopics returns the processor lookups for topics

func (*Topic) ProcessorOutputsByTopics 

func (r *Topic) ProcessorOutputsByTopics(ctx context.Context, topics []int) ([][]*model.ProcessorOutput, error)

ProcessorOutputsByTopics returns the processor outputs for topics

func (*Topic) ProcessorPersistencesByTopics 

func (r *Topic) ProcessorPersistencesByTopics(ctx context.Context, topics []int) ([][]*model.Processor, error)

ProcessorPersistencesByTopics returns the process persistences for topics

func (*Topic) SinksByTopics 

func (r *Topic) SinksByTopics(ctx context.Context, topics []int) ([][]*model.Sink, error)

SinksByTopics returns the sinks for topics

func (*Topic) SourcesByTopics 

func (r *Topic) SourcesByTopics(ctx context.Context, topics []int) ([][]*model.Source, error)

SourcesByTopics returns the sources for topics

func (*Topic) ViewSinksByTopics 

func (r *Topic) ViewSinksByTopics(ctx context.Context, topics []int) ([][]*model.ViewSink, error)

ViewSinksByTopics returns the view sinks for topics

func (*Topic) ViewSourcesByTopics 

func (r *Topic) ViewSourcesByTopics(ctx context.Context, topics []int) ([][]*model.ViewSource, error)

ViewSourcesByTopics returns the view sources for topics

func (*Topic) ViewsByTopics 

func (r *Topic) ViewsByTopics(ctx context.Context, topics []int) ([][]*model.View, error)

ViewsByTopics returns the views for topics

type View 

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

View is the repository for views

func (*View) ComponentByViews 

func (r *View) ComponentByViews(ctx context.Context, views []int) ([]*model.Component, error)

ComponentByViews returns components for views

func (*View) PodsByViews 

func (r *View) PodsByViews(ctx context.Context, views []int) ([][]*model.Pod, error)

PodsByViews returns the pods for views

func (*View) TopicByViews 

func (r *View) TopicByViews(ctx context.Context, views []int) ([]*model.Topic, error)

TopicByViews returns the topics for views

type ViewSink 

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

ViewSink is the repository for view sinks

func (*ViewSink) ComponentByViewSinks 

func (r *ViewSink) ComponentByViewSinks(ctx context.Context, viewSinks []int) ([]*model.Component, error)

ComponentByViewSinks returns the components for view sinks

func (*ViewSink) PodsByViewSinks 

func (r *ViewSink) PodsByViewSinks(ctx context.Context, viewSinks []int) ([][]*model.Pod, error)

PodsByViewSinks returns the pods for view sinks

func (*ViewSink) TopicByViewSinks 

func (r *ViewSink) TopicByViewSinks(ctx context.Context, viewSinks []int) ([]*model.Topic, error)

TopicByViewSinks returns the topics for view sinks

type ViewSource 

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

ViewSource is the repository for view sources

func (*ViewSource) ComponentByViewSources 

func (r *ViewSource) ComponentByViewSources(ctx context.Context, viewSources []int) ([]*model.Component, error)

ComponentByViewSources returns the components for view sources

func (*ViewSource) PodsByViewSources 

func (r *ViewSource) PodsByViewSources(ctx context.Context, viewSources []int) ([][]*model.Pod, error)

PodsByViewSources returns the pods for view sources

func (*ViewSource) TopicByViewSources 

func (r *ViewSource) TopicByViewSources(ctx context.Context, viewSources []int) ([]*model.Topic, error)

TopicByViewSources returns the topics for view sources

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.