writer

type Column struct {
	Name      string
	DataType  int
	MaxLength int
	Nullable  bool
	Mode      int
	Field     reflect.StructField
}

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

type InsertDataOperation struct {
	Context            *TableContext
	Data               any
	InsertArgFactoryFn tracking.InsertArgFactoryFunc
}

type Request struct {
	TableOperation
	InsertDataOperation
	ResponseCh chan Response
	// contains filtered or unexported fields
}

type Response struct {
	Error          error
	Context        *TableContext
	QueuedForRetry bool
}

type RetryableError struct {
	Message              string
	Err                  error
	CausedByMissingTable bool
}

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

type TableOperation struct {
	Operation int
	Name      string
	Columns   []Column
}