snapshot

Documentation

Index

• Constants
• type Column
• type Errors
  • func NewErrors(err error) *Errors
  • func (e *Errors) AddSnapshotError(err error)
  • func (e *Errors) Error() string
  • func (e *Errors) GetFailedTables() []string
  • func (e *Errors) IsTableError(table string) bool
• type Request
  • func (r *Request) HasFailed() bool
  • func (r *Request) HasFailedForTable(table string) bool
  • func (r *Request) IsPending() bool
  • func (r *Request) MarkCompleted(err error)
  • func (r *Request) MarkInProgress()
• type Row
• type RowProcessor
• type Snapshot
  • func (s *Snapshot) IsValid() bool
• type Status
• type TableError
  • func NewTableError(table string, err error) TableError
  • func (e TableError) Error() string

Constants

const (
	StatusRequested  = Status("requested")
	StatusInProgress = Status("in progress")
	StatusCompleted  = Status("completed")
)

Types

type Column

type Column struct {
	Name  string
	Type  string
	Value any
}

type Errors

type Errors struct {
	Snapshot error        `json:"snapshot,omitempty"`
	Tables   []TableError `json:"tables,omitempty"`
}

func NewErrors

func NewErrors(err error) *Errors

func (*Errors) AddSnapshotError

func (e *Errors) AddSnapshotError(err error)

func (*Errors) Error

func (e *Errors) Error() string

func (*Errors) GetFailedTables

func (e *Errors) GetFailedTables() []string

func (*Errors) IsTableError

func (e *Errors) IsTableError(table string) bool

type Request

type Request struct {
	Snapshot Snapshot
	Status   Status
	Errors   *Errors
}

func (*Request) HasFailed

func (r *Request) HasFailed() bool

func (*Request) HasFailedForTable

func (r *Request) HasFailedForTable(table string) bool

func (*Request) IsPending

func (r *Request) IsPending() bool

func (*Request) MarkCompleted

func (r *Request) MarkCompleted(err error)

func (*Request) MarkInProgress

func (r *Request) MarkInProgress()

type Row

type Row struct {
	Schema  string
	Table   string
	Columns []Column
}

type RowProcessor

type RowProcessor func(context.Context, *Row) error

type Snapshot

type Snapshot struct {
	SchemaName string
	TableNames []string
}

func (*Snapshot) IsValid

func (s *Snapshot) IsValid() bool

type Status

type Status string

type TableError

type TableError struct {
	Table    string `json:"table"`
	ErrorMsg string `json:"error"`
}

func NewTableError

func NewTableError(table string, err error) TableError

func (TableError) Error

func (e TableError) Error() string