scramjet

package module

Go to main page

Versions in this module

v0

v0.0.17

Feb 20, 2023

Changes in this version

+ func TimestampString() string

type DatabaseInfo

+ Application string

v0.0.16

Mar 18, 2022

v0.0.15

Mar 3, 2022

v0.0.14

Jun 14, 2021

v0.0.13

Mar 22, 2021

Changes in this version

+ func ClearFilteredDeletedFromStaging(filter Filter, typeName string) error

+ func RemoveStagingDeletedFromResourcesFiltered(filter Filter, typeName string) error

type StagingResource

+ func RetrieveFilteredStagingDelete(filter Filter, typeName string) ([]StagingResource, error)

v0.0.12

Jun 14, 2021

v0.0.11

Jun 11, 2021

Changes in this version

type DiffProcessConfig

+ AllowDeleteAll bool

v0.0.10

Mar 29, 2021

Changes in this version

+ func ClearMultipleDeletedFromStaging(items ...Identifiable) error

+ func Configure(conf Config)

+ func Eject(config OutakeConfig) error

+ func Inject(config IntakeConfig) error

+ func RemoveRecords(stubs ...Stub) error

+ func Scramjet(in IntakeConfig, process TrajectConfig, out OutakeConfig) error

+ func ScramjetIntake(in IntakeConfig, process TrajectConfig) error

+ func ScramjetOutake(out OutakeConfig) error

+ func SetConfig(c *Config)

+ func SetLogLevel(lvl LogLevel)

+ func SetLogger(log Logger)

+ func Shutdown()

+ func Traject(config TrajectConfig) error

+ func TransferAll(typeName string, validator ValidatorFunc) error

+ func TransferSubset(typeName string, filter Filter, validator ValidatorFunc) error

type Config

+ LogLevel LogLevel

+ Logger *Logger

+ var Cfg *Config

+ func GetConfig() *Config

+ type IntakeConfig struct

+ ChunkSize int

+ Count int

+ ListMaker IntakeListMaker

+ TypeName string

+ type LogLevel int

+ const DEBUG

+ const INFO

+ func GetLogLevel() LogLevel

+ type Logger interface

+ Debug func(msg string)

+ Info func(msg string)

+ func GetLogger() Logger

+ type OutakeConfig struct

+ Filter *Filter

+ ListMaker OutakeListMaker

+ TypeName string

type Packet

+ func MakePacket(id string, typeName string, obj interface{}) Packet

type Stub

+ func MakeStub(id string, typeName string) Stub

+ type TrajectConfig struct

+ Filter *Filter

+ TypeName string

+ Validator ValidatorFunc

v0.0.9

Mar 22, 2021

Changes in this version

+ func FlagDeletes(sourceDataIds []string, existingData []Resource, config DiffProcessConfig) error

+ func ProcessDiff(config DiffProcessConfig) error

type DiffProcessConfig

+ Checker DeleteChecker

+ Inspector JustTestingInspector

+ type ResourceListMaker func() ([]Resource, error)

v0.0.8

Mar 19, 2021

Changes in this version

+ func BulkMoveStagingToResourcesByFilter(typeName string, filter Filter, items ...StagingResource) error

+ func ClearStagingTypeValidByFilter(typeName string, filter Filter) error

+ func StagingCount() int

type StagingResource

+ func RetrieveAllStaging() ([]StagingResource, error)

v0.0.7

Mar 19, 2021

Changes in this version

type CompareOpt

+ const In

type Filter

+ SubFilter *SubFilter

+ type SubFilter struct

+ MatchField string

+ ParentMatch string

+ Typename string

+ Value string

v0.0.6

Mar 17, 2021

Changes in this version

+ func FilterTypeStagingByQuery(typeName string, filter Filter, validator ValidatorFunc) ([]Identifiable, []Identifiable, error)

+ func ProcessTypeStagingFiltered(typeName string, filter Filter, validator ValidatorFunc) error

+ type CompareOpt string

+ const Eq

+ const Gt

+ const Gte

+ const Lt

+ const Lte

+ type Filter struct

+ Compare CompareOpt

+ Field string

+ Value string

type Resource

+ func RetrieveTypeResourcesByQuery(typeName string, filter Filter) ([]Resource, error)

+ func ScanResources(rows pgx.Rows) ([]Resource, error)

type StagingResource

+ func RetrieveTypeStagingFiltered(typeName string, filter Filter) ([]StagingResource, error)

+ func RetrieveValidStagingFiltered(typeName string, filter Filter) ([]StagingResource, error)

+ func ScanStaging(rows pgx.Rows) ([]StagingResource, error)

v0.0.5

Mar 12, 2021

v0.0.4

Mar 12, 2021

v0.0.3

Mar 12, 2021

Changes in this version

type Resource

+ func RetrieveSingleResource(id string, typeName string) (Resource, error)

v0.0.2

Mar 11, 2021

v0.0.1

Mar 11, 2021

Changes in this version

+ var DBPool *pgxpool.Pool

+ var Name string

+ func AddStagingResource(obj interface{}, id string, typeName string) error

+ func BatchDeleteResourcesFromResources(resources ...Identifiable) error

+ func BatchDeleteStagingFromResources(resources ...Identifiable) error

