Documentation ¶
Index ¶
- func NewManifestFileStore(db *sql.DB) *manifestFileStore
- func NewManifestStore(db *sql.DB) *manifestStore
- func NewUserInfoStore(db *sql.DB) *userInfoStore
- func NewUserSettingsStore(db *sql.DB) *userSettingsStore
- type Manifest
- type ManifestFile
- type ManifestFileParams
- type ManifestFileStore
- type ManifestParams
- type ManifestStore
- type NoClientSessionError
- type UserInfo
- type UserInfoParams
- type UserInfoStore
- type UserSettings
- type UserSettingsParams
- type UserSettingsStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewManifestFileStore ¶
func NewManifestStore ¶
func NewUserInfoStore ¶
func NewUserSettingsStore ¶
Types ¶
type Manifest ¶
type Manifest struct { Id int32 `json:"id"` NodeId sql.NullString `json:"node_id"` UserId string `json:"user_id"` UserName string `json:"user_name"` OrganizationId string `json:"organization_id"` OrganizationName string `json:"organization_name"` DatasetId string `json:"dataset_id"` DatasetName string `json:"dataset_name"` Status manifest.Status `json:"status"` CreatedAt time.Time `json:"created_at"` UpdatedAt time.Time `json:"updated_at"` }
type ManifestFile ¶
type ManifestFile struct { Id int32 `json:"id"` ManifestId int32 `json:"manifest_id"` UploadId uuid.UUID `json:"upload_id"` SourcePath string `json:"source_path"` TargetPath string `json:"target_path"` TargetName string `json:"target_name"` Status manifestFile.Status `json:"status"` CreatedAt time.Time `json:"created_at"` UpdatedAt time.Time `json:"updated_at"` }
type ManifestFileParams ¶
type ManifestFileStore ¶
type ManifestFileStore interface { Get(manifestId int32, limit int32, offset int32) ([]ManifestFile, error) GetByStatus(manifestId int32, statusArray []manifestFile.Status, limit int, offset int) ([]ManifestFile, error) Add(records []ManifestFileParams) error BatchSetStatus(status manifestFile.Status, uploadIds []string) error SetStatus(status manifestFile.Status, uploadId string) error SyncResponseStatusUpdate(manifestId int32, statusList []manifestFile.FileStatusDTO) error SyncResponseStatusUpdate2(manifestId int32, failedFiles []string) RemoveFromManifest(manifestId int32, removePath string) error ResetStatusForManifest(manifestId int32) error GetNumberOfRowsForStatus(manifestId int32, statusArr []manifestFile.Status, invert bool) (int64, error) ManifestFilesToChannel(ctx context.Context, manifestId int32, statusArr []manifestFile.Status, walker chan<- ManifestFile) }
type ManifestParams ¶
type ManifestStore ¶
type NoClientSessionError ¶
type NoClientSessionError struct{}
func (*NoClientSessionError) Error ¶
func (m *NoClientSessionError) Error() string
type UserInfo ¶
type UserInfo struct { InnerId int `json:"inner_id"` Id string `json:"id"` Name string `json:"name"` SessionToken string `json:"session_token"` RefreshToken string `json:"refresh_token"` TokenExpire time.Time `json:"token_expire"` IdToken string `json:"id_token"` Profile string `json:"profile"'` Environment string `json:"environment"` OrganizationId string `json:"organization_id"` OrganizationName string `json:"organization_name"` UpdatedAt time.Time `json:"updated_at"` }
type UserInfoParams ¶
type UserInfoStore ¶
type UserSettings ¶
type UserSettingsParams ¶
type UserSettingsStore ¶
type UserSettingsStore interface { Get() (*UserSettings, error) CreateNewUserSettings(data UserSettingsParams) (*UserSettings, error) UpdateActiveDataset(datasetId string) error Delete() error }
Click to show internal directories.
Click to hide internal directories.