test

Documentation

Index

• type CreateDatasetDataInput
• type FindPreviousActiveDatasetForDeviceOutput
• type GetDatasetByIDOutput
• type GetDatasetDataDeduplicatorHashesInput
• type GetDatasetDataDeduplicatorHashesOutput
• type GetDatasetsForUserByIDInput
• type GetDatasetsForUserByIDOutput
• type Session
  • func NewSession() *Session
  • func (s *Session) ActivateDatasetData(dataset *upload.Upload) error
  • func (s *Session) Close()
  • func (s *Session) CreateDataset(dataset *upload.Upload) error
  • func (s *Session) CreateDatasetData(dataset *upload.Upload, datasetData []data.Datum) error
  • func (s *Session) DeleteDataset(dataset *upload.Upload) error
  • func (s *Session) DeleteOtherDatasetData(dataset *upload.Upload) error
  • func (s *Session) DestroyDataForUserByID(userID string) error
  • func (s *Session) FindPreviousActiveDatasetForDevice(dataset *upload.Upload) (*upload.Upload, error)
  • func (s *Session) GetDatasetByID(datasetID string) (*upload.Upload, error)
  • func (s *Session) GetDatasetDataDeduplicatorHashes(dataset *upload.Upload, active bool) ([]string, error)
  • func (s *Session) GetDatasetsForUserByID(userID string, filter *store.Filter, pagination *store.Pagination) ([]*upload.Upload, error)
  • func (s *Session) IsClosed() bool
  • func (s *Session) SetAgent(agent commonStore.Agent)
  • func (s *Session) SetDatasetDataActiveUsingHashes(dataset *upload.Upload, queryHashes []string, active bool) error
  • func (s *Session) SetDeviceDataActiveUsingHashes(dataset *upload.Upload, queryHashes []string, active bool) error
  • func (s *Session) UnusedOutputsCount() int
  • func (s *Session) UpdateDataset(dataset *upload.Upload) error
• type SetDatasetDataActiveUsingHashesInput
• type SetDeviceDataActiveUsingHashesInput

Types

type CreateDatasetDataInput

type CreateDatasetDataInput struct {
	Dataset     *upload.Upload
	DatasetData []data.Datum
}

type FindPreviousActiveDatasetForDeviceOutput

type FindPreviousActiveDatasetForDeviceOutput struct {
	Dataset *upload.Upload
	Error   error
}

type GetDatasetByIDOutput

type GetDatasetByIDOutput struct {
	Dataset *upload.Upload
	Error   error
}

type GetDatasetDataDeduplicatorHashesInput

type GetDatasetDataDeduplicatorHashesInput struct {
	Dataset *upload.Upload
	Active  bool
}

type GetDatasetDataDeduplicatorHashesOutput

type GetDatasetDataDeduplicatorHashesOutput struct {
	Hashes []string
	Error  error
}

type GetDatasetsForUserByIDInput

type GetDatasetsForUserByIDInput struct {
	UserID     string
	Filter     *store.Filter
	Pagination *store.Pagination
}

type GetDatasetsForUserByIDOutput

type GetDatasetsForUserByIDOutput struct {
	Datasets []*upload.Upload
	Error    error
}

type Session

