models

Documentation

Index

• type Manifest
  • func (m *Manifest) Add(s ManifestParams) (*Manifest, error)
  • func (*Manifest) Get(id int32) (*Manifest, error)
  • func (*Manifest) GetAll() ([]Manifest, error)
  • func (*Manifest) Remove(manifestId int32) error
• type ManifestFile
  • func (*ManifestFile) Add(records []ManifestFileParams) error
  • func (*ManifestFile) Get(manifestId int32, limit int32, offset int32) ([]ManifestFile, error)
  • func (*ManifestFile) GetAll() ([]ManifestFile, error)
• type ManifestFileParams
• type ManifestFileStatus
  • func (s ManifestFileStatus) ManifestFileStatusMap(value string) ManifestFileStatus
  • func (s ManifestFileStatus) String() string
• type ManifestParams
• type NoClientSessionError
  • func (m *NoClientSessionError) Error() string
• type UserInfo
  • func CreateNewUserInfo(data UserInfoParams) (*UserInfo, error)
  • func GetUserInfo(id string, profile string) (*UserInfo, error)
  • func UpdateTokenForUser(user *UserInfo, credentials *pennsieve.APISession) (*UserInfo, error)
  • func (user *UserInfo) GetAll() ([]UserInfo, error)
• type UserInfoParams
• type UserSettings
  • func CreateNewUserSettings(data UserSettingsParams) (*UserSettings, error)
  • func (*UserSettings) Get() (*UserSettings, error)
  • func (*UserSettings) UpdateActiveDataset(datasetId string) error
• type UserSettingsParams

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.ManifestStatus `json:"status"`
	CreatedAt        time.Time               `json:"created_at"`
	UpdatedAt        time.Time               `json:"updated_at"`
}

func (*Manifest) Add

func (m *Manifest) Add(s ManifestParams) (*Manifest, error)

Add adds multiple rows to the UploadRecords database.

func (*Manifest) Get

func (*Manifest) Get(id int32) (*Manifest, error)

Get returns all rows in the Upload Record Table

func (*Manifest) GetAll

func (*Manifest) GetAll() ([]Manifest, error)

GetAll returns all rows in the Upload Record Table

func (*Manifest) Remove

func (*Manifest) Remove(manifestId int32) error

Remove removes a manifest from the local DB.

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"`
	Status     ManifestFileStatus `json:"status"`
	CreatedAt  time.Time          `json:"created_at"`
	UpdatedAt  time.Time          `json:"updated_at"`
}

func (*ManifestFile) Add

func (*ManifestFile) Add(records []ManifestFileParams) error

Add adds multiple rows to the UploadRecords database.

func (*ManifestFile) Get

func (*ManifestFile) Get(manifestId int32, limit int32, offset int32) ([]ManifestFile, error)

func (*ManifestFile) GetAll

func (*ManifestFile) GetAll() ([]ManifestFile, error)

GetAll returns all rows in the Upload Record Table

type ManifestFileParams

type ManifestFileParams struct {
	SourcePath string `json:"source_path"`
	TargetPath string `json:"target_path"`
	ManifestId int32  `json:"manifest_id"`
}

type ManifestFileStatus

type ManifestFileStatus int64

const (
	FileRegistered ManifestFileStatus = iota
	FileSynced
	FileUploading
	FileCompleted
	FileVerified
	FileCancelled
)

func (ManifestFileStatus) ManifestFileStatusMap

func (s ManifestFileStatus) ManifestFileStatusMap(value string) ManifestFileStatus

func (ManifestFileStatus) String

func (s ManifestFileStatus) String() string

type ManifestParams

type ManifestParams struct {
	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"`
}

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"`
}

func CreateNewUserInfo

func CreateNewUserInfo(data UserInfoParams) (*UserInfo, error)

func GetUserInfo

func GetUserInfo(id string, profile string) (*UserInfo, error)

func UpdateTokenForUser

func UpdateTokenForUser(user *UserInfo, credentials *pennsieve.APISession) (*UserInfo, error)

func (*UserInfo) GetAll

func (user *UserInfo) GetAll() ([]UserInfo, error)

type UserInfoParams

type UserInfoParams struct {
	Id           string
	Name         string
	SessionToken string
	RefreshToken string
	Profile      string
	IdToken      string

	Environment      string
	OrganizationId   string
	OrganizationName string
	// contains filtered or unexported fields
}

type UserSettings

type UserSettings struct {
	UserId          string `json:"user_id"`
	Profile         string `json:"profile"`
	UseDatasetId    string `json:"use_dataset_id"`
	UploadSessionId string `json:"upload_session_id"`
}

func CreateNewUserSettings

func CreateNewUserSettings(data UserSettingsParams) (*UserSettings, error)

CreateNewUserSettings creates or replaces existing user-settings row in db.

func (*UserSettings) Get

func (*UserSettings) Get() (*UserSettings, error)

Get returns the UserSettings object or nil if no user-settings are defined.

func (*UserSettings) UpdateActiveDataset

func (*UserSettings) UpdateActiveDataset(datasetId string) error

type UserSettingsParams

type UserSettingsParams struct {
	UserId  string
	Profile string
}