+ func BatchMarkInvalidInStaging(resources []Identifiable) error

+ func BatchMarkValidInStaging(resources []Identifiable) error

+ func BulkAddStaging(items ...Storeable) error

+ func BulkAddStagingForDelete(items ...Identifiable) error

+ func BulkAddStagingResources(resources ...StagingResource) error

+ func BulkMoveStagingTypeToResources(typeName string, items ...StagingResource) error

+ func BulkRemoveResources(items ...Identifiable) error

+ func BulkRemoveStagingDeletedFromResources(typeName string) error

+ func ClearAllResources() error

+ func ClearAllStaging() error

+ func ClearDeletedFromStaging(id string, typeName string) error

+ func ClearResourceType(typeName string) error

+ func ClearStagingType(typeName string) error

+ func ClearStagingTypeDeletes(typeName string) error

+ func ClearStagingTypeValid(typeName string) error

+ func DeleteFromStaging(res StagingResource) error

+ func Difference(a, b []string) (diff []string)

+ func DropResources() error

+ func DropStaging() error

+ func FilterTypeStaging(typeName string, validator ValidatorFunc) ([]Identifiable, []Identifiable)

+ func GetDbName() string

+ func GetMaxUpdatedAt(typeName string) time.Time

+ func GetPool() *pgxpool.Pool

+ func IntakeInChunks(ins ChunkableIntakeConfig) error

+ func MakeConnectionPool(conf Config) error

+ func MakeResourceSchema()

+ func MakeStagingSchema()

+ func MarkInvalidInStaging(res Storeable) error

+ func MarkValidInStaging(res StagingResource) error

+ func ProcessOutake(proc OutakeProcessConfig) error

+ func ProcessSingleStaging(item Identifiable, validator ValidatorFunc) error

+ func ProcessTypeStaging(typeName string, validator ValidatorFunc) error

+ func RemoveStagingDeletedFromResources(id string, typeName string) error

+ func ResourceCount(typeName string) int

+ func ResourceTableExists() bool

+ func SaveResource(obj Storeable) error

+ func SaveStagingResource(obj Storeable) error

+ func SaveStagingResourceDirect(res StagingResource, typeName string) error

+ func StagingDeleteCount(typeName string) int

+ func StagingResourceExists(id string, typeName string) bool

+ func StagingTableExists() bool

+ func StashStaging(docs ...Storeable) error

+ type ChunkableIntakeConfig struct

+ ChunkSize int

+ Count int

+ Inspector JustTestingInspector

+ JustTest bool

+ ListMaker IntakeListMaker

+ Progress ProgressChecker

+ TypeName string

+ type Config struct

+ Database DatabaseInfo

+ type DatabaseInfo struct

+ AcquireTimeout int

+ Database string

+ MaxConnections int

+ Password string

+ Port int

+ Server string

+ User string

+ type DeleteChecker func([]string)

+ type DiffProcessConfig struct

+ ExistingListMaker ExistingListMaker

+ JustTest bool

+ ListMaker OutakeListMaker

+ TypeName string

+ type ExistingListMaker func() (error, []Resource)

+ type Identifiable interface

+ Identifier func() Identifier

+ func RetrieveDeletedStaging(typeName string) ([]Identifiable, error)

+ type Identifier struct

+ Id string

+ Type string

+ type IntakeListMaker func(int) ([]Storeable, error)

+ type JustTestingInspector func(...interface{})

+ type OutakeListMaker func() ([]string, error)

+ type OutakeProcessConfig struct

+ Checker DeleteChecker

+ Inspector JustTestingInspector

+ JustTest bool

+ ListMaker OutakeListMaker

+ TypeName string

+ type Packet struct

+ Id Identifier

+ Obj interface{}

+ func (p Packet) Identifier() Identifier

+ func (ps Packet) Object() interface{}

+ type ProgressChecker func(int)

+ type Resource struct

+ CreatedAt time.Time

+ Data pgtype.JSON

+ DataB pgtype.JSONB

+ Hash string

+ Id string

+ Type string

+ UpdatedAt time.Time

+ func RetrieveTypeResources(typeName string) ([]Resource, error)

+ func RetrieveTypeResourcesLimited(typeName string, limit int) ([]Resource, error)

+ func (res Resource) Identifier() Identifier

+ type StagingResource struct

+ Data []byte

+ Id string

+ IsValid sql.NullBool

+ ToDelete sql.NullBool

+ Type string

+ func RetrieveInvalidStaging(typeName string) []StagingResource

+ func RetrieveSingleStaging(id string, typeName string) (StagingResource, error)

+ func RetrieveSingleStagingDelete(id string, typeName string) (StagingResource, error)

+ func RetrieveSingleStagingValid(id string, typeName string) (StagingResource, error)

+ func RetrieveTypeStaging(typeName string) []StagingResource

+ func RetrieveValidStaging(typeName string) []StagingResource

+ func (res StagingResource) Identifier() Identifier

+ type Storeable interface

+ Identifier func() Identifier

+ Object func() interface{}

+ type Stub struct

+ Id Identifier

+ func (s Stub) Identifier() Identifier

+ type ValidatorFunc func(json string) bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL