session

type ConvWithMetadata struct {
	SessionMetadata
	internal.Conv
}

type Counter struct {
	ObjectId string
}

type SchemaConversionSession struct {
	SessionMetadata
	VersionId              string
	PreviousVersionId      []string
	SchemaChanges          string
	SchemaConversionObject string
	CreateTimestamp        time.Time
}

type SessionMetadata struct {
	SessionName  string
	EditorName   string
	DatabaseType string
	DatabaseName string
	Dialect      string
	Notes        []string
	Tags         []string
}

type SessionNameError struct {
	DbName string
	DbType string
}

type SessionParams struct {
	Driver    string `json:"driver"`
	FilePath  string `json:"filePath"`
	DBName    string `json:"dbName"`
	CreatedAt string `json:"createdAt"`
}

type SessionService struct {
	// contains filtered or unexported fields
}

type SessionState struct {
	SourceDB             *sql.DB             // Connection to source database in case of direct connection
	SourceDBConnDetails  SourceDBConnDetails // Connection details for source database
	DbName               string              // Name of source database
	Driver               string              // Name of Spanner migration tool driver in use
	Conv                 *internal.Conv      // Current conversion state
	SessionFile          string              // Path to session file
	IsOffline            bool                // True if the connection to remote metadata database is invalid
	GCPProjectID         string              // GCP project id where the migration resources are created
	SpannerProjectId     string              // Project id of the spanner instance
	SpannerInstanceID    string
	KeyspaceMetadata     cc.KeyspaceMetadataInterface
	Dialect              string
	IsSharded            bool
	TmpDir               string
	ShardedDbConnDetails []profiles.DirectConnectionConfig
	SourceProfileConfig  profiles.SourceProfileConfig
	Region               string
	SpannerDatabaseName  string
	Bucket               string
	RootPath             string
	SessionMetadata      SessionMetadata
	Error                error
	Counter
}

type SessionStore interface {
	GetSessionsMetadata(ctx context.Context) ([]SchemaConversionSession, error)
	GetConvWithMetadata(ctx context.Context, versionId string) (ConvWithMetadata, error)
	SaveSession(ctx context.Context, scs SchemaConversionSession) error
	IsSessionNameUnique(ctx context.Context, scs SchemaConversionSession) (bool, error)
}

type SourceDBConnDetails struct {
	Host           string
	Port           string
	User           string
	Password       string
	DataCenter     string
	Path           string
	ConnectionType string
}