test

Documentation

Index

• type Datum
  • func NewDatum() *Datum
  • func (d *Datum) DeduplicatorDescriptor() *data.DeduplicatorDescriptor
  • func (d *Datum) IdentityFields() ([]string, error)
  • func (d *Datum) Init()
  • func (d *Datum) Meta() interface{}
  • func (d *Datum) Normalize(normalizer data.Normalizer) error
  • 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) SetGroupID(groupID string)
  • func (d *Datum) SetModifiedTime(modifiedTime string)
  • func (d *Datum) SetModifiedUserID(modifiedUserID string)
  • func (d *Datum) SetUserID(userID string)
  • func (d *Datum) UnusedOutputsCount() int
  • func (d *Datum) Validate(validator data.Validator) error
• type Deduplicator
  • func NewDeduplicator() *Deduplicator
  • func (d *Deduplicator) AddDataToDataset(datasetData []data.Datum) error
  • func (d *Deduplicator) FinalizeDataset() error
  • func (d *Deduplicator) InitializeDataset() error
  • func (d *Deduplicator) UnusedOutputsCount() int
• type IdentityFieldsOutput

Types

type Datum

type Datum struct {
	ID                                   string
	InitInvocations                      int
	MetaInvocations                      int
	MetaOutputs                          []interface{}
	ParseInvocations                     int
	ParseInputs                          []data.ObjectParser
	ParseOutputs                         []error
	ValidateInvocations                  int
	ValidateInputs                       []data.Validator
	ValidateOutputs                      []error
	NormalizeInvocations                 int
	NormalizeInputs                      []data.Normalizer
	NormalizeOutputs                     []error
	IdentityFieldsInvocations            int
	IdentityFieldsOutputs                []IdentityFieldsOutput
	SetUserIDInvocations                 int
	SetUserIDInputs                      []string
	SetGroupIDInvocations                int
	SetGroupIDInputs                     []string
	SetDatasetIDInvocations              int
	SetDatasetIDInputs                   []string
	SetActiveInvocations                 int
	SetActiveInputs                      []bool
	SetCreatedTimeInvocations            int
	SetCreatedTimeInputs                 []string
	SetCreatedUserIDInvocations          int
	SetCreatedUserIDInputs               []string
	SetModifiedTimeInvocations           int
	SetModifiedTimeInputs                []string
	SetModifiedUserIDInvocations         int
	SetModifiedUserIDInputs              []string
	SetDeletedTimeInvocations            int
	SetDeletedTimeInputs                 []string
	SetDeletedUserIDInvocations          int
	SetDeletedUserIDInputs               []string
	DeduplicatorDescriptorInvocations    int
	DeduplicatorDescriptorOutputs        []*data.DeduplicatorDescriptor
	SetDeduplicatorDescriptorInvocations int
	SetDeduplicatorDescriptorInputs      []*data.DeduplicatorDescriptor
}

func NewDatum

func NewDatum() *Datum

func (*Datum) DeduplicatorDescriptor

func (d *Datum) DeduplicatorDescriptor() *data.DeduplicatorDescriptor

func (*Datum) IdentityFields

func (d *Datum) IdentityFields() ([]string, error)

func (*Datum) Init

func (d *Datum) Init()

func (*Datum) Meta

func (d *Datum) Meta() interface{}

func (*Datum) Normalize

func (d *Datum) Normalize(normalizer data.Normalizer) error

func (*Datum) Parse

func (d *Datum) Parse(parser data.ObjectParser) error

func (*Datum) SetActive

func (d *Datum) SetActive(active bool)

func (*Datum) SetCreatedTime

func (d *Datum) SetCreatedTime(createdTime string)

func (*Datum) SetCreatedUserID

func (d *Datum) SetCreatedUserID(createdUserID string)

func (*Datum) SetDatasetID

func (d *Datum) SetDatasetID(datasetID string)

func (*Datum) SetDeduplicatorDescriptor

func (d *Datum) SetDeduplicatorDescriptor(deduplicatorDescriptor *data.DeduplicatorDescriptor)

func (*Datum) SetDeletedTime

func (d *Datum) SetDeletedTime(deletedTime string)

func (*Datum) SetDeletedUserID

func (d *Datum) SetDeletedUserID(deletedUserID string)

func (*Datum) SetGroupID

func (d *Datum) SetGroupID(groupID string)

func (*Datum) SetModifiedTime

func (d *Datum) SetModifiedTime(modifiedTime string)

func (*Datum) SetModifiedUserID

func (d *Datum) SetModifiedUserID(modifiedUserID string)

func (*Datum) SetUserID

func (d *Datum) SetUserID(userID string)

func (*Datum) UnusedOutputsCount

func (d *Datum) UnusedOutputsCount() int

func (*Datum) Validate

func (d *Datum) Validate(validator data.Validator) error

type Deduplicator

type Deduplicator struct {
	ID                           string
	InitializeDatasetInvocations int
	InitializeDatasetOutputs     []error
	AddDataToDatasetInvocations  int
	AddDataToDatasetInputs       [][]data.Datum
	AddDataToDatasetOutputs      []error
	FinalizeDatasetInvocations   int
	FinalizeDatasetOutputs       []error
}

func NewDeduplicator

func NewDeduplicator() *Deduplicator

func (*Deduplicator) AddDataToDataset

func (d *Deduplicator) AddDataToDataset(datasetData []data.Datum) error

func (*Deduplicator) FinalizeDataset

func (d *Deduplicator) FinalizeDataset() error

func (*Deduplicator) InitializeDataset

func (d *Deduplicator) InitializeDataset() error

func (*Deduplicator) UnusedOutputsCount

func (d *Deduplicator) UnusedOutputsCount() int

type IdentityFieldsOutput

type IdentityFieldsOutput struct {
	IdentityFields []string
	Error          error
}