type Session struct {
	ID                                            string
	IsClosedInvocations                           int
	IsClosedOutputs                               []bool
	CloseInvocations                              int
	SetAgentInvocations                           int
	SetAgentInputs                                []commonStore.Agent
	GetDatasetsForUserByIDInvocations             int
	GetDatasetsForUserByIDInputs                  []GetDatasetsForUserByIDInput
	GetDatasetsForUserByIDOutputs                 []GetDatasetsForUserByIDOutput
	GetDatasetByIDInvocations                     int
	GetDatasetByIDInputs                          []string
	GetDatasetByIDOutputs                         []GetDatasetByIDOutput
	FindPreviousActiveDatasetForDeviceInvocations int
	FindPreviousActiveDatasetForDeviceInputs      []*upload.Upload
	FindPreviousActiveDatasetForDeviceOutputs     []FindPreviousActiveDatasetForDeviceOutput
	CreateDatasetInvocations                      int
	CreateDatasetInputs                           []*upload.Upload
	CreateDatasetOutputs                          []error
	UpdateDatasetInvocations                      int
	UpdateDatasetInputs                           []*upload.Upload
	UpdateDatasetOutputs                          []error
	DeleteDatasetInvocations                      int
	DeleteDatasetInputs                           []*upload.Upload
	DeleteDatasetOutputs                          []error
	GetDatasetDataDeduplicatorHashesInvocations   int
	GetDatasetDataDeduplicatorHashesInputs        []GetDatasetDataDeduplicatorHashesInput
	GetDatasetDataDeduplicatorHashesOutputs       []GetDatasetDataDeduplicatorHashesOutput
	CreateDatasetDataInvocations                  int
	CreateDatasetDataInputs                       []CreateDatasetDataInput
	CreateDatasetDataOutputs                      []error
	ActivateDatasetDataInvocations                int
	ActivateDatasetDataInputs                     []*upload.Upload
	ActivateDatasetDataOutputs                    []error
	SetDatasetDataActiveUsingHashesInvocations    int
	SetDatasetDataActiveUsingHashesInputs         []SetDatasetDataActiveUsingHashesInput
	SetDatasetDataActiveUsingHashesOutputs        []error
	SetDeviceDataActiveUsingHashesInvocations     int
	SetDeviceDataActiveUsingHashesInputs          []SetDeviceDataActiveUsingHashesInput
	SetDeviceDataActiveUsingHashesOutputs         []error
	DeleteOtherDatasetDataInvocations             int
	DeleteOtherDatasetDataInputs                  []*upload.Upload
	DeleteOtherDatasetDataOutputs                 []error
	DestroyDataForUserByIDInvocations             int
	DestroyDataForUserByIDInputs                  []string
	DestroyDataForUserByIDOutputs                 []error
}

func NewSession

func NewSession() *Session

func (*Session) ActivateDatasetData

func (s *Session) ActivateDatasetData(dataset *upload.Upload) error

func (*Session) Close

func (s *Session) Close()

func (*Session) CreateDataset

func (s *Session) CreateDataset(dataset *upload.Upload) error

func (*Session) CreateDatasetData

func (s *Session) CreateDatasetData(dataset *upload.Upload, datasetData []data.Datum) error

func (*Session) DeleteDataset

func (s *Session) DeleteDataset(dataset *upload.Upload) error

func (*Session) DeleteOtherDatasetData

func (s *Session) DeleteOtherDatasetData(dataset *upload.Upload) error

func (*Session) DestroyDataForUserByID

func (s *Session) DestroyDataForUserByID(userID string) error

func (*Session) FindPreviousActiveDatasetForDevice

func (s *Session) FindPreviousActiveDatasetForDevice(dataset *upload.Upload) (*upload.Upload, error)

func (*Session) GetDatasetByID

func (s *Session) GetDatasetByID(datasetID string) (*upload.Upload, error)

func (*Session) GetDatasetDataDeduplicatorHashes

func (s *Session) GetDatasetDataDeduplicatorHashes(dataset *upload.Upload, active bool) ([]string, error)

func (*Session) GetDatasetsForUserByID

func (s *Session) GetDatasetsForUserByID(userID string, filter *store.Filter, pagination *store.Pagination) ([]*upload.Upload, error)

func (*Session) IsClosed

func (s *Session) IsClosed() bool

func (*Session) SetAgent

func (s *Session) SetAgent(agent commonStore.Agent)

func (*Session) SetDatasetDataActiveUsingHashes

func (s *Session) SetDatasetDataActiveUsingHashes(dataset *upload.Upload, queryHashes []string, active bool) error

func (*Session) SetDeviceDataActiveUsingHashes

func (s *Session) SetDeviceDataActiveUsingHashes(dataset *upload.Upload, queryHashes []string, active bool) error

func (*Session) UnusedOutputsCount

func (s *Session) UnusedOutputsCount() int

func (*Session) UpdateDataset

func (s *Session) UpdateDataset(dataset *upload.Upload) error

type SetDatasetDataActiveUsingHashesInput

type SetDatasetDataActiveUsingHashesInput struct {
	Dataset *upload.Upload
	Hashes  []string
	Active  bool
}

type SetDeviceDataActiveUsingHashesInput

type SetDeviceDataActiveUsingHashesInput struct {
	Dataset *upload.Upload
	Hashes  []string
	Active  bool
}