Documentation ¶
Index ¶
- Constants
- Variables
- func CloneBlob(datum *data.Blob) *data.Blob
- func CloneBlobArray(datum *data.BlobArray) *data.BlobArray
- func CloneDeduplicatorDescriptor(datum *data.DeduplicatorDescriptor) *data.DeduplicatorDescriptor
- func ComposeError(expectedError *service.Error, source string, meta interface{}) *service.Error
- func NewBlob() *data.Blob
- func NewBlobArray() *data.BlobArray
- func NewDeduplicatorDescriptor() *data.DeduplicatorDescriptor
- func RawBaseObject() map[string]interface{}
- type AddDatasetDataInput
- type Datum
- func (d *Datum) DeduplicatorDescriptor() *data.DeduplicatorDescriptor
- func (d *Datum) Expectations()
- func (d *Datum) GetPayload() *data.Blob
- func (d *Datum) IdentityFields() ([]string, error)
- func (d *Datum) Init()
- func (d *Datum) Meta() interface{}
- func (d *Datum) Normalize(normalizer data.Normalizer)
- func (d *Datum) Parse(parser data.ObjectParser) error
- func (d *Datum) SetActive(active bool)
- func (d *Datum) SetCreatedTime(createdTime *string)
- func (d *Datum) SetCreatedUserID(createdUserID *string)
- func (d *Datum) SetDatasetID(datasetID *string)
- func (d *Datum) SetDeduplicatorDescriptor(deduplicatorDescriptor *data.DeduplicatorDescriptor)
- func (d *Datum) SetDeletedTime(deletedTime *string)
- func (d *Datum) SetDeletedUserID(deletedUserID *string)
- func (d *Datum) SetDeviceID(deviceID *string)
- func (d *Datum) SetModifiedTime(modifiedTime *string)
- func (d *Datum) SetModifiedUserID(modifiedUserID *string)
- func (d *Datum) SetUserID(userID *string)
- func (d *Datum) Validate(validator structure.Validator)
- type Deduplicator
- func (d *Deduplicator) AddDatasetData(ctx context.Context, datasetData []data.Datum) error
- func (d *Deduplicator) DeduplicateDataset(ctx context.Context) error
- func (d *Deduplicator) DeleteDataset(ctx context.Context) error
- func (d *Deduplicator) Expectations()
- func (d *Deduplicator) Name() string
- func (d *Deduplicator) RegisterDataset(ctx context.Context) error
- func (d *Deduplicator) Version() string
- type IdentityFieldsOutput
- type Normalizable
Constants ¶
View Source
const ( BlobValuesMaximum = 3 BlobArrayValuesMaximum = 3 )
Variables ¶
View Source
var ExpectFieldIsValid = func(object map[string]interface{}, field string, value interface{}) { checkErrorsFromParseValidateNormalize(object, field, value, []*service.Error{}) }
View Source
var ExpectFieldNotValid = func(object map[string]interface{}, field string, value interface{}, expectedErrors []*service.Error) {
checkErrorsFromParseValidateNormalize(object, field, value, expectedErrors)
}
Functions ¶
func CloneDeduplicatorDescriptor ¶ added in v1.24.0
func CloneDeduplicatorDescriptor(datum *data.DeduplicatorDescriptor) *data.DeduplicatorDescriptor
func ComposeError ¶ added in v1.5.0
func NewBlobArray ¶ added in v1.24.0
func NewDeduplicatorDescriptor ¶ added in v1.24.0
func NewDeduplicatorDescriptor() *data.DeduplicatorDescriptor
func RawBaseObject ¶ added in v1.5.0
func RawBaseObject() map[string]interface{}
Types ¶
type AddDatasetDataInput ¶ added in v1.20.0
type Datum ¶
type Datum struct { *test.Mock InitInvocations int MetaInvocations int MetaOutputs []interface{} ParseInvocations int ParseInputs []data.ObjectParser ParseOutputs []error ValidateInvocations int ValidateInputs []structure.Validator NormalizeInvocations int NormalizeInputs []data.Normalizer IdentityFieldsInvocations int IdentityFieldsOutputs []IdentityFieldsOutput GetPayloadInvocations int GetPayloadOutputs []*data.Blob SetUserIDInvocations int SetUserIDInputs []*string SetDatasetIDInvocations int SetDatasetIDInputs []*string SetActiveInvocations int SetActiveInputs []bool SetDeviceIDInvocations int SetDeviceIDInputs []*string SetCreatedTimeInvocations int SetCreatedTimeInputs []*string SetCreatedUserIDInvocations int SetCreatedUserIDInputs []*string SetModifiedTimeInvocations int SetModifiedTimeInputs []*string SetModifiedUserIDInvocations int SetModifiedUserIDInputs []*string SetDeletedTimeInvocations int SetDeletedTimeInputs []*string SetDeletedUserIDInvocations int SetDeletedUserIDInputs []*string DeduplicatorDescriptorValue *data.DeduplicatorDescriptor DeduplicatorDescriptorInvocations int SetDeduplicatorDescriptorInvocations int }
func (*Datum) DeduplicatorDescriptor ¶
func (d *Datum) DeduplicatorDescriptor() *data.DeduplicatorDescriptor
func (*Datum) Expectations ¶ added in v1.20.0
func (d *Datum) Expectations()
func (*Datum) GetPayload ¶ added in v1.20.0
func (*Datum) IdentityFields ¶
func (*Datum) Normalize ¶
func (d *Datum) Normalize(normalizer data.Normalizer)
func (*Datum) SetCreatedTime ¶
func (*Datum) SetCreatedUserID ¶
func (*Datum) SetDatasetID ¶
func (*Datum) SetDeduplicatorDescriptor ¶
func (d *Datum) SetDeduplicatorDescriptor(deduplicatorDescriptor *data.DeduplicatorDescriptor)
func (*Datum) SetDeletedTime ¶
func (*Datum) SetDeletedUserID ¶
func (*Datum) SetDeviceID ¶ added in v1.20.0
func (*Datum) SetModifiedTime ¶
func (*Datum) SetModifiedUserID ¶
type Deduplicator ¶
type Deduplicator struct { *test.Mock NameInvocations int NameOutputs []string VersionInvocations int VersionOutputs []string RegisterDatasetInvocations int RegisterDatasetInputs []context.Context RegisterDatasetOutputs []error AddDatasetDataInvocations int AddDatasetDataInputs []AddDatasetDataInput AddDatasetDataOutputs []error DeduplicateDatasetInvocations int DeduplicateDatasetInputs []context.Context DeduplicateDatasetOutputs []error DeleteDatasetInvocations int DeleteDatasetInputs []context.Context DeleteDatasetOutputs []error }
func NewDeduplicator ¶
func NewDeduplicator() *Deduplicator
func (*Deduplicator) AddDatasetData ¶ added in v1.5.0
func (*Deduplicator) DeduplicateDataset ¶ added in v1.5.0
func (d *Deduplicator) DeduplicateDataset(ctx context.Context) error
func (*Deduplicator) DeleteDataset ¶ added in v1.5.0
func (d *Deduplicator) DeleteDataset(ctx context.Context) error
func (*Deduplicator) Expectations ¶ added in v1.20.0
func (d *Deduplicator) Expectations()
func (*Deduplicator) Name ¶ added in v1.5.0
func (d *Deduplicator) Name() string
func (*Deduplicator) RegisterDataset ¶ added in v1.5.0
func (d *Deduplicator) RegisterDataset(ctx context.Context) error
func (*Deduplicator) Version ¶ added in v1.8.0
func (d *Deduplicator) Version() string
type IdentityFieldsOutput ¶
type Normalizable ¶ added in v1.24.0
type Normalizable struct { *test.Mock NormalizeInvocations int NormalizeInputs []data.Normalizer NormalizeStub func(normalizer data.Normalizer) }
func NewNormalizable ¶ added in v1.24.0
func NewNormalizable() *Normalizable
func (*Normalizable) Expectations ¶ added in v1.24.0
func (n *Normalizable) Expectations()
func (*Normalizable) Normalize ¶ added in v1.24.0
func (n *Normalizable) Normalize(normalizer data.Normalizer)
Click to show internal directories.
Click to hide internal directories.