models

package

Go to main page

Versions in this module

v0

v0.8.5

Apr 5, 2026

Changes in this version

type Bookmark

+ func (b Bookmark) Clone() Bookmark

type BookmarkEntry

+ LastEmitted string

+ type BookmarkUpdate struct

+ Emitted bool

+ NaturalKey interface{}

+ SurrogateKey string

+ Timestamp string

type StreamState

+ PreviousBookmark Bookmark

+ func (s *StreamState) QueueBookmarkUpdate(record map[string]interface{}, emitted bool)

+ func (s *StreamState) StartBookmarkUpdates()

+ func (s *StreamState) StopBookmarkUpdates()

v0.8.4

Apr 3, 2026

Changes in this version

type StreamCatalog

+ SchemaDiscoveredAt string

v0.8.1

Mar 28, 2026

Changes in this version

+ var DISCOVER_MODE bool

v0.8.0

Mar 28, 2026

Changes in this version

+ type BookmarkEntry struct

+ LastSeen string

+ SurrogateKey string

+ type Model interface

+ Create func(source ...interface{}) error

+ Message func() error

+ Read func() error

+ Update func() error

+ type Record map[string]interface

+ func (r *Record) Create(source ...interface{}) error

+ func (r *Record) Read() error

+ func (r Record) Get(key string) interface{}

+ func (r Record) Message() error

+ func (r Record) PassesBookmark() bool

+ func (r Record) Set(key string, value interface{})

+ func (r Record) ToMap() map[string]interface{}

+ func (r Record) Update() error

+ type Schema map[string]interface

+ func (s *Schema) Create(data ...interface{}) error

+ func (s *Schema) CreateFromRecord(record interface{}) error

+ func (s *Schema) Read() error

+ func (s Schema) IsEmpty() bool

+ func (s Schema) Merge(newRecord map[string]interface{}) error

+ func (s Schema) Message() error

+ func (s Schema) Properties() map[string]interface{}

+ func (s Schema) SetProperties(properties map[string]interface{})

+ func (s Schema) ToMap() map[string]interface{}

+ func (s Schema) Update() error

type StreamCatalog

+ func (c *StreamCatalog) ValidateRecordAgainstCatalog(record map[string]interface{}) (bool, error)

type StreamConfig

+ func (c *StreamConfig) Create(source ...interface{}) error

+ func (c *StreamConfig) Message() error

+ func (c *StreamConfig) Read() error

+ func (c *StreamConfig) Update() error

type StreamState

+ LastExtractionStartedAt string

+ func (s *StreamState) StartExtraction()

+ func (s *StreamState) UpdateBookmark(record map[string]interface{})

v0.7.1

Nov 26, 2025

v0.7.0

Nov 26, 2025

v0.6.0

Jul 17, 2025

Changes in this version

+ var FULL_REFRESH bool

+ var STREAM_NAME string

+ var StateMutex sync.RWMutex

+ type AuthConfig struct

+ Basic BasicAuthConfig

+ OAuth OAuthConfig

+ Required bool

+ Strategy string

+ Token TokenAuthConfig

+ type BasicAuthConfig struct

+ Password string

+ Username string

+ type Bookmark struct

+ Latest map[string]string

+ UpdatedAt string

+ type Message struct

+ BookmarkProperties []string

+ KeyProperties []string

+ Record map[string]interface{}

+ Required []string

+ Schema interface{}

+ Stream string

+ Type string

+ Value interface{}

+ type OAuthConfig struct

+ ClientID string

+ ClientSecret string

+ RefreshToken string

+ TokenURL string

+ type PaginationQueryConfig struct

+ QueryIncrement int

+ QueryParameter string

+ QueryValue int

+ type RecordsConfig struct

+ DropFieldPaths [][]string

+ SensitiveFieldPaths [][]string

+ UniqueKeyPath []string

+ type ResponseConfig struct

+ Pagination bool

+ PaginationNextPath []string

+ PaginationQuery PaginationQueryConfig

+ PaginationStrategy string

+ RecordsPath []string

+ type RestConfig struct

+ Auth AuthConfig

+ Response ResponseConfig

+ type StreamCatalog struct

+ KeyProperties []string

+ Schema map[string]interface{}

+ Stream string

+ var DerivedCatalog StreamCatalog

+ func (c *StreamCatalog) Create() error

+ func (c *StreamCatalog) Message() error

+ func (c *StreamCatalog) Read() error

+ func (c *StreamCatalog) RecordVersusCatalog(record map[string]interface{}) (bool, error)

+ func (c *StreamCatalog) Update() error

+ type StreamConfig struct

+ MaxConcurrency int

+ Records RecordsConfig

+ Rest RestConfig

+ SourceType string

+ StreamName string

+ URL string

+ var Config StreamConfig

+ type StreamState struct

+ Bookmark Bookmark

+ Stream string

+ var State StreamState

+ func (s *StreamState) Create() error

+ func (s *StreamState) Message() error

+ func (s *StreamState) Read() error

+ func (s *StreamState) Update(record map[string]interface{})

+ type TokenAuthConfig struct

+ Header string

+ HeaderValue string

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