test

Documentation

Index

• type AddDataInput
• type CloseInput
• type Deduplicator
  • func NewDeduplicator() *Deduplicator
  • func (d *Deduplicator) AddData(ctx context.Context, session dataStoreDEPRECATED.DataSession, ...) error
  • func (d *Deduplicator) AssertOutputsEmpty()
  • func (d *Deduplicator) Close(ctx context.Context, session dataStoreDEPRECATED.DataSession, ...) error
  • func (d *Deduplicator) Delete(ctx context.Context, session dataStoreDEPRECATED.DataSession, ...) error
  • func (d *Deduplicator) DeleteData(ctx context.Context, session dataStoreDEPRECATED.DataSession, ...) error
  • func (d *Deduplicator) Open(ctx context.Context, session dataStoreDEPRECATED.DataSession, ...) (*dataTypesUpload.Upload, error)
• type DeleteDataInput
• type DeleteInput
• type Factory
  • func NewFactory() *Factory
  • func (f *Factory) AssertOutputsEmpty()
  • func (f *Factory) Get(dataSet *dataTypesUpload.Upload) (dataDeduplicator.Deduplicator, error)
  • func (f *Factory) New(dataSet *dataTypesUpload.Upload) (dataDeduplicator.Deduplicator, error)
• type GetOutput
• type NewOutput
• type OpenInput
• type OpenOutput

Types

type AddDataInput

type AddDataInput struct {
	Context     context.Context
	Session     dataStoreDEPRECATED.DataSession
	DataSet     *dataTypesUpload.Upload
	DataSetData data.Data
}

type CloseInput

type CloseInput struct {
	Context context.Context
	Session dataStoreDEPRECATED.DataSession
	DataSet *dataTypesUpload.Upload
}

type Deduplicator

type Deduplicator struct {
	OpenInvocations       int
	OpenInputs            []OpenInput
	OpenStub              func(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload) (*dataTypesUpload.Upload, error)
	OpenOutputs           []OpenOutput
	OpenOutput            *OpenOutput
	AddDataInvocations    int
	AddDataInputs         []AddDataInput
	AddDataStub           func(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload, dataSetData data.Data) error
	AddDataOutputs        []error
	AddDataOutput         *error
	DeleteDataInvocations int
	DeleteDataInputs      []DeleteDataInput
	DeleteDataStub        func(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload, selectors *data.Selectors) error
	DeleteDataOutputs     []error
	DeleteDataOutput      *error
	CloseInvocations      int
	CloseInputs           []CloseInput
	CloseStub             func(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload) error
	CloseOutputs          []error
	CloseOutput           *error
	DeleteInvocations     int
	DeleteInputs          []DeleteInput
	DeleteStub            func(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload) error
	DeleteOutputs         []error
	DeleteOutput          *error
}

func NewDeduplicator

func NewDeduplicator() *Deduplicator

func (*Deduplicator) AddData

func (d *Deduplicator) AddData(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload, dataSetData data.Data) error

func (*Deduplicator) AssertOutputsEmpty

func (d *Deduplicator) AssertOutputsEmpty()

func (*Deduplicator) Close

func (d *Deduplicator) Close(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload) error

func (*Deduplicator) Delete

func (d *Deduplicator) Delete(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload) error

func (*Deduplicator) DeleteData

func (d *Deduplicator) DeleteData(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload, selectors *data.Selectors) error

func (*Deduplicator) Open

func (d *Deduplicator) Open(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload) (*dataTypesUpload.Upload, error)

type DeleteDataInput

type DeleteDataInput struct {
	Context   context.Context
	Session   dataStoreDEPRECATED.DataSession
	DataSet   *dataTypesUpload.Upload
	Selectors *data.Selectors
}

type DeleteInput

type DeleteInput struct {
	Context context.Context
	Session dataStoreDEPRECATED.DataSession
	DataSet *dataTypesUpload.Upload
}

type Factory

type Factory struct {
	NewInvocations int
	NewInputs      []*dataTypesUpload.Upload
	NewStub        func(dataSet *dataTypesUpload.Upload) (dataDeduplicator.Deduplicator, error)
	NewOutputs     []NewOutput
	NewOutput      *NewOutput
	GetInvocations int
	GetInputs      []*dataTypesUpload.Upload
	GetStub        func(dataSet *dataTypesUpload.Upload) (dataDeduplicator.Deduplicator, error)
	GetOutputs     []GetOutput
	GetOutput      *GetOutput
}

func NewFactory

func NewFactory() *Factory

func (*Factory) AssertOutputsEmpty

func (f *Factory) AssertOutputsEmpty()

func (*Factory) Get

func (f *Factory) Get(dataSet *dataTypesUpload.Upload) (dataDeduplicator.Deduplicator, error)

func (*Factory) New

func (f *Factory) New(dataSet *dataTypesUpload.Upload) (dataDeduplicator.Deduplicator, error)

type GetOutput

type GetOutput struct {
	Deduplicator dataDeduplicator.Deduplicator
	Error        error
}

type NewOutput

type NewOutput struct {
	Deduplicator dataDeduplicator.Deduplicator
	Error        error
}

type OpenInput

type OpenInput struct {
	Context context.Context
	Session dataStoreDEPRECATED.DataSession
	DataSet *dataTypesUpload.Upload
}

type OpenOutput

type OpenOutput struct {
	DataSet *dataTypesUpload.Upload
	Error   error
}