Documentation
¶
Index ¶
- type AddDataInput
- type CloseInput
- type 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
- type GetOutput
- type NewOutput
- type OpenInput
- type OpenOutput
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddDataInput ¶ added in v1.29.0
type AddDataInput struct {
Context context.Context
Session dataStoreDEPRECATED.DataSession
DataSet *dataTypesUpload.Upload
DataSetData data.Data
}
type CloseInput ¶ added in v1.29.0
type CloseInput struct {
Context context.Context
Session dataStoreDEPRECATED.DataSession
DataSet *dataTypesUpload.Upload
}
type Deduplicator ¶ added in v1.29.0
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 ¶ added in v1.29.0
func NewDeduplicator() *Deduplicator
func (*Deduplicator) AddData ¶ added in v1.29.0
func (d *Deduplicator) AddData(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload, dataSetData data.Data) error
func (*Deduplicator) AssertOutputsEmpty ¶ added in v1.29.0
func (d *Deduplicator) AssertOutputsEmpty()
func (*Deduplicator) Close ¶ added in v1.29.0
func (d *Deduplicator) Close(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload) error
func (*Deduplicator) Delete ¶ added in v1.29.0
func (d *Deduplicator) Delete(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload) error
func (*Deduplicator) DeleteData ¶ added in v1.29.0
func (d *Deduplicator) DeleteData(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload, selectors *data.Selectors) error
func (*Deduplicator) Open ¶ added in v1.29.0
func (d *Deduplicator) Open(ctx context.Context, session dataStoreDEPRECATED.DataSession, dataSet *dataTypesUpload.Upload) (*dataTypesUpload.Upload, error)
type DeleteDataInput ¶ added in v1.29.0
type DeleteDataInput struct {
Context context.Context
Session dataStoreDEPRECATED.DataSession
DataSet *dataTypesUpload.Upload
Selectors *data.Selectors
}
type DeleteInput ¶ added in v1.29.0
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 ¶ added in v1.29.0
func (f *Factory) AssertOutputsEmpty()
func (*Factory) Get ¶ added in v1.29.0
func (f *Factory) Get(dataSet *dataTypesUpload.Upload) (dataDeduplicator.Deduplicator, error)
func (*Factory) New ¶ added in v1.29.0
func (f *Factory) New(dataSet *dataTypesUpload.Upload) (dataDeduplicator.Deduplicator, error)
type GetOutput ¶ added in v1.29.0
type GetOutput struct {
Deduplicator dataDeduplicator.Deduplicator
Error error
}
type NewOutput ¶ added in v1.29.0
type NewOutput struct {
Deduplicator dataDeduplicator.Deduplicator
Error error
}
type OpenInput ¶ added in v1.29.0
type OpenInput struct {
Context context.Context
Session dataStoreDEPRECATED.DataSession
DataSet *dataTypesUpload.Upload
}
type OpenOutput ¶ added in v1.29.0
type OpenOutput struct {
DataSet *dataTypesUpload.Upload
Error error
}
Click to show internal directories.
Click to hide internal directories.