Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ImageDbHandler ¶
type ImageDbHandler struct {
DatabaseContext *model.DatabaseContext
}
func NewImageDbHandler ¶
func NewImageDbHandler(databaseContext *model.DatabaseContext) *ImageDbHandler
func (*ImageDbHandler) RemoveExpiredContexts ¶
func (ih *ImageDbHandler) RemoveExpiredContexts(item model.PharosImageMeta) model.PharosImageMeta
func (*ImageDbHandler) RemoveImagesWithoutContext ¶
func (ih *ImageDbHandler) RemoveImagesWithoutContext(item model.PharosImageMeta) model.PharosImageMeta
type ImageDbSink ¶
type ImageDbSink struct {
Logger *zerolog.Logger
DatabaseContext *model.DatabaseContext
// contains filtered or unexported fields
}
func NewImageDbSink ¶
func NewImageDbSink(databaseContext *model.DatabaseContext) *ImageDbSink
func (*ImageDbSink) AwaitCompletion ¶
func (is *ImageDbSink) AwaitCompletion()
AwaitCompletion blocks until the ImageSink has processed all received data.
func (*ImageDbSink) In ¶
func (is *ImageDbSink) In() chan<- any
In returns the input channel of the ImageSink connector.
type ImageDbSource ¶
type ImageDbSource struct {
Config *model.Config
DatabaseContext *model.DatabaseContext
Logger *zerolog.Logger
ScannerFlow bool
// contains filtered or unexported fields
}
func NewImageDbSource ¶
func NewImageDbSource(databaseContext *model.DatabaseContext, config *model.Config) *ImageDbSource
func (*ImageDbSource) CheckSplit ¶
func (sr *ImageDbSource) CheckSplit(element any) bool
func (*ImageDbSource) Out ¶
func (is *ImageDbSource) Out() <-chan any
Out returns the output channel of the ChanSource connector.
func (*ImageDbSource) RunAsync ¶
func (is *ImageDbSource) RunAsync()
func (*ImageDbSource) Start ¶
func (is *ImageDbSource) Start()
TODO consider instead of Source use map function
Source Files
Click to show internal directories.
Click to hide internal directories.