test

Documentation

Index

• type CanDeduplicateDatasetOutput
• type Factory
  • func NewFactory() *Factory
  • func (f *Factory) CanDeduplicateDataset(dataset *upload.Upload) (bool, error)
  • func (f *Factory) IsRegisteredWithDataset(dataset *upload.Upload) (bool, error)
  • func (f *Factory) NewDeduplicatorForDataset(logger log.Logger, dataStoreSession store.Session, dataset *upload.Upload) (data.Deduplicator, error)
  • func (f *Factory) NewRegisteredDeduplicatorForDataset(logger log.Logger, dataStoreSession store.Session, dataset *upload.Upload) (data.Deduplicator, error)
  • func (f *Factory) UnusedOutputsCount() int
• type IsRegisteredWithDatasetOutput
• type NewDeduplicatorForDatasetInput
• type NewDeduplicatorForDatasetOutput
• type NewRegisteredDeduplicatorForDatasetInput
• type NewRegisteredDeduplicatorForDatasetOutput

Types

type CanDeduplicateDatasetOutput

type CanDeduplicateDatasetOutput struct {
	Can   bool
	Error error
}

type Factory

type Factory struct {
	ID                                             string
	CanDeduplicateDatasetInvocations               int
	CanDeduplicateDatasetInputs                    []*upload.Upload
	CanDeduplicateDatasetOutputs                   []CanDeduplicateDatasetOutput
	NewDeduplicatorForDatasetInvocations           int
	NewDeduplicatorForDatasetInputs                []NewDeduplicatorForDatasetInput
	NewDeduplicatorForDatasetOutputs               []NewDeduplicatorForDatasetOutput
	IsRegisteredWithDatasetInvocations             int
	IsRegisteredWithDatasetInputs                  []*upload.Upload
	IsRegisteredWithDatasetOutputs                 []IsRegisteredWithDatasetOutput
	NewRegisteredDeduplicatorForDatasetInvocations int
	NewRegisteredDeduplicatorForDatasetInputs      []NewRegisteredDeduplicatorForDatasetInput
	NewRegisteredDeduplicatorForDatasetOutputs     []NewRegisteredDeduplicatorForDatasetOutput
}

func NewFactory

func NewFactory() *Factory

func (*Factory) CanDeduplicateDataset

func (f *Factory) CanDeduplicateDataset(dataset *upload.Upload) (bool, error)

func (*Factory) IsRegisteredWithDataset

func (f *Factory) IsRegisteredWithDataset(dataset *upload.Upload) (bool, error)

func (*Factory) NewDeduplicatorForDataset

func (f *Factory) NewDeduplicatorForDataset(logger log.Logger, dataStoreSession store.Session, dataset *upload.Upload) (data.Deduplicator, error)

func (*Factory) NewRegisteredDeduplicatorForDataset

func (f *Factory) NewRegisteredDeduplicatorForDataset(logger log.Logger, dataStoreSession store.Session, dataset *upload.Upload) (data.Deduplicator, error)

func (*Factory) UnusedOutputsCount

func (f *Factory) UnusedOutputsCount() int

type IsRegisteredWithDatasetOutput

type IsRegisteredWithDatasetOutput struct {
	Is    bool
	Error error
}

type NewDeduplicatorForDatasetInput

type NewDeduplicatorForDatasetInput struct {
	Logger           log.Logger
	DataStoreSession store.Session
	Dataset          *upload.Upload
}

type NewDeduplicatorForDatasetOutput

type NewDeduplicatorForDatasetOutput struct {
	Deduplicator data.Deduplicator
	Error        error
}

type NewRegisteredDeduplicatorForDatasetInput

type NewRegisteredDeduplicatorForDatasetInput struct {
	Logger           log.Logger
	DataStoreSession store.Session
	Dataset          *upload.Upload
}

type NewRegisteredDeduplicatorForDatasetOutput

type NewRegisteredDeduplicatorForDatasetOutput struct {
	Deduplicator data.Deduplicator
	Error        error
}